- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newMatcher (0.17 sec)
-
cni/pkg/util/pluginutil.go
func (w *Watcher) Close() { _ = w.watcher.Close() } // Creates a file watcher that watches for any changes to the directory func CreateFileWatcher(paths ...string) (*Watcher, error) { watcher, err := fsnotify.NewWatcher() if err != nil { return nil, fmt.Errorf("watcher create: %v", err) } fileModified, errChan := make(chan struct{}), make(chan error) go watchFiles(watcher, fileModified, errChan)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
internal/config/etcd/etcd.go
if !cfg.Enabled { return nil, nil } cli, err := clientv3.New(cfg.Config) if err != nil { return nil, err } cli.KV = namespace.NewKV(cli.KV, cfg.PathPrefix) cli.Watcher = namespace.NewWatcher(cli.Watcher, cfg.PathPrefix) cli.Lease = namespace.NewLease(cli.Lease, cfg.PathPrefix) return cli, nil } func parseEndpoints(endpoints string) ([]string, bool, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.8K bytes - Viewed (0)