Home
last modified time | relevance | path

Searched refs:v2c (Results 1 – 25 of 1164) sorted by relevance

12345678910>>...47

/dports/security/vault/vault-1.8.2/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go102 v2c := &v2Client{
118 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
120 go v2c.run()
121 return v2c
126 v2c.cancelCtx()
133 go v2c.send()
210 v2c.mu.Lock()
233 v2c.mu.Lock()
268 v2c.mu.Lock()
477 v2c.mu.Lock()
[all …]
/dports/www/pomerium/pomerium-0.8.3/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go102 v2c := &v2Client{
118 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
120 go v2c.run()
121 return v2c
126 v2c.cancelCtx()
133 go v2c.send()
210 v2c.mu.Lock()
233 v2c.mu.Lock()
261 v2c.mu.Lock()
464 v2c.mu.Lock()
[all …]
/dports/sysutils/istio/istio-1.6.7/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go102 v2c := &v2Client{
118 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
120 go v2c.run()
121 return v2c
126 v2c.cancelCtx()
133 go v2c.send()
210 v2c.mu.Lock()
233 v2c.mu.Lock()
268 v2c.mu.Lock()
477 v2c.mu.Lock()
[all …]
/dports/net/grpcui/grpcui-1.1.0/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go107 v2c := &v2Client{
122 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
124 go v2c.run()
125 return v2c
130 v2c.cancelCtx()
137 go v2c.send()
214 v2c.mu.Lock()
240 v2c.mu.Lock()
268 v2c.hostname = ""
306 v2c.mu.Lock()
[all …]
/dports/net/evans/evans-0.9.1/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go107 v2c := &v2Client{
122 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
124 go v2c.run()
125 return v2c
130 v2c.cancelCtx()
137 go v2c.send()
214 v2c.mu.Lock()
240 v2c.mu.Lock()
268 v2c.hostname = ""
306 v2c.mu.Lock()
[all …]
/dports/security/lego/lego-4.5.3/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go97 v2c := &v2Client{
107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
109 go v2c.run()
110 return v2c
115 v2c.cancelCtx()
196 v2c.mu.Lock()
218 v2c.mu.Lock()
244 v2c.mu.Lock()
420 v2c.mu.Lock()
449 v2c.mu.Lock()
[all …]
/dports/misc/concourse/concourse-6.7.2/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go97 v2c := &v2Client{
107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
109 go v2c.run()
110 return v2c
115 v2c.cancelCtx()
196 v2c.mu.Lock()
218 v2c.mu.Lock()
244 v2c.mu.Lock()
420 v2c.mu.Lock()
449 v2c.mu.Lock()
[all …]
/dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go97 v2c := &v2Client{
107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
109 go v2c.run()
110 return v2c
115 v2c.cancelCtx()
196 v2c.mu.Lock()
218 v2c.mu.Lock()
244 v2c.mu.Lock()
420 v2c.mu.Lock()
449 v2c.mu.Lock()
[all …]
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go97 v2c := &v2Client{
107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
109 go v2c.run()
110 return v2c
115 v2c.cancelCtx()
196 v2c.mu.Lock()
218 v2c.mu.Lock()
244 v2c.mu.Lock()
420 v2c.mu.Lock()
449 v2c.mu.Lock()
[all …]
/dports/sysutils/helm/helm-3.5.2/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go97 v2c := &v2Client{
107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
109 go v2c.run()
110 return v2c
115 v2c.cancelCtx()
196 v2c.mu.Lock()
218 v2c.mu.Lock()
244 v2c.mu.Lock()
420 v2c.mu.Lock()
449 v2c.mu.Lock()
[all …]
/dports/net/storj/storj-1.45.3/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go97 v2c := &v2Client{
107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
109 go v2c.run()
110 return v2c
115 v2c.cancelCtx()
196 v2c.mu.Lock()
218 v2c.mu.Lock()
244 v2c.mu.Lock()
420 v2c.mu.Lock()
449 v2c.mu.Lock()
[all …]
/dports/devel/mutagen/mutagen-0.11.8/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go97 v2c := &v2Client{
107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
109 go v2c.run()
110 return v2c
115 v2c.cancelCtx()
196 v2c.mu.Lock()
218 v2c.mu.Lock()
244 v2c.mu.Lock()
420 v2c.mu.Lock()
449 v2c.mu.Lock()
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/google.golang.org/grpc/xds/internal/client/
H A Dv2client.go97 v2c := &v2Client{
107 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
109 go v2c.run()
110 return v2c
115 v2c.cancelCtx()
196 v2c.mu.Lock()
218 v2c.mu.Lock()
244 v2c.mu.Lock()
420 v2c.mu.Lock()
449 v2c.mu.Lock()
[all …]
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go66 v2c := &client{
72 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
74 return v2c, nil
108 v2c.mu.Lock()
115 v2c.ldsWatchCount++
120 v2c.mu.Unlock()
127 v2c.mu.Lock()
134 v2c.ldsWatchCount--
139 v2c.mu.Unlock()
242 v2c.mu.Lock()
[all …]
/dports/net-im/dendrite/dendrite-0.5.1/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go69 v2c := &client{
76 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
78 return v2c, nil
113 v2c.mu.Lock()
120 v2c.ldsWatchCount++
125 v2c.mu.Unlock()
132 v2c.mu.Lock()
139 v2c.ldsWatchCount--
144 v2c.mu.Unlock()
251 v2c.mu.Lock()
[all …]
/dports/net-mgmt/py-pysnmp/pysnmp-4.4.9/pysnmp/proto/proxy/
H A Drfc2576.py8 from pysnmp.proto.api import v1, v2c
14 v1.Integer.tagSet: v2c.Integer32(),
16 v1.Null.tagSet: v2c.Null(),
19 v1.Counter.tagSet: v2c.Counter32(),
20 v1.Gauge.tagSet: v2c.Gauge32(),
22 v1.Opaque.tagSet: v2c.Opaque()
26 v2c.Integer32.tagSet: v1.Integer(),
28 v2c.Null.tagSet: v1.Null(),
32 v2c.Gauge32.tagSet: v1.Gauge(),
34 v2c.Opaque.tagSet: v1.Opaque()
[all …]
/dports/ftp/sftpgo/sftpgo-2.2.0/vendor/google.golang.org/grpc/xds/internal/xdsclient/v2/
H A Dclient.go68 v2c := &client{
75 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
76 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff)
77 return v2c, nil
117 Node: v2c.nodeProto,
168 err = v2c.handleLDSResponse(resp)
171 err = v2c.handleRDSResponse(resp)
194 Logger: v2c.logger,
208 Logger: v2c.logger,
222 Logger: v2c.logger,
[all …]
/dports/net-mgmt/py-pysnmp/pysnmp-4.4.9/examples/v1arch/asyncore/manager/cmdgen/
H A Dgetbulk-pull-whole-mib.py21 from pysnmp.proto.api import v2c
28 reqPDU = v2c.GetBulkRequestPDU()
29 v2c.apiBulkPDU.setDefaults(reqPDU)
30 v2c.apiBulkPDU.setNonRepeaters(reqPDU, 0)
32 v2c.apiBulkPDU.setVarBinds(reqPDU, [(x, v2c.null) for x in headVars])
35 reqMsg = v2c.Message()
36 v2c.apiMessage.setDefaults(reqMsg)
38 v2c.apiMessage.setPDU(reqMsg, reqPDU)
57 if v2c.apiBulkPDU.getRequestID(reqPDU) == v2c.apiBulkPDU.getRequestID(rspPDU):
86 v2c.apiBulkPDU.setVarBinds(
[all …]
/dports/net/grpcurl/grpcurl-1.8.5/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go67 v2c := &client{
73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff)
75 return v2c, nil
114 Node: v2c.nodeProto,
165 err = v2c.handleLDSResponse(resp)
168 err = v2c.handleRDSResponse(resp)
171 err = v2c.handleCDSResponse(resp)
174 err = v2c.handleEDSResponse(resp)
189 v2c.parent.NewListeners(update, md)
[all …]
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go67 v2c := &client{
73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff)
75 return v2c, nil
114 Node: v2c.nodeProto,
165 err = v2c.handleLDSResponse(resp)
168 err = v2c.handleRDSResponse(resp)
171 err = v2c.handleCDSResponse(resp)
174 err = v2c.handleEDSResponse(resp)
189 v2c.parent.NewListeners(update, md)
[all …]
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go67 v2c := &client{
73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff)
75 return v2c, nil
114 Node: v2c.nodeProto,
165 err = v2c.handleLDSResponse(resp)
168 err = v2c.handleRDSResponse(resp)
171 err = v2c.handleCDSResponse(resp)
174 err = v2c.handleEDSResponse(resp)
189 v2c.parent.NewListeners(update, md)
[all …]
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go67 v2c := &client{
73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff)
75 return v2c, nil
114 Node: v2c.nodeProto,
165 err = v2c.handleLDSResponse(resp)
168 err = v2c.handleRDSResponse(resp)
171 err = v2c.handleCDSResponse(resp)
174 err = v2c.handleEDSResponse(resp)
189 v2c.parent.NewListeners(update, md)
[all …]
/dports/net/v2ray/v2ray-core-4.36.2/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go67 v2c := &client{
73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff)
75 return v2c, nil
114 Node: v2c.nodeProto,
165 err = v2c.handleLDSResponse(resp)
168 err = v2c.handleRDSResponse(resp)
171 err = v2c.handleCDSResponse(resp)
192 v2c.parent.NewListeners(update)
216 v2c.parent.NewClusters(update)
[all …]
/dports/sysutils/restic/restic-0.12.1/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go67 v2c := &client{
73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff)
75 return v2c, nil
114 Node: v2c.nodeProto,
165 err = v2c.handleLDSResponse(resp)
168 err = v2c.handleRDSResponse(resp)
171 err = v2c.handleCDSResponse(resp)
174 err = v2c.handleEDSResponse(resp)
189 v2c.parent.NewListeners(update, md)
[all …]
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/google.golang.org/grpc/xds/internal/client/v2/
H A Dclient.go67 v2c := &client{
73 v2c.ctx, v2c.cancelCtx = context.WithCancel(context.Background())
74 v2c.TransportHelper = xdsclient.NewTransportHelper(v2c, opts.Logger, opts.Backoff)
75 return v2c, nil
114 Node: v2c.nodeProto,
165 err = v2c.handleLDSResponse(resp)
168 err = v2c.handleRDSResponse(resp)
171 err = v2c.handleCDSResponse(resp)
192 v2c.parent.NewListeners(update)
216 v2c.parent.NewClusters(update)
[all …]

12345678910>>...47