- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 891 for watcher (0.27 sec)
-
security/pkg/nodeagent/cache/secretcache.go
// use them as the source of secrets if they exist. existingCertificateFile security.SdsCertificateConfig // certWatcher watches the certificates for changes and triggers a notification to proxy. certWatcher *fsnotify.Watcher // certs being watched with file watcher. fileCerts map[FileCert]struct{} certMutex sync.RWMutex // outputMutex protects writes of certificates to disk outputMutex sync.Mutex
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 08:29:46 UTC 2024 - 28.2K bytes - Viewed (0) -
pkg/config/mesh/watcher_test_utils.go
w.doneCh <- struct{}{} }) return w } // blocks until watcher handlers trigger func (t *TestWatcher) Update(meshConfig *meshconfig.MeshConfig, timeout time.Duration) error { t.HandleMeshConfig(meshConfig) select { case <-t.doneCh: return nil case <-time.After(timeout): return errors.New("timed out waiting for mesh.Watcher handler to trigger") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Nov 03 00:26:45 UTC 2023 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
t.Errorf("Unexpected object watched: %s, expected %s", a, e) } watched++ } // We expect at least N events to be delivered, depending on the implementation. // For now, this number is smallest for Cacher and it equals 10 (size of the out buffer). if watched < 10 { t.Errorf("Unexpected number of events: %v, expected: %v", watched, totalPods) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
pkg/kube/kclient/crdwatcher.go
kube.NewCrdWatcher = newCrdWatcher } // newCrdWatcher returns a new CRD watcher controller. func newCrdWatcher(client kube.Client) kubetypes.CrdWatcher { c := &crdWatcher{ running: make(chan struct{}), callbacks: map[string][]func(){}, } c.queue = controllers.NewQueue("crd watcher", controllers.WithReconciler(c.Reconcile)) c.crds = NewMetadata(client, gvr.CustomResourceDefinition, Filter{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 5.7K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
if !chained { if len(cniConfName) == 0 { cniConfName = "YYY-istio-cni.conf" } return filepath.Join(mountedCNINetDir, cniConfName), nil } watcher, err := util.CreateFileWatcher(mountedCNINetDir) if err != nil { return "", err } defer watcher.Close() for len(cniConfName) == 0 { cniConfName, err = getDefaultCNINetwork(mountedCNINetDir) if err == nil { break }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/pkg/bootstrap/servicecontroller.go
func (s *Server) initServiceControllers(args *PilotArgs) error { serviceControllers := s.ServiceController() s.serviceEntryController = serviceentry.NewController( s.configController, s.XDSServer, s.environment.Watcher, serviceentry.WithClusterID(s.clusterID), ) serviceControllers.AddRegistry(s.serviceEntryController) registered := sets.New[provider.ID]() for _, r := range args.RegistryOptions.Registries {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/stub.go
func NewDevicePluginStub(devs []*pluginapi.Device, socket string, name string, preStartContainerFlag bool, getPreferredAllocationFlag bool) *Stub { watcher, err := fsnotify.NewWatcher() if err != nil { klog.ErrorS(err, "Watcher creation failed") panic(err) } return &Stub{ devs: devs, socket: socket, resourceName: name,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 11:19:10 UTC 2023 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
} w, err := store.watcher.Watch(ctx, "/abc", int64(102), requestOpts) if err != nil { t.Fatal(err) } defer w.Stop() actualEvent := <-w.ResultChan() if actualEvent.Type != watch.Error { t.Fatalf("Unexpected type of the event: %v, expected: %v", actualEvent.Type, watch.Error) } actualErr, ok := actualEvent.Object.(*metav1.Status) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/revisions/default_watcher_test.go
Name: defaultTagWebhookName, Labels: map[string]string{ label.IoIstioRev.Name: revision, }, }, } } func expectRevision(t test.Failer, watcher DefaultWatcher, expected string) { t.Helper() retry.UntilSuccessOrFail(t, func() error { got := watcher.GetDefault() if got != expected { return fmt.Errorf("wanted default revision %q, got %q", expected, got) } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 23 17:46:59 UTC 2023 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/get.go
} klog.V(3).InfoS("Starting watch", "path", req.URL.Path, "resourceVersion", opts.ResourceVersion, "labels", opts.LabelSelector, "fields", opts.FieldSelector, "timeout", timeout) ctx, cancel := context.WithTimeout(ctx, timeout) defer func() { cancel() }() watcher, err := rw.Watch(ctx, &opts) if err != nil { scope.err(err, w, req) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:22:16 UTC 2024 - 10.7K bytes - Viewed (0)