| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 141 type controller struct { struct
142 id string
144 sandboxes sandboxTable
154 defOsSbox osl.Sandbox
155 ingressSandbox *sandbox
156 sboxOnce sync.Once
157 agent *agent
161 clusterConfigAvailable bool
162 sync.Mutex
473 func (c *controller) ID() string {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 148 type controller struct { struct
149 id string
151 sandboxes sandboxTable
161 defOsSbox osl.Sandbox
162 ingressSandbox *sandbox
163 sboxOnce sync.Once
164 agent *agent
169 clusterConfigAvailable bool
170 sync.Mutex
523 func (c *controller) ID() string {
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 158 type controller struct { struct
159 id string
161 sandboxes sandboxTable
171 defOsSbox osl.Sandbox
172 ingressSandbox *sandbox
173 sboxOnce sync.Once
174 agent *agent
179 clusterConfigAvailable bool
181 sync.Mutex
536 func (c *controller) ID() string {
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 158 type controller struct { struct
159 id string
161 sandboxes sandboxTable
171 defOsSbox osl.Sandbox
172 ingressSandbox *sandbox
173 sboxOnce sync.Once
174 agent *agent
179 clusterConfigAvailable bool
181 sync.Mutex
536 func (c *controller) ID() string {
[all …]
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 158 type controller struct { struct
159 id string
161 sandboxes sandboxTable
171 defOsSbox osl.Sandbox
172 ingressSandbox *sandbox
173 sboxOnce sync.Once
174 agent *agent
179 clusterConfigAvailable bool
181 sync.Mutex
536 func (c *controller) ID() string {
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 158 type controller struct { struct
159 id string
161 sandboxes sandboxTable
171 defOsSbox osl.Sandbox
172 ingressSandbox *sandbox
173 sboxOnce sync.Once
174 agent *agent
179 clusterConfigAvailable bool
181 sync.Mutex
536 func (c *controller) ID() string {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 157 type controller struct { struct
158 id string
160 sandboxes sandboxTable
170 defOsSbox osl.Sandbox
171 ingressSandbox *sandbox
172 sboxOnce sync.Once
173 agent *agent
178 clusterConfigAvailable bool
180 sync.Mutex
534 func (c *controller) ID() string {
[all …]
|
| /dports/sysutils/docker/docker-ce-18.09.5/components/engine/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 157 type controller struct { struct
158 id string
160 sandboxes sandboxTable
170 defOsSbox osl.Sandbox
171 ingressSandbox *sandbox
172 sboxOnce sync.Once
173 agent *agent
178 clusterConfigAvailable bool
180 sync.Mutex
535 func (c *controller) ID() string {
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 157 type controller struct { struct
158 id string
160 sandboxes sandboxTable
170 defOsSbox osl.Sandbox
171 ingressSandbox *sandbox
172 sboxOnce sync.Once
173 agent *agent
178 clusterConfigAvailable bool
180 sync.Mutex
535 func (c *controller) ID() string {
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 156 type controller struct { struct
157 id string
159 sandboxes sandboxTable
169 defOsSbox osl.Sandbox
170 ingressSandbox *sandbox
171 sboxOnce sync.Once
172 agent *agent
177 clusterConfigAvailable bool
179 sync.Mutex
534 func (c *controller) ID() string {
[all …]
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 157 type controller struct { struct
158 id string
160 sandboxes sandboxTable
170 defOsSbox osl.Sandbox
171 ingressSandbox *sandbox
172 sboxOnce sync.Once
173 agent *agent
178 clusterConfigAvailable bool
180 sync.Mutex
535 func (c *controller) ID() string {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 156 type controller struct { struct
157 id string
159 sandboxes sandboxTable
169 defOsSbox osl.Sandbox
170 ingressSandbox *sandbox
171 sboxOnce sync.Once
172 agent *agent
177 clusterConfigAvailable bool
179 sync.Mutex
534 func (c *controller) ID() string {
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/docker/docker/vendor/github.com/docker/libnetwork/ |
| H A D | controller.go | 156 type controller struct { struct
157 id string
159 sandboxes sandboxTable
169 defOsSbox osl.Sandbox
170 ingressSandbox *sandbox
171 sboxOnce sync.Once
172 agent *agent
177 clusterConfigAvailable bool
179 sync.Mutex
534 func (c *controller) ID() string {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/pilot/pkg/serviceregistry/mcp/ |
| H A D | controller.go | 62 type controller struct { struct
63 configStoreMu sync.RWMutex
66 options *Options
68 ledger ledger.Ledger
70 syncedMu sync.Mutex
71 synced map[string]bool
260 func (c *controller) HasSynced() bool {
284 func (c *controller) Version() string {
292 func (c *controller) GetLedger() ledger.Ledger {
302 func (c *controller) Run(<-chan struct{}) {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/pilot/pkg/config/kube/ingress/ |
| H A D | controller.go | 85 type controller struct { struct
86 mesh *meshconfig.MeshConfig
87 domainSuffix string
89 client kubernetes.Interface
90 queue queue.Instance
91 informer cache.SharedIndexInformer
95 classes *v1beta1.IngressClassInformer
234 func (c *controller) Version() string {
242 func (c *controller) GetLedger() ledger.Ledger {
251 func (c *controller) HasSynced() bool {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/pilot/pkg/config/memory/ |
| H A D | controller.go | 27 type controller struct { struct
28 monitor Monitor
29 configStore model.ConfigStore
48 func (c *controller) HasSynced() bool {
52 func (c *controller) Version() string {
60 func (c *controller) GetLedger() ledger.Ledger {
64 func (c *controller) SetLedger(l ledger.Ledger) error {
68 func (c *controller) Run(stop <-chan struct{}) {
72 func (c *controller) Schemas() collection.Schemas {
80 func (c *controller) Create(config model.Config) (revision string, err error) {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vic/vendor/github.com/docker/docker/daemon/cluster/executor/container/ |
| H A D | controller.go | 32 type controller struct { struct
33 task *api.Task
34 adapter *containerAdapter
35 closed chan struct{}
36 err error
38 pulled chan struct{} // closed after pull
59 func (r *controller) Task() (*api.Task, error) {
99 func (r *controller) Prepare(ctx context.Context) error {
169 func (r *controller) Start(ctx context.Context) error {
523 func (r *controller) Close() error {
[all …]
|
| /dports/sysutils/helm/helm-3.5.2/vendor/github.com/docker/docker/daemon/cluster/executor/container/ |
| H A D | controller.go | 30 type controller struct { struct
31 task *api.Task
32 adapter *containerAdapter
33 closed chan struct{}
34 err error
35 pulled chan struct{} // closed after pull
56 func (r *controller) Task() (*api.Task, error) {
165 func (r *controller) Start(ctx context.Context) error {
306 func (r *controller) hasServiceBinding() bool {
548 func (r *controller) Close() error {
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/docker/docker/daemon/cluster/executor/container/ |
| H A D | controller.go | 30 type controller struct { struct
31 task *api.Task
32 adapter *containerAdapter
33 closed chan struct{}
34 err error
35 pulled chan struct{} // closed after pull
56 func (r *controller) Task() (*api.Task, error) {
165 func (r *controller) Start(ctx context.Context) error {
306 func (r *controller) hasServiceBinding() bool {
548 func (r *controller) Close() error {
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/pilot/pkg/config/kube/gateway/ |
| H A D | controller.go | 36 type controller struct { struct
37 client kubernetes.Interface
38 cache model.ConfigStoreCache
41 func (c *controller) GetLedger() ledger.Ledger {
45 func (c *controller) SetLedger(l ledger.Ledger) error {
49 func (c *controller) Schemas() collection.Schemas {
111 func (c controller) Create(config model.Config) (revision string, err error) {
115 func (c controller) Update(config model.Config) (newRevision string, err error) {
123 func (c controller) Version() string {
137 func (c controller) Run(stop <-chan struct{}) {
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/protocolPB/ |
| H A D | ClientNamenodeProtocolServerSideTranslatorPB.java | 394 public CreateResponseProto create(RpcController controller, in create()
415 public AppendResponseProto append(RpcController controller, in append()
560 public ConcatResponseProto concat(RpcController controller, in concat()
572 public RenameResponseProto rename(RpcController controller, in rename()
583 public Rename2ResponseProto rename2(RpcController controller, in rename2()
608 public DeleteResponseProto delete(RpcController controller, in delete()
619 public MkdirsResponseProto mkdirs(RpcController controller, in mkdirs()
900 public FsyncResponseProto fsync(RpcController controller, in fsync()
1194 removeCacheDirective(RpcController controller, in removeCacheDirective()
1327 public SetAclResponseProto setAcl(RpcController controller, in setAcl()
[all …]
|
| /dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/docker/docker/daemon/cluster/executor/container/ |
| H A D | controller.go | 34 type controller struct { struct
35 task *api.Task
36 adapter *containerAdapter
37 closed chan struct{}
38 err error
39 pulled chan struct{} // closed after pull
60 func (r *controller) Task() (*api.Task, error) {
188 func (r *controller) Start(ctx context.Context) error {
329 func (r *controller) hasServiceBinding() bool {
571 func (r *controller) Close() error {
[all …]
|
| /dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/docker/moby-20.10.2/daemon/cluster/executor/container/ |
| H A D | controller.go | 34 type controller struct { struct
35 task *api.Task
36 adapter *containerAdapter
37 closed chan struct{}
38 err error
39 pulled chan struct{} // closed after pull
60 func (r *controller) Task() (*api.Task, error) {
188 func (r *controller) Start(ctx context.Context) error {
330 func (r *controller) hasServiceBinding() bool {
571 func (r *controller) Close() error {
[all …]
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/docker/docker/daemon/cluster/executor/container/ |
| H A D | controller.go | 34 type controller struct { struct
35 task *api.Task
36 adapter *containerAdapter
37 closed chan struct{}
38 err error
39 pulled chan struct{} // closed after pull
60 func (r *controller) Task() (*api.Task, error) {
188 func (r *controller) Start(ctx context.Context) error {
329 func (r *controller) hasServiceBinding() bool {
571 func (r *controller) Close() error {
[all …]
|
| /dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/docker/docker/daemon/cluster/executor/container/ |
| H A D | controller.go | 34 type controller struct { struct
35 task *api.Task
36 adapter *containerAdapter
37 closed chan struct{}
38 err error
39 pulled chan struct{} // closed after pull
60 func (r *controller) Task() (*api.Task, error) {
188 func (r *controller) Start(ctx context.Context) error {
330 func (r *controller) hasServiceBinding() bool {
571 func (r *controller) Close() error {
[all …]
|