/dports/sysutils/istio/istio-1.6.7/mixer/adapter/solarwinds/internal/appoptics/ |
H A D | batching_test.go | 37 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 D | batching.go | 26 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 D | metrics_handler.go | 42 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | hostdiscovery.go | 22 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 D | reconciler_test.go | 188 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 D | server.go | 27 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 D | iterator.go | 53 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 D | iterator.go | 53 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 D | iterator.go | 53 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 D | iterator.go | 53 stopChan := make(chan struct{}) 56 stop: stopChan, 57 }, itemChan, stopChan
|
/dports/sysutils/consul/consul-1.10.3/connect/proxy/ |
H A D | proxy.go | 17 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 D | proxy.go | 16 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 D | proxy.go | 17 stopChan chan struct{} member 30 stopChan: make(chan struct{}), 130 case <-p.stopChan: 149 <-p.stopChan 160 close(p.stopChan)
|