Home
last modified time | relevance | path

Searched refs:stopChan (Results 1 – 25 of 423) sorted by relevance

12345678910>>...17

/dports/sysutils/istio/istio-1.6.7/mixer/adapter/solarwinds/internal/appoptics/
H A Dbatching_test.go37 stopChan := make(chan struct{})
65 stopChan <- struct{}{}
68 close(stopChan)
78 stopChan := make(chan struct{})
81 defer close(stopChan)
86 stopChan <- struct{}{}
141 stopChan := make(chan struct{})
161 }, pushChan, stopChan, logger)
168 stopChan <- struct{}{}
187 stopChan <- struct{}{}
[all …]
H A Dbatching.go26 pushChan chan<- []*Measurement, stopChan <-chan struct{}, batchSize int) {
50 case <-stopChan:
59 stopChan <-chan struct{}, logger adapter.Logger) {
69 case <-stopChan:
/dports/sysutils/istio/istio-1.6.7/mixer/adapter/solarwinds/
H A Dmetrics_handler.go42 stopChan chan struct{} member
59 stopChan := make(chan struct{})
73 appoptics.BatchMeasurements(prepChan, pushChan, stopChan, int(batchSize))
77 appoptics.PersistBatches(lc, pushChan, stopChan, env.Logger())
84 stopChan: stopChan,
122 close(h.stopChan)
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/libnetwork/hostdiscovery/
H A Dhostdiscovery.go22 stopChan chan struct{} member
34 return &hostDiscovery{watcher: watcher, nodes: mapset.NewSet(), stopChan: make(chan struct{})}
44 discoveryCh, errCh := d.Watch(h.stopChan)
59 case <-h.stopChan:
67 stopChan := h.stopChan
71 close(stopChan)
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/kubelet/pluginmanager/reconciler/
H A Dreconciler_test.go188 stopChan := make(chan struct{})
189 defer close(stopChan)
190 go reconciler.Run(stopChan)
233 stopChan := make(chan struct{})
234 defer close(stopChan)
235 go reconciler.Run(stopChan)
289 stopChan := make(chan struct{})
290 defer close(stopChan)
291 go reconciler.Run(stopChan)
/dports/net/traefik/traefik-2.6.1/pkg/server/
H A Dserver.go27 stopChan chan bool member
41 stopChan: make(chan bool, 1),
70 <-s.stopChan
80 s.stopChan <- true
103 close(s.stopChan)
/dports/security/keybase/client-v5.7.1/go/vendor/github.com/deckarep/golang-set/
H A Diterator.go53 stopChan := make(chan struct{})
56 stop: stopChan,
57 }, itemChan, stopChan
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/deckarep/golang-set/
H A Diterator.go53 stopChan := make(chan struct{})
56 stop: stopChan,
57 }, itemChan, stopChan
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/deckarep/golang-set/
H A Diterator.go53 stopChan := make(chan struct{})
56 stop: stopChan,
57 }, itemChan, stopChan
/dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/deckarep/golang-set/
H A Diterator.go53 stopChan := make(chan struct{})
56 stop: stopChan,
57 }, itemChan, stopChan
/dports/sysutils/consul/consul-1.10.3/connect/proxy/
H A Dproxy.go17 stopChan chan struct{} member
30 stopChan: make(chan struct{}),
130 case <-p.stopChan:
149 <-p.stopChan
160 close(p.stopChan)
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/consul/connect/proxy/
H A Dproxy.go16 stopChan chan struct{} member
29 stopChan: make(chan struct{}),
121 case <-p.stopChan:
140 <-p.stopChan
151 close(p.stopChan)
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/connect/proxy/
H A Dproxy.go17 stopChan chan struct{} member
30 stopChan: make(chan struct{}),
130 case <-p.stopChan:
149 <-p.stopChan
160 close(p.stopChan)

12345678910>>...17