- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 988 for watcher (0.17 sec)
-
pkg/config/mesh/watcher.go
func NewFixedWatcher(mesh *meshconfig.MeshConfig) Watcher { iw := internalWatcher{} iw.MeshConfig.Store(mesh) return &iw } // NewFileWatcher creates a new Watcher for changes to the given mesh config file. Returns an error // if the given file does not exist or failed during parsing. func NewFileWatcher(fileWatcher filewatcher.FileWatcher, filename string, multiWatch bool) (Watcher, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
pkg/config/mesh/kubemesh/watcher.go
}) go c.Run(stop) // Ensure the ConfigMap is initially loaded if present. if !client.WaitForCacheSync("configmap watcher", stop, c.HasSynced) { log.Error("failed to wait for cache sync") } return w } func AddUserMeshConfig(client kube.Client, watcher mesh.Watcher, namespace, key, userMeshConfig string, stop <-chan struct{}) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 25 20:54:46 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/kube/inject/watcher.go
"istio.io/istio/pkg/kube/watcher/configmapwatcher" "istio.io/istio/pkg/log" "istio.io/istio/pkg/util/istiomultierror" ) // Watcher watches for and reacts to injection config updates. type Watcher interface { // SetHandler sets the handler that is run when the config changes. // Must call this before Run. SetHandler(func(*Config, string) error) // Run starts the Watcher. Must call this after SetHandler.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/util/filesystem/watcher.go
} // Initialize watcher, fall back to no-op var ( eventsCh chan fsnotify.Event errorCh chan error watcher watchAddRemover ) if w, err := fsnotify.NewWatcher(); err != nil { errorHandler(fmt.Errorf("error creating file watcher, falling back to poll at interval %s: %w", pollInterval, err)) watcher = noopWatcher{} } else { watcher = w eventsCh = w.Events errorCh = w.Errors
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 14 23:09:15 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/keycertbundle/watcher.go
id := w.watcherID w.watchers[id] = ch w.watcherID++ return id, ch } // RemoveWatcher removes the given watcher. func (w *Watcher) RemoveWatcher(id int32) { w.mutex.Lock() defer w.mutex.Unlock() ch := w.watchers[id] if ch != nil { close(ch) } delete(w.watchers, id) } // SetAndNotify sets the key cert and root cert and notify the watchers.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 05 14:00:18 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
} if len(wc.resultChan) == outgoingBufSize { klog.V(3).InfoS("Fast watcher, slow processing. Probably caused by slow dispatching events to watchers", "outgoingEvents", outgoingBufSize, "objectType", wc.watcher.objectType, "groupResource", wc.watcher.groupResource) } // If user couldn't receive results fast enough, we also block incoming events from watcher. // Because storing events in local will cause more memory usage.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
John Howard <******@****.***> 1717709495 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 6.7K bytes - Viewed (0) -
pilot/pkg/keycertbundle/watcher_test.go
watcher.SetAndNotify(key, cert, ca) select { case <-watch1: keyCertBundle := watcher.GetKeyCertBundle() if !bytes.Equal(keyCertBundle.KeyPem, key) || !bytes.Equal(keyCertBundle.CertPem, cert) || !bytes.Equal(keyCertBundle.CABundle, ca) { t.Errorf("got wrong keyCertBundle %v", keyCertBundle) } default: t.Errorf("watcher1 watched non keyCertBundle") } select { case <-watch2:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 28 17:46:00 UTC 2022 - 3.1K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/test/groovy/org/gradle/internal/watch/registry/impl/NonHierarchicalFileWatcherUpdaterTest.groovy
addSnapshot(snapshotRegularFile(fileInWatchableHierarchies)) then: 1 * watcher.startWatching({ equalIgnoringOrder(it, [probeRegistry.getProbeDirectory(file("first"))]) }) 1 * watcher.startWatching({ equalIgnoringOrder(it, [fileInWatchableHierarchies.parentFile]) }) 1 * watcher.startWatching({ equalIgnoringOrder(it, [watchableHierarchies[0]]) }) 0 * _ when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 23 13:24:54 UTC 2024 - 4.8K bytes - Viewed (0) -
pkg/volume/flexvolume/probe_test.go
// test add nested subdir inside testDriverName basePath := testDriverPath for i := 0; i < 10; i++ { subdirName := "subdirName" subdirPath := filepath.Join(basePath, subdirName) fs.MkdirAll(subdirPath, 0777) watcher.TriggerEvent(fsnotify.Create, subdirPath) // Assert assert.Equal(t, 4+i, len(watcher.watches)) // 3 + newly added
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 10.5K bytes - Viewed (0)