| /dports/misc/concourse/concourse-6.7.2/vendor/google.golang.org/grpc/xds/internal/balancer/ |
| H A D | xds.go | 117 type edsBalancer struct { struct
120 startupTimeout time.Duration
121 xdsStaleTimeout *time.Duration
122 connStateMgr *connStateMgr
126 inFallbackMonitor bool
129 grpcUpdate chan interface{}
130 xdsClientUpdate chan interface{}
131 timer *time.Timer
132 noSubConnAlert <-chan struct{}
139 loadStore lrs.Store
[all …]
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/google.golang.org/grpc/xds/internal/balancer/ |
| H A D | xds.go | 117 type edsBalancer struct { struct
120 startupTimeout time.Duration
121 xdsStaleTimeout *time.Duration
122 connStateMgr *connStateMgr
126 inFallbackMonitor bool
129 grpcUpdate chan interface{}
130 xdsClientUpdate chan interface{}
131 timer *time.Timer
132 noSubConnAlert <-chan struct{}
139 loadStore lrs.Store
[all …]
|
| /dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 107 type edsBalancer struct { struct
109 buildOpts balancer.BuildOptions
110 ctx context.Context
111 cancel context.CancelFunc
114 grpcUpdate chan interface{}
115 xdsClientUpdate chan interface{}
119 edsImpl edsBalancerImplInterface
125 func (x *edsBalancer) run() {
218 func (x *edsBalancer) ResolverError(error) {
248 func (x *edsBalancer) loseContact() {
[all …]
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 107 type edsBalancer struct { struct
109 buildOpts balancer.BuildOptions
110 ctx context.Context
111 cancel context.CancelFunc
114 grpcUpdate chan interface{}
115 xdsClientUpdate chan interface{}
119 edsImpl edsBalancerImplInterface
125 func (x *edsBalancer) run() {
218 func (x *edsBalancer) ResolverError(error) {
248 func (x *edsBalancer) loseContact() {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 107 type edsBalancer struct { struct
109 buildOpts balancer.BuildOptions
110 ctx context.Context
111 cancel context.CancelFunc
114 grpcUpdate chan interface{}
115 xdsClientUpdate chan interface{}
119 edsImpl edsBalancerImplInterface
125 func (x *edsBalancer) run() {
218 func (x *edsBalancer) ResolverError(error) {
248 func (x *edsBalancer) loseContact() {
[all …]
|
| /dports/net/storj/storj-1.45.3/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 107 type edsBalancer struct { struct
109 buildOpts balancer.BuildOptions
110 ctx context.Context
111 cancel context.CancelFunc
114 grpcUpdate chan interface{}
115 xdsClientUpdate chan interface{}
119 edsImpl edsBalancerImplInterface
125 func (x *edsBalancer) run() {
218 func (x *edsBalancer) ResolverError(error) {
248 func (x *edsBalancer) loseContact() {
[all …]
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 107 type edsBalancer struct { struct
109 buildOpts balancer.BuildOptions
110 ctx context.Context
111 cancel context.CancelFunc
114 grpcUpdate chan interface{}
115 xdsClientUpdate chan interface{}
119 edsImpl edsBalancerImplInterface
125 func (x *edsBalancer) run() {
218 func (x *edsBalancer) ResolverError(error) {
248 func (x *edsBalancer) loseContact() {
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 107 type edsBalancer struct { struct
109 buildOpts balancer.BuildOptions
110 ctx context.Context
111 cancel context.CancelFunc
114 grpcUpdate chan interface{}
115 xdsClientUpdate chan interface{}
119 edsImpl edsBalancerImplInterface
125 func (x *edsBalancer) run() {
218 func (x *edsBalancer) ResolverError(error) {
248 func (x *edsBalancer) loseContact() {
[all …]
|
| /dports/net/v2ray/v2ray-core-4.36.2/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 127 type edsBalancer struct { struct
128 cc balancer.ClientConn
129 closed *grpcsync.Event
130 logger *grpclog.PrefixLogger
138 xdsClient xdsClientInterface
139 lsw *loadStoreWrapper
145 edsServiceName string
146 cancelEndpointsWatch func()
148 cancelLoadReport func()
155 func (x *edsBalancer) run() {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 115 type edsBalancer struct { struct
117 buildOpts balancer.BuildOptions
118 ctx context.Context
119 cancel context.CancelFunc
121 logger *grpclog.PrefixLogger
124 grpcUpdate chan interface{}
125 xdsClientUpdate chan interface{}
126 childPolicyUpdate *buffer.Unbounded
130 edsImpl edsBalancerImplInterface
136 func (x *edsBalancer) run() {
[all …]
|
| /dports/www/pomerium/pomerium-0.8.3/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 115 type edsBalancer struct { struct
117 buildOpts balancer.BuildOptions
118 ctx context.Context
119 cancel context.CancelFunc
121 logger *grpclog.PrefixLogger
124 grpcUpdate chan interface{}
125 xdsClientUpdate chan interface{}
126 childPolicyUpdate *buffer.Unbounded
130 edsImpl edsBalancerImplInterface
136 func (x *edsBalancer) run() {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 115 type edsBalancer struct { struct
117 buildOpts balancer.BuildOptions
118 ctx context.Context
119 cancel context.CancelFunc
121 logger *grpclog.PrefixLogger
124 grpcUpdate chan interface{}
125 xdsClientUpdate chan interface{}
126 childPolicyUpdate *buffer.Unbounded
130 edsImpl edsBalancerImplInterface
136 func (x *edsBalancer) run() {
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 131 type edsBalancer struct { struct
132 cc balancer.ClientConn
133 closed *grpcsync.Event
134 done *grpcsync.Event
135 logger *grpclog.PrefixLogger
143 xdsClient xdsClientInterface
144 lsw *loadStoreWrapper
150 edsServiceName string
151 cancelEndpointsWatch func()
153 cancelLoadReport func()
[all …]
|
| /dports/sysutils/restic/restic-0.12.1/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 131 type edsBalancer struct { struct
132 cc balancer.ClientConn
133 closed *grpcsync.Event
134 done *grpcsync.Event
135 logger *grpclog.PrefixLogger
143 xdsClient xdsClientInterface
144 lsw *loadStoreWrapper
150 edsServiceName string
151 cancelEndpointsWatch func()
153 cancelLoadReport func()
[all …]
|
| /dports/textproc/gitlab-elasticsearch-indexer/gitlab-elasticsearch-indexer-ef1440548effec15831eda2d246dacc43233cefb/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 131 type edsBalancer struct { struct
132 cc balancer.ClientConn
133 closed *grpcsync.Event
134 done *grpcsync.Event
135 logger *grpclog.PrefixLogger
143 xdsClient xdsClientInterface
144 lsw *loadStoreWrapper
150 edsServiceName string
151 cancelEndpointsWatch func()
153 cancelLoadReport func()
[all …]
|
| /dports/sysutils/terraform-docs/terraform-docs-0.16.0/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 131 type edsBalancer struct { struct
132 cc balancer.ClientConn
133 closed *grpcsync.Event
134 done *grpcsync.Event
135 logger *grpclog.PrefixLogger
143 xdsClient xdsClientInterface
144 lsw *loadStoreWrapper
150 edsServiceName string
151 cancelEndpointsWatch func()
153 cancelLoadReport func()
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 127 type edsBalancer struct { struct
128 cc balancer.ClientConn
129 closed *grpcsync.Event
130 logger *grpclog.PrefixLogger
138 xdsClient xdsClientInterface
139 lsw *loadStoreWrapper
145 edsServiceName string
146 cancelEndpointsWatch func()
148 cancelLoadReport func()
155 func (x *edsBalancer) run() {
[all …]
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 127 type edsBalancer struct { struct
128 cc balancer.ClientConn
129 closed *grpcsync.Event
130 logger *grpclog.PrefixLogger
138 xdsClient xdsClientInterface
139 lsw *loadStoreWrapper
145 edsServiceName string
146 cancelEndpointsWatch func()
148 cancelLoadReport func()
155 func (x *edsBalancer) run() {
[all …]
|
| /dports/databases/litestream/litestream-0.3.6/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 127 type edsBalancer struct { struct
128 cc balancer.ClientConn
129 closed *grpcsync.Event
130 logger *grpclog.PrefixLogger
138 xdsClient xdsClientInterface
139 lsw *loadStoreWrapper
145 edsServiceName string
146 cancelEndpointsWatch func()
148 cancelLoadReport func()
155 func (x *edsBalancer) run() {
[all …]
|
| /dports/net/grpcurl/grpcurl-1.8.5/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 127 type edsBalancer struct { struct
128 cc balancer.ClientConn
129 closed *grpcsync.Event
130 logger *grpclog.PrefixLogger
138 xdsClient xdsClientInterface
139 lsw *loadStoreWrapper
145 edsServiceName string
146 cancelEndpointsWatch func()
148 cancelLoadReport func()
155 func (x *edsBalancer) run() {
[all …]
|
| /dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 108 type edsBalancer struct { struct
110 buildOpts balancer.BuildOptions
111 ctx context.Context
112 cancel context.CancelFunc
114 logger *grpclog.PrefixLogger
117 grpcUpdate chan interface{}
118 xdsClientUpdate chan *edsUpdate
119 childPolicyUpdate *buffer.Unbounded
123 edsImpl edsBalancerImplInterface
129 func (x *edsBalancer) run() {
[all …]
|
| /dports/net/evans/evans-0.9.1/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 108 type edsBalancer struct { struct
110 buildOpts balancer.BuildOptions
111 ctx context.Context
112 cancel context.CancelFunc
114 logger *grpclog.PrefixLogger
117 grpcUpdate chan interface{}
118 xdsClientUpdate chan *edsUpdate
119 childPolicyUpdate *buffer.Unbounded
123 edsImpl edsBalancerImplInterface
129 func (x *edsBalancer) run() {
[all …]
|
| /dports/sysutils/helmfile/helmfile-0.138.7/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 108 type edsBalancer struct { struct
110 buildOpts balancer.BuildOptions
111 ctx context.Context
112 cancel context.CancelFunc
114 logger *grpclog.PrefixLogger
117 grpcUpdate chan interface{}
118 xdsClientUpdate chan *edsUpdate
119 childPolicyUpdate *buffer.Unbounded
123 edsImpl edsBalancerImplInterface
129 func (x *edsBalancer) run() {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 104 type edsBalancer struct { struct
105 cc balancer.ClientConn // *xdsClientConn
106 buildOpts balancer.BuildOptions
107 closed *grpcsync.Event
108 logger *grpclog.PrefixLogger
111 grpcUpdate chan interface{}
112 xdsClientUpdate chan *edsUpdate
113 childPolicyUpdate *buffer.Unbounded
117 edsImpl edsBalancerImplInterface
123 func (x *edsBalancer) run() {
[all …]
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/google.golang.org/grpc/xds/internal/balancer/edsbalancer/ |
| H A D | eds.go | 104 type edsBalancer struct { struct
105 cc balancer.ClientConn // *xdsClientConn
106 closed *grpcsync.Event
107 logger *grpclog.PrefixLogger
110 grpcUpdate chan interface{}
111 xdsClientUpdate chan *edsUpdate
112 childPolicyUpdate *buffer.Unbounded
116 edsImpl edsBalancerImplInterface
122 func (x *edsBalancer) run() {
232 func (x *edsBalancer) ResolverError(err error) {
[all …]
|