- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for watcher (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// cluster-wide watchers scoped by name for _, watcher := range c.watchers.allWatchers[namespacedName{name: name}] { c.watchersBuffer = append(c.watchersBuffer, watcher) } } // cluster-wide watchers unscoped by name for _, watcher := range c.watchers.allWatchers[namespacedName{}] { c.watchersBuffer = append(c.watchersBuffer, watcher) } if supported {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
t.Errorf("Unexpected object watched: %s, expected %s", a, e) } watched++ } // We expect at least N events to be delivered, depending on the implementation. // For now, this number is smallest for Cacher and it equals 10 (size of the out buffer). if watched < 10 { t.Errorf("Unexpected number of events: %v, expected: %v", watched, totalPods) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
wg.Wait() if watchErr != nil { t.Fatal(watchErr) } // wait out the expiration period and pop expired watchers time.Sleep(2 * time.Second) cacher.Lock() defer cacher.Unlock() cacher.bookmarkWatchers.popExpiredWatchersThreadUnsafe() if len(cacher.bookmarkWatchers.watchersBuckets) != 0 { numWatchers := 0 for bucketID, v := range cacher.bookmarkWatchers.watchersBuckets {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/resttest/resttest.go
watcher, err := t.storage.(rest.Watcher).Watch(ctx, options) if err != nil { t.Errorf("unexpected error: %v, %v", err, action) } if err := emitFn(obj, action); err != nil { t.Errorf("unexpected error: %v", err) } select { case _, ok := <-watcher.ResultChan(): if !ok { t.Errorf("watch channel should be open") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 55.8K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
} return } if len(filter.Patches[networking.EnvoyFilter_CLUSTER]) != tt.expectedClusterPatches { t.Errorf("Expect %d envoy filter cluster patches, but got %d", tt.expectedClusterPatches, len(filter.Patches[networking.EnvoyFilter_CLUSTER])) } if len(filter.Patches[networking.EnvoyFilter_LISTENER]) != tt.expectedListenerPatches {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
collectionDeleter, isCollectionDeleter := storage.(rest.CollectionDeleter) updater, isUpdater := storage.(rest.Updater) patcher, isPatcher := storage.(rest.Patcher) watcher, isWatcher := storage.(rest.Watcher) connecter, isConnecter := storage.(rest.Connecter) storageMeta, isMetadata := storage.(rest.StorageMetadata)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
cmd/iam.go
} const maxDurationSecondsForLog = 5 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
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
if !apiequality.Semantic.DeepDerivative(rsSpec, testRSSpec) { t.Errorf("Expected %#v, but got %#v", testRSSpec, rsSpec) } close(received) return nil } // Start only the ReplicaSet watcher and the workqueue, send a watch event, // and make sure it hits the sync method. go wait.UntilWithContext(tCtx, manager.worker, 10*time.Millisecond) testRSSpec.Name = "foo" fakeWatch.Add(&testRSSpec) select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/listener_patch_test.go
configStore model.ConfigStore, ) *model.Environment { e := &model.Environment{ ServiceDiscovery: serviceDiscovery, ConfigStore: configStore, Watcher: mesh.NewFixedWatcher(meshConfig), } pushContext := model.NewPushContext() e.Init() _ = pushContext.InitContext(e, nil, nil) e.SetPushContext(pushContext) return e }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 70.1K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
shouldBind := false if volume.Name != claim.Spec.VolumeName { shouldBind = true } // The claim from method args can be pointing to watcher cache. We must not // modify these, therefore create a copy. claimClone := claim.DeepCopy() if shouldBind { dirty = true // Bind the claim to the volume claimClone.Spec.VolumeName = volume.Name
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0)