Home
last modified time | relevance | path

Searched defs:clusterNode (Results 1 – 25 of 55) sorted by relevance

123

/dports/net/rclone/rclone-1.57.0/vendor/google.golang.org/grpc/xds/internal/balancer/cdsbalancer/
H A Dcluster_handler.go124 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 Dcluster_handler.go124 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 Dcluster_handler.go124 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 Dcluster_handler.go124 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 Dcluster_handler.go124 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 Dcluster_handler.go124 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 Dcluster_handler.go134 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 Dcluster_handler.go133 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 Dcluster_handler.go133 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 Dcluster_handler.go133 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 Dcluster_handler.go133 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 Dcluster_handler.go133 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 Dcluster.h114 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 Dcluster.h116 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 Dcluster.h113 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 Dcluster.go125 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 Dcluster.go172 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 Dcluster.go172 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 Dcluster.go172 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 Dcluster.go168 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 Dcluster.go153 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 Dcluster.go164 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 Dcluster.go164 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 Dcluster.go168 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 Dcluster.go153 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 …]

123