- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 194 for Watcher (0.15 sec)
-
cni/pkg/nodeagent/cni-watcher_test.go
Ben Leggett <******@****.***> 1714685380 -0400
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.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 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 17 12:24:17 GMT 2024 - 10.1K bytes - Viewed (0) -
cni/README.md
- watches k8s resource for existing pods, so that pods that have already been started can be moved in or out of the ambient mesh. - sends UDS events to ztunnel via a socket whenever a pod is enabled for ambient mesh (whether from CNI plugin or node watcher), instructing ztunnel to create the "tube" socket.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 12.3K 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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
private final EventBus bus; private final List<StringCatcher> catchers; Registrator(EventBus bus, List<StringCatcher> catchers) { this.bus = bus; this.catchers = catchers; } @Override public void run() { StringCatcher catcher = new StringCatcher(); bus.register(catcher); catchers.add(catcher); } } /** * A collector for DeadEvents.
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
private final EventBus bus; private final List<StringCatcher> catchers; Registrator(EventBus bus, List<StringCatcher> catchers) { this.bus = bus; this.catchers = catchers; } @Override public void run() { StringCatcher catcher = new StringCatcher(); bus.register(catcher); catchers.add(catcher); } } /** * A collector for DeadEvents.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
guava-tests/test/com/google/common/base/CharMatcherTest.java
assertTrue(matcher.matches(s.charAt(0))); assertTrue(matcher.apply(s.charAt(0))); assertEquals(0, matcher.indexIn(s)); assertEquals(0, matcher.indexIn(s, 0)); assertEquals(-1, matcher.indexIn(s, 1)); assertEquals(0, matcher.lastIndexIn(s)); assertTrue(matcher.matchesAnyOf(s)); assertTrue(matcher.matchesAllOf(s)); assertFalse(matcher.matchesNoneOf(s));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 30.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/CharMatcherTest.java
assertTrue(matcher.matches(s.charAt(0))); assertTrue(matcher.apply(s.charAt(0))); assertEquals(0, matcher.indexIn(s)); assertEquals(0, matcher.indexIn(s, 0)); assertEquals(-1, matcher.indexIn(s, 1)); assertEquals(0, matcher.lastIndexIn(s)); assertTrue(matcher.matchesAnyOf(s)); assertTrue(matcher.matchesAllOf(s)); assertFalse(matcher.matchesNoneOf(s));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 30.1K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
Xiaopeng Han <******@****.***> 1709887099 +0800
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0)