- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 123 for waitForCacheSync (0.34 sec)
-
pkg/kubelet/runtimeclass/runtimeclass_manager.go
func (m *Manager) Start(stopCh <-chan struct{}) { m.informerFactory.Start(stopCh) } // WaitForCacheSync exposes the WaitForCacheSync method on the informer factory for testing // purposes. func (m *Manager) WaitForCacheSync(stopCh <-chan struct{}) { m.informerFactory.WaitForCacheSync(stopCh) } // LookupRuntimeHandler returns the RuntimeHandler string associated with the given RuntimeClass
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 11 19:22:32 UTC 2020 - 2.3K bytes - Viewed (0) -
pkg/kube/krt/sync.go
return waitForCacheSync(c.name, stop, c.synced) } func (c channelSyncer) HasSynced() bool { select { case <-c.synced: return true default: return false } } type pollSyncer struct { name string f func() bool } func (c pollSyncer) WaitUntilSynced(stop <-chan struct{}) bool { return kube.WaitForCacheSync(c.name, stop, c.f) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 03 14:25:07 UTC 2024 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/informers/externalversions/factory.go
// // Shutdown may be called multiple times, even concurrently. All such calls will // block until all goroutines have terminated. Shutdown() // WaitForCacheSync blocks until all started informers' caches were synced // or the stop channel gets closed. WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool // ForResource gives generic access to a shared informer of the matching type.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go
// // Shutdown may be called multiple times, even concurrently. All such calls will // block until all goroutines have terminated. Shutdown() // WaitForCacheSync blocks until all started informers' caches were synced // or the stop channel gets closed. WaitForCacheSync(stopCh <-chan struct{}) map[reflect.Type]bool // ForResource gives generic access to a shared informer of the matching type.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 9K bytes - Viewed (0) -
pkg/kube/informerfactory/factory.go
InformerFor(resource schema.GroupVersionResource, opts kubetypes.InformerOptions, newFunc NewInformerFunc) StartableInformer // WaitForCacheSync blocks until all started informers' caches were synced // or the stop channel gets closed. WaitForCacheSync(stopCh <-chan struct{}) bool // Shutdown marks a factory as shutting down. At that point no new // informers can be started anymore and Start will return without
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/plugin_test.go
wh.SetServiceResolver(webhooktesting.NewServiceResolver(*serverURL)) wh.SetExternalKubeClientSet(client) wh.SetExternalKubeInformerFactory(informer) informer.Start(stopCh) informer.WaitForCacheSync(stopCh) if err = wh.ValidateInitialization(); err != nil { b.Errorf("%s: failed to validate initialization: %v", tt.Name, err) return } attr := webhooktesting.NewAttribute(ns, nil, tt.IsDryRun)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/kube/client.go
} if !sleep.Until(stop, delay) { return false } } } // WaitForCacheSync is a specialized version of the general WaitForCacheSync function which also // handles fake client syncing. // This is only required in cases where fake clients are used without RunAndWait. func (c *client) WaitForCacheSync(name string, stop <-chan struct{}, cacheSyncs ...cache.InformerSynced) bool { if c.informerWatchesPending == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/mutating/plugin_test.go
wh.SetServiceResolver(webhooktesting.NewServiceResolver(*serverURL)) wh.SetExternalKubeClientSet(client) wh.SetExternalKubeInformerFactory(informer) informer.Start(stopCh) informer.WaitForCacheSync(stopCh) if err = wh.ValidateInitialization(); err != nil { b.Errorf("failed to validate initialization: %v", err) return } var attr admission.Attributes if tt.IsCRD {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:52 UTC 2024 - 11K bytes - Viewed (0) -
pkg/config/mesh/kubemesh/watcher.go
log.Errorf("failed to read mesh config from ConfigMap: %v", err) return } w.HandleMeshConfig(meshConfig) }) go c.Run(stop) // Ensure the ConfigMap is initially loaded if present. if !client.WaitForCacheSync("configmap watcher", stop, c.HasSynced) { log.Error("failed to wait for cache sync") } return w }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 25 20:54:46 UTC 2024 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
require.False(t, myController.HasSynced()) // Wait for all enqueued reconciliations require.NoError(t, waitForReconcile(initialObject)) // Now it is safe to wait for it to Sync require.True(t, cache.WaitForCacheSync(testContext.Done(), myController.HasSynced)) // Updated object updatedObject := &unstructured.Unstructured{} updatedObject.SetUnstructuredContent(map[string]interface{}{ "metadata": map[string]interface{}{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0)