- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 891 for watcher (0.15 sec)
-
pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta1/api.proto
string v1beta1_field = 2; } message ExampleResponse { string error = 1; } // Example is a simple example service for general reference on the recommended // kubelet plugin model and plugin watcher testing. service Example { rpc GetExampleInfo(ExampleRequest) returns (ExampleResponse) {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 23 17:31:18 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/xds/server.go
close(conn.initialized) } // ConnectionContext is used by the RPC event loop to respond to requests and pushes. type ConnectionContext interface { XdsConnection() *Connection Watcher() Watcher // Initialize checks the first request. Initialize(node *core.Node) error // Close discards the connection. Close() // Process responds to a discovery request.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/example_plugin_apis/v1beta2/api.proto
string v1beta2_field = 2; } message ExampleResponse { string error = 1; } // Example is a simple example service for general reference on the recommended // kubelet plugin model and plugin watcher testing. service Example { rpc GetExampleInfo(ExampleRequest) returns (ExampleResponse) {}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 23 17:31:18 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/webhooks/util/util.go
reason string } func (e ConfigError) Error() string { return e.err.Error() } func (e ConfigError) Reason() string { return e.reason } func LoadCABundle(caBundleWatcher *keycertbundle.Watcher) ([]byte, error) { caBundle := caBundleWatcher.GetCABundle() if err := VerifyCABundle(caBundle); err != nil { return nil, &ConfigError{err, "could not verify caBundle"} } return caBundle, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 17:33:33 UTC 2022 - 1.5K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection.go
} func newLeaderElection(namespace, name, electionID, revision string, perRevision bool, remote bool, client kube.Client) *LeaderElection { var watcher revisions.DefaultWatcher if features.EnableLeaderElection { watcher = revisions.NewDefaultWatcher(client, revision) } if name == "" { hn, _ := os.Hostname() name = fmt.Sprintf("unknown-%s", hn) } if perRevision && revision != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 9.7K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
} func (c *Context) Watcher() xds.Watcher { return c.w } func (w *Watch) DeleteWatchedResource(string) { w.Lock() defer w.Unlock() w.watch = nil } func (w *Watch) GetWatchedResource(string) *xds.WatchedResource { w.Lock() defer w.Unlock() return w.watch } func (w *Watch) NewWatchedResource(typeURL string, names []string) { w.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
security/pkg/k8s/chiron/utils.go
return append(certPEM, caCert...), caCert, nil } // Return signed CSR through a watcher. If no CSR is read, return nil. func readSignedCsr(client clientset.Interface, csr string, watchTimeout time.Duration) ([]byte, error) { selector := fields.OneTermEqualSelector("metadata.name", csr).String() // Setup a List+Watch, like informers do // A simple Watch will fail if the cert is signed too quickly
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 18:11:22 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go
caBundleWatcher *keycertbundle.Watcher queue controllers.Queue namespaces kclient.Client[*v1.Namespace] configmaps kclient.Client[*v1.ConfigMap] ignoredNamespaces sets.Set[string] } // NewNamespaceController returns a pointer to a newly constructed NamespaceController instance. func NewNamespaceController(kubeClient kube.Client, caBundleWatcher *keycertbundle.Watcher) *NamespaceController {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
watcher, err := t.storage.(rest.Watcher).Watch(ctx, options) if err != nil { t.Errorf("unexpected error: %v, %v", err, action) } if err := emitFn(obj, action); err != nil { t.Errorf("unexpected error: %v", err) } select { case _, ok := <-watcher.ResultChan(): if !ok { t.Errorf("watch channel should be open") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
// shouldn't we be doing this for both validating and mutating webhooks...? func (c *Controller) startCaBundleWatcher(stop <-chan struct{}) { if c.o.CABundleWatcher == nil { return } id, watchCh := c.o.CABundleWatcher.AddWatcher() defer c.o.CABundleWatcher.RemoveWatcher(id) for { select { case <-watchCh: c.syncAll() case <-stop:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0)