Home
last modified time | relevance | path

Searched defs:ClusterClient (Results 1 – 25 of 93) sorted by relevance

1234

/dports/net/traefik/traefik-2.6.1/vendor/gopkg.in/redis.v5/
H A Dcluster.go329 type ClusterClient struct { struct
330 cmdable
332 opt *ClusterOptions
333 cmds map[string]*CommandInfo
334 nodes *clusterNodes
335 _state atomic.Value
338 reloading uint32
340 closed bool
428 func (c *ClusterClient) Close() error {
597 func (c *ClusterClient) lazyReloadSlots() {
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/go-redis/redis/
H A Dcluster.go558 type ClusterClient struct { struct
559 cmdable
561 ctx context.Context
563 opt *ClusterOptions
564 nodes *clusterNodes
565 state *clusterStateHolder
566 cmdsInfoCache *cmdsInfoCache
568 process func(Cmder) error
569 processPipeline func([]Cmder) error
570 processTxPipeline func([]Cmder) error
[all …]
/dports/multimedia/livego/livego-0.0.15/vendor/github.com/go-redis/redis/v7/
H A Dcluster.go659 type ClusterClient struct { struct
660 *clusterClient
661 cmdable
662 hooks
663 ctx context.Context
711 func (c *ClusterClient) ReloadState() error {
720 func (c *ClusterClient) Close() error {
1159 func (c *ClusterClient) pipelineReadCmds(
1183 func (c *ClusterClient) checkMovedErr(
1363 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/www/pomerium/pomerium-0.8.3/vendor/github.com/go-redis/redis/v7/
H A Dcluster.go659 type ClusterClient struct { struct
660 *clusterClient
661 cmdable
662 hooks
663 ctx context.Context
711 func (c *ClusterClient) ReloadState() error {
720 func (c *ClusterClient) Close() error {
1159 func (c *ClusterClient) pipelineReadCmds(
1183 func (c *ClusterClient) checkMovedErr(
1363 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go696 type ClusterClient struct { struct
697 *clusterClient
698 cmdable
699 hooks
700 ctx context.Context
856 func (c *ClusterClient) ForEachMaster(
894 func (c *ClusterClient) ForEachSlave(
932 func (c *ClusterClient) ForEachShard(
1233 func (c *ClusterClient) checkMovedErr(
1421 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go696 type ClusterClient struct { struct
697 *clusterClient
698 cmdable
699 hooks
700 ctx context.Context
854 func (c *ClusterClient) ForEachMaster(
892 func (c *ClusterClient) ForEachSlave(
930 func (c *ClusterClient) ForEachShard(
1231 func (c *ClusterClient) checkMovedErr(
1419 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go696 type ClusterClient struct { struct
697 *clusterClient
698 cmdable
699 hooks
700 ctx context.Context
856 func (c *ClusterClient) ForEachMaster(
894 func (c *ClusterClient) ForEachSlave(
932 func (c *ClusterClient) ForEachShard(
1233 func (c *ClusterClient) checkMovedErr(
1421 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/net/storj/storj-1.45.3/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go682 type ClusterClient struct { struct
683 *clusterClient
684 cmdable
685 hooks
686 ctx context.Context
840 func (c *ClusterClient) ForEachMaster(
878 func (c *ClusterClient) ForEachSlave(
916 func (c *ClusterClient) ForEachShard(
1217 func (c *ClusterClient) checkMovedErr(
1405 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/games/automuteus/automuteus-6.15.2/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go684 type ClusterClient struct { struct
685 *clusterClient
686 cmdable
687 hooks
688 ctx context.Context
842 func (c *ClusterClient) ForEachMaster(
880 func (c *ClusterClient) ForEachSlave(
918 func (c *ClusterClient) ForEachShard(
1219 func (c *ClusterClient) checkMovedErr(
1407 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/www/gitea/gitea-1.16.5/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go684 type ClusterClient struct { struct
685 *clusterClient
686 cmdable
687 hooks
688 ctx context.Context
842 func (c *ClusterClient) ForEachMaster(
880 func (c *ClusterClient) ForEachSlave(
918 func (c *ClusterClient) ForEachShard(
1219 func (c *ClusterClient) checkMovedErr(
1407 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go684 type ClusterClient struct { struct
685 *clusterClient
686 cmdable
687 hooks
688 ctx context.Context
842 func (c *ClusterClient) ForEachMaster(
880 func (c *ClusterClient) ForEachSlave(
918 func (c *ClusterClient) ForEachShard(
1219 func (c *ClusterClient) checkMovedErr(
1407 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/security/vuls/vuls-0.13.7/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go678 type ClusterClient struct { struct
679 *clusterClient
680 cmdable
681 hooks
682 ctx context.Context
836 func (c *ClusterClient) ForEachMaster(
874 func (c *ClusterClient) ForEachSlave(
912 func (c *ClusterClient) ForEachShard(
1213 func (c *ClusterClient) checkMovedErr(
1397 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go678 type ClusterClient struct { struct
679 *clusterClient
680 cmdable
681 hooks
682 ctx context.Context
836 func (c *ClusterClient) ForEachMaster(
874 func (c *ClusterClient) ForEachSlave(
912 func (c *ClusterClient) ForEachShard(
1213 func (c *ClusterClient) checkMovedErr(
1397 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/github.com/go-redis/redis/v8/
H A Dcluster.go678 type ClusterClient struct { struct
679 *clusterClient
680 cmdable
681 hooks
682 ctx context.Context
836 func (c *ClusterClient) ForEachMaster(
874 func (c *ClusterClient) ForEachSlave(
912 func (c *ClusterClient) ForEachShard(
1213 func (c *ClusterClient) checkMovedErr(
1397 func (c *ClusterClient) cmdsMoved(
[all …]
/dports/devel/sccache/sccache-0.2.15/cargo-crates/redis-0.17.0/src/
H A Dcluster.rs88 pub fn open(self) -> RedisResult<ClusterClient> { in open()
109 pub struct ClusterClient { struct
115 impl ClusterClient { implementation
123 pub fn open<T: IntoConnectionInfo>(initial_nodes: Vec<T>) -> RedisResult<ClusterClient> { in open()
140 fn open_internal(builder: ClusterClientBuilder) -> RedisResult<ClusterClient> { in open_internal()
604 impl Clone for ClusterClient { implementation
605 fn clone(&self) -> ClusterClient { in clone()
/dports/www/oauth2-proxy/oauth2-proxy-7.2.0/pkg/sessions/redis/
H A Dclient.go50 *redis.ClusterClient anonMember
53 func newClusterClient(c *redis.ClusterClient) Client {
/dports/textproc/py-elasticsearch5/elasticsearch-py-719a94ab4/elasticsearch/client/
H A Dcluster.py3 class ClusterClient(NamespacedClient): class
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/concourse/dex/vendor/github.com/coreos/etcd/clientv3/
H A Dcluster.go53 func NewClusterFromClusterClient(remote pb.ClusterClient) Cluster {
/dports/textproc/py-elasticsearch6/elasticsearch-6.8.2/elasticsearch/client/
H A Dcluster.py21 class ClusterClient(NamespacedClient): class
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/clientv3/
H A Dcluster.go61 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {
/dports/misc/concourse/vault-bdd38fca2cff/vendor/go.etcd.io/etcd/clientv3/
H A Dcluster.go61 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/vault/vendor/go.etcd.io/etcd/clientv3/
H A Dcluster.go61 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/github.com/hashicorp/vault/vendor/go.etcd.io/etcd/clientv3/
H A Dcluster.go61 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {
/dports/devel/etcd32/etcd-3.2.32/clientv3/
H A Dcluster.go60 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/hashicorp/vault/vendor/go.etcd.io/etcd/clientv3/
H A Dcluster.go61 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {

1234