- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for FileWatcher (0.19 sec)
-
pkg/filewatcher/filewatcher.go
// limitations under the License. package filewatcher import ( "errors" "fmt" "path/filepath" "sync" "github.com/fsnotify/fsnotify" ) // FileWatcher is an interface that watches a set of files, // delivering events to related channel. type FileWatcher interface { // Start watching a path. Calling Add multiple times on the same path panics.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/HierarchicalFileWatcherUpdater.java
private final FileWatcher fileWatcher; private final FileSystemLocationToWatchValidator locationToWatchValidator; private ImmutableSet<File> watchedHierarchies = ImmutableSet.of(); public HierarchicalFileWatcherUpdater( FileWatcher fileWatcher, FileSystemLocationToWatchValidator locationToWatchValidator,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/config/mesh/watcher.go
handlers[i].handler() } } // Add to the FileWatcher the provided file and execute the provided function // on any change event for this file. // Using a debouncing mechanism to avoid calling the callback multiple times // per event. func addFileWatcher(fileWatcher filewatcher.FileWatcher, file string, callback func()) { _ = fileWatcher.Add(file) go func() { var timerC <-chan time.Time for {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
pilot/pkg/bootstrap/mesh.go
func (s *Server) initMeshNetworks(args *PilotArgs, fileWatcher filewatcher.FileWatcher) { if s.environment.NetworksWatcher != nil { return } log.Info("initializing mesh networks") if args.NetworksConfigFile != "" { var err error s.environment.NetworksWatcher, err = mesh.NewNetworksWatcher(fileWatcher, args.NetworksConfigFile) if err != nil { log.Info(err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/filewatcher/fakefilewatcher.go
// limitations under the License. package filewatcher import ( "errors" "fmt" "sync" "github.com/fsnotify/fsnotify" ) // NewFileWatcherFunc returns a function which creates a new file // watcher. This may be used to provide test hooks for using the // FakeWatcher implementation below. type NewFileWatcherFunc func() FileWatcher // FakeWatcher provides a fake file watcher implementation for unit
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 14:06:41 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/kube/inject/watcher.go
Run(<-chan struct{}) // Get returns the sidecar and values configuration. Get() (*Config, string, error) } var _ Watcher = &fileWatcher{} var _ Watcher = &configMapWatcher{} type fileWatcher struct { watcher *fsnotify.Watcher configFile string valuesFile string handler func(*Config, string) error } type configMapWatcher struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.9K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/NonHierarchicalFileWatcherUpdater.java
private final FileWatcher fileWatcher; private final Multiset<String> watchedDirectories = HashMultiset.create(); private final Map<String, String> watchedDirectoryForSnapshot = new HashMap<>(); private final Set<String> watchedWatchableHierarchies = new HashSet<>(); public NonHierarchicalFileWatcherUpdater( FileWatcher fileWatcher, FileWatcherProbeRegistry probeRegistry,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 17 04:59:05 UTC 2023 - 9.8K bytes - Viewed (0) -
pilot/pkg/config/monitor/file_snapshot_test.go
g := NewWithT(t) ts := &testState{ ConfigFiles: map[string][]byte{"gateway.yml": []byte(gatewayYAML)}, } ts.testSetup(t) fileWatcher := NewFileSnapshot(ts.rootPath, collection.SchemasFor(), "foo") configs, err := fileWatcher.ReadConfigFiles() g.Expect(err).NotTo(HaveOccurred()) g.Expect(configs).To(HaveLen(1)) g.Expect(configs[0].Domain).To(Equal("foo"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/config/mesh/networks_watcher_test.go
"time" . "github.com/onsi/gomega" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/filewatcher" ) func TestNewNetworksWatcherWithBadInputShouldFail(t *testing.T) { g := NewWithT(t) _, err := mesh.NewNetworksWatcher(filewatcher.NewWatcher(), "") g.Expect(err).ToNot(BeNil()) } func TestNetworksWatcherShouldNotifyHandlers(t *testing.T) { g := NewWithT(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/config/mesh/networks_watcher.go
return &internalNetworkWatcher{ networks: networks, } } // NewNetworksWatcher creates a new watcher for changes to the given networks config file. func NewNetworksWatcher(fileWatcher filewatcher.FileWatcher, filename string) (NetworksWatcher, error) { meshNetworks, err := ReadMeshNetworks(filename) if err != nil { return nil, fmt.Errorf("failed to read mesh networks configuration from %q: %v", filename, err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 4.9K bytes - Viewed (0)