- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 988 for watcher (0.18 sec)
-
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/kubelet/pluginmanager/plugin_manager.go
} return pm } // pluginManager implements the PluginManager interface type pluginManager struct { // desiredStateOfWorldPopulator (the plugin watcher) runs an asynchronous // periodic loop to populate the desiredStateOfWorld. desiredStateOfWorldPopulator *pluginwatcher.Watcher // reconciler runs an asynchronous periodic loop to reconcile the // desiredStateOfWorld with the actualStateOfWorld by triggering register
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 01 05:56:33 UTC 2022 - 4.3K bytes - Viewed (0) -
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/kubelet/oom/oom_watcher_unsupported.go
*/ package oom import ( v1 "k8s.io/api/core/v1" "k8s.io/client-go/tools/record" ) type oomWatcherUnsupported struct{} var _ Watcher = new(oomWatcherUnsupported) // NewWatcher creates a fake one here func NewWatcher(_ record.EventRecorder) (Watcher, error) { return &oomWatcherUnsupported{}, nil } func (ow *oomWatcherUnsupported) Start(_ *v1.ObjectReference) error { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 993 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) -
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)