/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 124 type clusterNode struct { struct 126 cancelFunc func() 129 children []*clusterNode 133 clusterUpdate xdsclient.ClusterUpdate 139 receivedUpdate bool 141 clusterHandler *clusterHandler 162 func (c *clusterNode) delete() { 170 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 200 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/net/drive/drive-0.4.0/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 124 type clusterNode struct { struct 126 cancelFunc func() 129 children []*clusterNode 133 clusterUpdate xdsclient.ClusterUpdate 139 receivedUpdate bool 141 clusterHandler *clusterHandler 162 func (c *clusterNode) delete() { 170 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 200 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 124 type clusterNode struct { struct 126 cancelFunc func() 129 children []*clusterNode 133 clusterUpdate xdsclient.ClusterUpdate 139 receivedUpdate bool 141 clusterHandler *clusterHandler 162 func (c *clusterNode) delete() { 170 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 200 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 124 type clusterNode struct { struct 126 cancelFunc func() 129 children []*clusterNode 133 clusterUpdate xdsclient.ClusterUpdate 139 receivedUpdate bool 141 clusterHandler *clusterHandler 162 func (c *clusterNode) delete() { 170 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 200 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 124 type clusterNode struct { struct 126 cancelFunc func() 129 children []*clusterNode 133 clusterUpdate xdsclient.ClusterUpdate 139 receivedUpdate bool 141 clusterHandler *clusterHandler 162 func (c *clusterNode) delete() { 170 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 200 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/security/xray-core/Xray-core-1.5.0/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 124 type clusterNode struct { struct 126 cancelFunc func() 129 children []*clusterNode 133 clusterUpdate xdsclient.ClusterUpdate 139 receivedUpdate bool 141 clusterHandler *clusterHandler 162 func (c *clusterNode) delete() { 170 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 200 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/www/gitea/gitea-1.16.5/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 134 type clusterNode struct { struct 136 cancelFunc func() 139 children []*clusterNode 143 clusterUpdate xdsresource.ClusterUpdate 149 receivedUpdate bool 151 clusterHandler *clusterHandler 172 func (c *clusterNode) delete() { 180 func (c *clusterNode) constructClusterUpdate() ([]xdsresource.ClusterUpdate, error) { 210 func (c *clusterNode) handleResp(clusterUpdate xdsresource.ClusterUpdate, err error) {
|
/dports/net/cloudquery/cloudquery-0.16.0/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 133 type clusterNode struct { struct 135 cancelFunc func() 138 children []*clusterNode 142 clusterUpdate xdsclient.ClusterUpdate 148 receivedUpdate bool 150 clusterHandler *clusterHandler 171 func (c *clusterNode) delete() { 179 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 209 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 133 type clusterNode struct { struct 135 cancelFunc func() 138 children []*clusterNode 142 clusterUpdate xdsclient.ClusterUpdate 148 receivedUpdate bool 150 clusterHandler *clusterHandler 171 func (c *clusterNode) delete() { 179 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 209 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 133 type clusterNode struct { struct 135 cancelFunc func() 138 children []*clusterNode 142 clusterUpdate xdsclient.ClusterUpdate 148 receivedUpdate bool 150 clusterHandler *clusterHandler 171 func (c *clusterNode) delete() { 179 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 209 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/www/grafana8/grafana-8.3.6/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 133 type clusterNode struct { struct 135 cancelFunc func() 138 children []*clusterNode 142 clusterUpdate xdsclient.ClusterUpdate 148 receivedUpdate bool 150 clusterHandler *clusterHandler 171 func (c *clusterNode) delete() { 179 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 209 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/ftp/sftpgo/sftpgo-2.2.0/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/ |
H A D | cluster_handler.go | 133 type clusterNode struct { struct 135 cancelFunc func() 138 children []*clusterNode 142 clusterUpdate xdsclient.ClusterUpdate 148 receivedUpdate bool 150 clusterHandler *clusterHandler 171 func (c *clusterNode) delete() { 179 func (c *clusterNode) constructClusterUpdate() ([]xdsclient.ClusterUpdate, error) { 209 func (c *clusterNode) handleResp(clusterUpdate xdsclient.ClusterUpdate, err error) {
|
/dports/databases/redis6/redis-6.0.16/src/ |
H A D | cluster.h | 114 typedef struct clusterNode { struct 122 struct clusterNode **slaves; /* pointers to slave nodes */ argument 123 struct clusterNode *slaveof; /* pointer to the master node. Note that it argument 140 } clusterNode; argument
|
/dports/databases/redis5/redis-5.0.14/src/ |
H A D | cluster.h | 116 typedef struct clusterNode { struct 124 struct clusterNode **slaves; /* pointers to slave nodes */ argument 125 struct clusterNode *slaveof; /* pointer to the master node. Note that it argument 142 } clusterNode; argument
|
/dports/databases/redis-devel/redis-0e5b813/src/ |
H A D | cluster.h | 113 typedef struct clusterNode { struct 122 struct clusterNode **slaves; /* pointers to slave nodes */ argument 123 struct clusterNode *slaveof; /* pointer to the master node. Note that it argument 142 } clusterNode; argument
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/go-redis/redis/ |
H A D | cluster.go | 125 type clusterNode struct { struct 126 Client *Client 128 latency uint32 // atomic 129 generation uint32 // atomic 130 loading uint32 // atomic 148 func (n *clusterNode) Close() error { 152 func (n *clusterNode) Test() error { 156 func (n *clusterNode) updateLatency() { 174 func (n *clusterNode) MarkAsLoading() { 178 func (n *clusterNode) Loading() bool { [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 | 172 type clusterNode struct { struct 173 Client *Client 175 latency uint32 // atomic 176 generation uint32 // atomic 177 failing uint32 // atomic 195 func (n *clusterNode) String() string { 199 func (n *clusterNode) Close() error { 203 func (n *clusterNode) updateLatency() { 224 func (n *clusterNode) MarkAsFailing() { 228 func (n *clusterNode) Failing() bool { [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-redis/redis/v8/ |
H A D | cluster.go | 172 type clusterNode struct { struct 173 Client *Client 175 latency uint32 // atomic 176 generation uint32 // atomic 177 failing uint32 // atomic 195 func (n *clusterNode) String() string { 199 func (n *clusterNode) Close() error { 203 func (n *clusterNode) updateLatency() { 224 func (n *clusterNode) MarkAsFailing() { 228 func (n *clusterNode) Failing() bool { [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 | 172 type clusterNode struct { struct 173 Client *Client 175 latency uint32 // atomic 176 generation uint32 // atomic 177 failing uint32 // atomic 195 func (n *clusterNode) String() string { 199 func (n *clusterNode) Close() error { 203 func (n *clusterNode) updateLatency() { 224 func (n *clusterNode) MarkAsFailing() { 228 func (n *clusterNode) Failing() bool { [all …]
|
/dports/net/storj/storj-1.45.3/vendor/github.com/go-redis/redis/v8/ |
H A D | cluster.go | 168 type clusterNode struct { struct 169 Client *Client 171 latency uint32 // atomic 172 generation uint32 // atomic 173 failing uint32 // atomic 191 func (n *clusterNode) String() string { 195 func (n *clusterNode) Close() error { 199 func (n *clusterNode) updateLatency() { 220 func (n *clusterNode) MarkAsFailing() { 224 func (n *clusterNode) Failing() bool { [all …]
|
/dports/multimedia/livego/livego-0.0.15/vendor/github.com/go-redis/redis/v7/ |
H A D | cluster.go | 153 type clusterNode struct { struct 154 Client *Client 156 latency uint32 // atomic 157 generation uint32 // atomic 158 failing uint32 // atomic 180 func (n *clusterNode) String() string { 184 func (n *clusterNode) Close() error { 188 func (n *clusterNode) updateLatency() { 206 func (n *clusterNode) MarkAsFailing() { 210 func (n *clusterNode) Failing() bool { [all …]
|
/dports/security/vuls/vuls-0.13.7/vendor/github.com/go-redis/redis/v8/ |
H A D | cluster.go | 164 type clusterNode struct { struct 165 Client *Client 167 latency uint32 // atomic 168 generation uint32 // atomic 169 failing uint32 // atomic 187 func (n *clusterNode) String() string { 191 func (n *clusterNode) Close() error { 195 func (n *clusterNode) updateLatency() { 216 func (n *clusterNode) MarkAsFailing() { 220 func (n *clusterNode) Failing() bool { [all …]
|
/dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/github.com/go-redis/redis/v8/ |
H A D | cluster.go | 164 type clusterNode struct { struct 165 Client *Client 167 latency uint32 // atomic 168 generation uint32 // atomic 169 failing uint32 // atomic 187 func (n *clusterNode) String() string { 191 func (n *clusterNode) Close() error { 195 func (n *clusterNode) updateLatency() { 216 func (n *clusterNode) MarkAsFailing() { 220 func (n *clusterNode) Failing() bool { [all …]
|
/dports/games/automuteus/automuteus-6.15.2/vendor/github.com/go-redis/redis/v8/ |
H A D | cluster.go | 168 type clusterNode struct { struct 169 Client *Client 171 latency uint32 // atomic 172 generation uint32 // atomic 173 failing uint32 // atomic 191 func (n *clusterNode) String() string { 195 func (n *clusterNode) Close() error { 199 func (n *clusterNode) updateLatency() { 220 func (n *clusterNode) MarkAsFailing() { 224 func (n *clusterNode) Failing() bool { [all …]
|
/dports/www/pomerium/pomerium-0.8.3/vendor/github.com/go-redis/redis/v7/ |
H A D | cluster.go | 153 type clusterNode struct { struct 154 Client *Client 156 latency uint32 // atomic 157 generation uint32 // atomic 158 failing uint32 // atomic 180 func (n *clusterNode) String() string { 184 func (n *clusterNode) Close() error { 188 func (n *clusterNode) updateLatency() { 206 func (n *clusterNode) MarkAsFailing() { 210 func (n *clusterNode) Failing() bool { [all …]
|