Home
last modified time | relevance | path

Searched defs:Dispatcher (Results 1 – 25 of 1003) sorted by relevance

12345678910>>...41

/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 Ddispatcher.go126 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 Ddispatcher.go126 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 Ddispatcher.go126 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 Ddispatcher.go126 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 Ddispatcher.go126 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 Ddispatcher.go126 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 Ddispatcher.go126 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 Ddispatcher.go126 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 Ddispatcher.go126 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 Ddispatcher.go107 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 Ddispatcher.go127 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 Ddispatcher.go127 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 Ddispatcher.go84 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 Dstream.rs11 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 Ddispatch.go23 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 Ddispatch.go62 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 Ddispatch.go76 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 Ddispatch.go76 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 Ddispatch.go76 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 Ddispatch.go76 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 Ddispatcher.go29 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 Ddispatcher.go28 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 Ddispatcher.rs11 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 Ddispatcher.rs32 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 Dhotindexer-insert-committed.cc11 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()

12345678910>>...41