/dports/net/traefik/traefik-2.6.1/vendor/gopkg.in/redis.v5/ |
H A D | cluster.go | 329 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 D | cluster.go | 558 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 D | cluster.go | 659 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 D | cluster.go | 659 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 D | cluster.go | 696 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 D | cluster.go | 696 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 D | cluster.go | 696 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 D | cluster.go | 682 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 D | cluster.go | 684 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 D | cluster.go | 684 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 D | cluster.go | 684 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 D | cluster.go | 678 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 D | cluster.go | 678 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 D | cluster.go | 678 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 D | cluster.rs | 88 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 D | client.go | 50 *redis.ClusterClient anonMember 53 func newClusterClient(c *redis.ClusterClient) Client {
|
/dports/textproc/py-elasticsearch5/elasticsearch-py-719a94ab4/elasticsearch/client/ |
H A D | cluster.py | 3 class ClusterClient(NamespacedClient): class
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/concourse/dex/vendor/github.com/coreos/etcd/clientv3/ |
H A D | cluster.go | 53 func NewClusterFromClusterClient(remote pb.ClusterClient) Cluster {
|
/dports/textproc/py-elasticsearch6/elasticsearch-6.8.2/elasticsearch/client/ |
H A D | cluster.py | 21 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 D | cluster.go | 61 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {
|
/dports/misc/concourse/vault-bdd38fca2cff/vendor/go.etcd.io/etcd/clientv3/ |
H A D | cluster.go | 61 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 D | cluster.go | 61 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 D | cluster.go | 61 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {
|
/dports/devel/etcd32/etcd-3.2.32/clientv3/ |
H A D | cluster.go | 60 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 D | cluster.go | 61 func NewClusterFromClusterClient(remote pb.ClusterClient, c *Client) Cluster {
|