- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 225 for Watch (0.18 sec)
-
cmd/iam-etcd-store.go
if !ok { time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } if err := watchResp.Err(); err != nil { iamLogIf(ctx, err) // log and retry. time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
return err } dclient := kc.Dynamic() r := dclient.Resource(targetSchema.GroupVersionResource()).Namespace(cliCtx.Namespace()) watch, err := r.Watch(context.TODO(), metav1.ListOptions{FieldSelector: "metadata.name=" + nf}) if err != nil { return err } for w := range watch.ResultChan() { o, ok := w.Object.(metav1.Object) if !ok { continue } if o.GetName() == nf {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
cni/pkg/install/install.go
// If an error occurs or context is canceled, the function will return an error. func (in *Installer) sleepWatchInstall(ctx context.Context, installedBinFiles sets.String) error { // Watch our specific binaries, in each configured binary dir. // We may or may not be the only CNI plugin in play, and if we are not // we shouldn't fire events for binaries that are not ours. var binPaths []string
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
gvr := action.GetResource() ns := action.GetNamespace() watch, err := fc.Tracker().Watch(gvr, ns) if err != nil { return false, nil, err } // Kubernetes Fake watches do not add initial state, but real server does // https://kubernetes.io/docs/reference/using-api/api-concepts/#semantics-for-watch
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 6.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
s.pods.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) { s.queue.Add(o) })) // Namespaces could be anything though, so we watch all of those // // NOTE that we are requeueing namespaces here explicitly to work around // test flakes with the fake kube client in `pkg/kube/client.go` - // because we are using `List()` in the handler, without this requeue,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0) -
cni/pkg/config/config.go
CNIBinTargetDirs []string // The HTTP port for monitoring MonitoringPort int // The UDS server address that CNI plugin will send log to. LogUDSAddress string // The watch server socket address that CNI plugin will forward CNI events to. CNIEventAddress string // The ztunnel server socket address that the ztunnel will connect to. ZtunnelUDSAddress string // Whether ambient is enabled
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 5.5K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
deserializer = codecs.UniversalDeserializer() ) // GetFirstPod returns a pod matching the namespace and label selector // and the number of all pods that match the label selector. // This is forked from polymorphichelpers.GetFirstPod to not watch and instead return an error if no pods are found func GetFirstPod(client v1.CoreV1Interface, namespace string, selector string) (*corev1.Pod, error) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
} fileModified, errChan := make(chan struct{}), make(chan error) go watchFiles(watcher, fileModified, errChan) for _, path := range paths { if !file.Exists(path) { log.Infof("file watcher skipping watch on non-existent path: %v", path) continue } if err := watcher.Add(path); err != nil { if closeErr := watcher.Close(); closeErr != nil { err = fmt.Errorf("%s: %w", closeErr.Error(), err) }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
cni/pkg/cmd/root.go
// based on atomic flag, as set by installer // TODO nodeagent watch server should affect this too, and drop atomic flag installDaemonReady, watchServerReady := nodeagent.StartHealthServer() if cfg.InstallConfig.AmbientEnabled { // Start ambient controller // node agent will spawn a goroutine and watch the K8S API for events, // as well as listen for messages from the CNI binary.
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
l.LogAndPrintf("Installing operator controller in namespace: %s using image: %s/operator:%s", oiArgs.common.operatorNamespace, oiArgs.common.hub, oiArgs.common.tag) } l.LogAndPrintf("Operator controller will watch namespaces: %s", oiArgs.common.watchedNamespaces) vals, mstr, err := renderOperatorManifest(args, &oiArgs.common) if err != nil { l.LogAndFatal(err) }
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 6.2K bytes - Viewed (0)