/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 126 type Dispatcher struct { struct 130 mu sync.Mutex 133 wg sync.WaitGroup 142 lastSeenRootCert []byte 143 config *Config 144 cluster Cluster 152 taskUpdatesLock sync.Mutex 155 nodeUpdatesLock sync.Mutex 157 downNodes *nodeStore 162 processUpdatesLock sync.Mutex [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 107 type Dispatcher struct { struct 108 mu sync.Mutex 109 nodes *nodeStore 111 mgrQueue *watch.Queue 115 config *Config 116 cluster Cluster 121 taskUpdatesLock sync.Mutex 124 nodeUpdatesLock sync.Mutex 126 downNodes *nodeStore 131 processUpdatesLock sync.Mutex [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 127 type Dispatcher struct { struct 128 mu sync.Mutex 130 nodes *nodeStore 134 lastSeenRootCert []byte 135 config *Config 136 cluster Cluster 144 taskUpdatesLock sync.Mutex 147 nodeUpdatesLock sync.Mutex 149 downNodes *nodeStore 154 processUpdatesLock sync.Mutex [all …]
|
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/swarmkit/manager/dispatcher/ |
H A D | dispatcher.go | 127 type Dispatcher struct { struct 128 mu sync.Mutex 130 nodes *nodeStore 134 lastSeenRootCert []byte 135 config *Config 136 cluster Cluster 144 taskUpdatesLock sync.Mutex 147 nodeUpdatesLock sync.Mutex 149 downNodes *nodeStore 154 processUpdatesLock sync.Mutex [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/lib/install/management/ |
H A D | dispatcher.go | 84 type Dispatcher struct { struct 85 Action 88 op trace.Operation 89 force bool 92 isVC bool 93 vchPoolPath string 94 vmPathName string 95 dockertlsargs string 97 DockerPort string 98 HostIP string [all …]
|
/dports/net/proby/proby-1.0.2/cargo-crates/actix-utils-1.0.6/src/ |
H A D | stream.rs | 11 pub struct Dispatcher<S, T> struct 23 impl<S, T> Dispatcher<S, T> implementation 42 impl<S, T> Future for Dispatcher<S, T> implementation
|
/dports/net/storj/storj-1.45.3/vendor/github.com/zeebo/admission/v3/ |
H A D | dispatch.go | 23 type Dispatcher struct { struct 25 Handler Handler 28 Conn syscall.RawConn 32 NumMessages int 36 InFlight int 39 Hooks struct { 49 func (d Dispatcher) Run(ctx context.Context) (err error) {
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/prometheus/alertmanager/dispatch/ |
H A D | dispatch.go | 62 type Dispatcher struct { struct 63 route *Route 64 alerts provider.Alerts 65 stage notify.Stage 66 metrics *DispatcherMetrics 68 marker types.Marker 72 mtx sync.RWMutex 74 done chan struct{} 75 ctx context.Context 76 cancel func() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/alertmanager/dispatch/ |
H A D | dispatch.go | 76 type Dispatcher struct { struct 77 route *Route 78 alerts provider.Alerts 79 stage notify.Stage 81 limits Limits 83 marker types.Marker 88 aggrGroupsNum int 90 done chan struct{} 91 ctx context.Context 92 cancel func() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/prometheus/alertmanager/dispatch/ |
H A D | dispatch.go | 76 type Dispatcher struct { struct 77 route *Route 78 alerts provider.Alerts 79 stage notify.Stage 81 limits Limits 83 marker types.Marker 88 aggrGroupsNum int 90 done chan struct{} 91 ctx context.Context 92 cancel func() [all …]
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/alertmanager/dispatch/ |
H A D | dispatch.go | 76 type Dispatcher struct { struct 77 route *Route 78 alerts provider.Alerts 79 stage notify.Stage 81 limits Limits 83 marker types.Marker 88 aggrGroupsNum int 90 done chan struct{} 91 ctx context.Context 92 cancel func() [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/prometheus/alertmanager/dispatch/ |
H A D | dispatch.go | 76 type Dispatcher struct { struct 77 route *Route 78 alerts provider.Alerts 79 stage notify.Stage 81 limits Limits 83 marker types.Marker 88 aggrGroupsNum int 90 done chan struct{} 91 ctx context.Context 92 cancel func() [all …]
|
/dports/security/xray-core/Xray-core-1.5.0/transport/internet/udp/ |
H A D | dispatcher.go | 29 type Dispatcher struct { struct 30 sync.RWMutex 31 conns map[net.Destination]*connEntry 32 dispatcher routing.Dispatcher 33 callback ResponseCallback 36 func NewDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) *Dispatcher { 44 func (v *Dispatcher) RemoveRay(dest net.Destination) { 54 func (v *Dispatcher) getInboundRay(ctx context.Context, dest net.Destination) *connEntry { 81 …c (v *Dispatcher) Dispatch(ctx context.Context, destination net.Destination, payload *buf.Buffer) { 130 func DialDispatcher(ctx context.Context, dispatcher routing.Dispatcher) (net.PacketConn, error) {
|
/dports/net/v2ray/v2ray-core-4.36.2/transport/internet/udp/ |
H A D | dispatcher.go | 28 type Dispatcher struct { struct 29 sync.RWMutex 30 conns map[net.Destination]*connEntry 31 dispatcher routing.Dispatcher 32 callback ResponseCallback 35 func NewDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) *Dispatcher { 43 func (v *Dispatcher) RemoveRay(dest net.Destination) { 53 func (v *Dispatcher) getInboundRay(ctx context.Context, dest net.Destination) *connEntry { 80 …c (v *Dispatcher) Dispatch(ctx context.Context, destination net.Destination, payload *buf.Buffer) { 129 func DialDispatcher(ctx context.Context, dispatcher routing.Dispatcher) (net.PacketConn, error) {
|
/dports/net/proby/proby-1.0.2/cargo-crates/actix-http-1.0.1/src/ws/ |
H A D | dispatcher.rs | 11 pub struct Dispatcher<S, T> struct 16 inner: framed::Dispatcher<S, T, Codec>, argument 19 impl<S, T> Dispatcher<S, T> impl 39 impl<S, T> Future for Dispatcher<S, T> implementation
|
/dports/net/proby/proby-1.0.2/cargo-crates/actix-http-1.0.1/src/h2/ |
H A D | dispatcher.rs | 32 pub struct Dispatcher<T, S: Service<Request = Request>, B: MessageBody> struct 46 impl<T, S, B> Dispatcher<T, S, B> argument 92 impl<T, S, B> Future for Dispatcher<T, S, B> implementation
|
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/tokudb/PerconaFT/src/tests/ |
H A D | hotindexer-insert-committed.cc | 11 it under the terms of the GNU General Public License, version 2, 12 as published by the Free Software Foundation. 14 PerconaFT is distributed in the hope that it will be useful, 15 but WITHOUT ANY WARRANTY; without even the implied warranty of 16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 43 #include <sys/stat.h> in poll_msg() 44 in poll_msg() 45 DB_ENV *env; in poll_msg()
|