- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for Butcher (0.3 sec)
-
cni/pkg/install/cniconfig.go
if len(filename) == 0 { filename = "YYY-istio-cni.conf" } return filepath.Join(cfg.mountedCNINetDir, filename), nil } watcher, err := util.CreateFileWatcher(cfg.mountedCNINetDir) if err != nil { return "", err } defer watcher.Close() for len(filename) == 0 { filename, err = getDefaultCNINetwork(cfg.mountedCNINetDir) if err == nil { break }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
Chun Li <******@****.***> 1707418344 +0800
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
Ben Leggett <******@****.***> 1706861920 -0500
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Feb 02 08:18:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/util/pluginutil.go
for _, path := range paths { if !file.Exists(path) { log.Infof("file watcher skipping watch on non-existent path: %v", path) continue } if err := watcher.Add(path); err != nil { if closeErr := watcher.Close(); closeErr != nil { err = fmt.Errorf("%s: %w", closeErr.Error(), err) } return nil, err } } return &Watcher{ watcher: watcher, Events: fileModified,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 3.6K bytes - Viewed (0) -
operator/cmd/mesh/test-util_test.go
return &HavePathValueEqualMatcher{ expected: expected, } } // HavePathValueEqualMatcher is a matcher type for HavePathValueEqual. type HavePathValueEqualMatcher struct { expected any } // Match implements the Matcher interface. func (m *HavePathValueEqualMatcher) Match(actual any) (bool, error) { pv := m.expected.(PathValue) node := actual.(map[string]any)
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 15.3K bytes - Viewed (0) -
cni/pkg/install/cniconfig_test.go
t.Fatalf("expected %s, got %s", expectedFilepath, result) } // Successful test case return } // Handle chained CNI plugin cases // Call with goroutine to test fsnotify watcher parent, cancel := context.WithCancel(context.Background()) defer cancel() resultChan, errChan := make(chan string, 1), make(chan error, 1)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed May 17 02:22:22 GMT 2023 - 15.4K 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() {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
cni/pkg/install/install.go
} } targets := append( binPaths, in.cfg.MountedCNINetDir, constants.ServiceAccountPath, ) // Create file watcher before checking for installation // so that no file modifications are missed while and after checking // note: we create a file watcher for each invocation, otherwise when we write to the directories // we would get infinite looping of events //
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
n := match.GetMatcherTree().GetInput().GetName() var m map[string]*matcher.Matcher_OnMatch equality := "=" switch v := match.GetMatcherTree().GetTreeType().(type) { case *matcher.Matcher_MatcherTree_ExactMatchMap: m = v.ExactMatchMap.Map case *matcher.Matcher_MatcherTree_PrefixMatchMap: m = v.PrefixMatchMap.Map equality = "^" case *matcher.Matcher_MatcherTree_CustomMatch: tc := v.CustomMatch.GetTypedConfig()
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0)