- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 891 for watcher (0.14 sec)
-
pilot/pkg/config/monitor/monitor.go
fs, err := fsnotify.NewWatcher() if err != nil { return err } watcher := recursiveWatcher{fs} if err = watcher.watchRecursive(path); err != nil { return err } go func() { defer watcher.Close() var debounceC <-chan time.Time for { select { case <-debounceC: debounceC = nil ch <- struct{}{} case e := <-watcher.Events: s, err := os.Stat(e.Name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 12 17:36:33 UTC 2024 - 7.2K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/WindowsFileWatcherRegistryFactory.java
@Override protected FileWatcherUpdater createFileWatcherUpdater( WindowsFileWatcher watcher, FileWatcherProbeRegistry probeRegistry, WatchableHierarchies watchableHierarchies ) { return new HierarchicalFileWatcherUpdater(watcher, NO_VALIDATION, probeRegistry, watchableHierarchies, root -> watcher.stopWatchingMovedPaths()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 22 09:41:33 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/filewatcher/fakefilewatcher.go
if ok { ch <- err } } // NewFakeWatcher returns a function which creates a new fake watcher for unit // testing. This allows observe callers to inject events and errors per-watched // path. changedFunc() provides a callback notification when a new watch is added // or removed. Production code should use `NewWatcher()`. func NewFakeWatcher(changedFunc func(path string, added bool)) (NewFileWatcherFunc, *FakeWatcher) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 14:06:41 UTC 2023 - 3.6K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/DarwinFileWatcherRegistryFactory.java
OsxFileWatcher watcher, FileWatcherProbeRegistry probeRegistry, WatchableHierarchies watchableHierarchies ) { return new HierarchicalFileWatcherUpdater(watcher, DarwinFileWatcherRegistryFactory::validateLocationToWatch, probeRegistry, watchableHierarchies, root -> Collections.emptyList()); } /** * The macOS native watcher reports the canonical path for watched paths.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 22 09:41:33 UTC 2023 - 3.6K bytes - Viewed (0) -
cni/pkg/install/install.go
watcher, err := util.CreateFileWatcher(targets...) if err != nil { return err } defer func() { setNotReady(in.isReady) watcher.Close() }() // Before we process whether any file events have been triggered, we must check that the file is correct // at this moment, and if not, yield. This is to catch other CNIs which might have mutated the file between
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
func (f *FakeWatcher) Stop() { f.Lock() defer f.Unlock() if !f.stopped { klog.V(4).Infof("Stopping fake watcher.") close(f.result) f.stopped = true } } func (f *FakeWatcher) IsStopped() bool { f.Lock() defer f.Unlock() return f.stopped } // Reset prepares the watcher to be reused. func (f *FakeWatcher) Reset() { f.Lock() defer f.Unlock() f.stopped = false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
pkg/filewatcher/worker.go
"os" "sync" "github.com/fsnotify/fsnotify" ) type worker struct { mu sync.RWMutex // watcher is an fsnotify watcher that watches the parent // dir of watchedFiles. dirWatcher *fsnotify.Watcher // The worker maintains a map of channels keyed by watched file path. // The worker watches parent path of given path, // and filters out events of given path, then redirect // to the result channel.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 12 22:31:06 UTC 2024 - 5.2K bytes - Viewed (0) -
istioctl/pkg/wait/wait.go
} return nil }) return g } type watcher struct { resultsChan chan string errorChan chan error ctx context.Context } func withContext(ctx context.Context) *watcher { return &watcher{ resultsChan: make(chan string, 1), errorChan: make(chan error, 1), ctx: ctx, } } func (w *watcher) Go(f func(chan string) error) { go func() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 17 12:24:17 UTC 2024 - 10.1K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/FileWatcherRegistry.java
/** * Registers a watchable hierarchy. * * The watcher registry will only watch for changes in watchable hierarchies. * * @throws WatchingNotSupportedException when the native watchers can't be updated. */ void registerWatchableHierarchy(File watchableHierarchy, SnapshotHierarchy root); /** * Updates the watchers after changes to the root. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller_test.go
c := kube.NewFakeClient() revision := "default" ns := "default" watcher := keycertbundle.NewWatcher() watcher.SetAndNotify(nil, nil, caBundle0) control := newController(Options{ WatchedNamespace: ns, CABundleWatcher: watcher, Revision: revision, ServiceName: "istiod", }, c) stop := test.NewStop(t) c.RunAndWait(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 05 03:21:04 UTC 2024 - 11.8K bytes - Viewed (0)