- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for Butcher (0.27 sec)
-
cmd/iam-store.go
} // IAMStoreSys contains IAMStorageAPI to add higher-level methods on the storage // layer. type IAMStoreSys struct { IAMStorageAPI } // HasWatcher - returns if the storage system has a watcher. func (store *IAMStoreSys) HasWatcher() bool { _, ok := store.IAMStorageAPI.(iamStorageWatcher) return ok } // GetUser - fetches credential from memory.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
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) -
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) -
internal/s3select/sql/stringfuncs.go
return strings.HasSuffix(text, string(s)), nil } return string(s) == text, nil } // matcher - Finds `pat` in `text`, and returns the part remainder of // `text`, after the match. If leadingPercent is false, `pat` must be // the prefix of `text`, otherwise it must be a substring. func matcher(text, pat string, leadingPercent bool) (res string, match bool) { if !leadingPercent { res = strings.TrimPrefix(text, pat)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 4.2K 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 Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.8K 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) -
cmd/iam.go
} func (sys *IAMSys) periodicRoutines(ctx context.Context, baseInterval time.Duration) { // Watch for IAM config changes for iamStorageWatcher. watcher, isWatcher := sys.store.IAMStorageAPI.(iamStorageWatcher) if isWatcher { go func() { ch := watcher.watch(ctx, iamConfigPrefix) for event := range ch { if err := sys.loadWatchedEvent(ctx, event); err != nil { // we simply log errors
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1)