- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 197 for HasSynced (0.3 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/configuration/mutating_webhook_manager.go
utilruntime.HandleError(fmt.Errorf("error getting webhook configuration: %v", err)) } return out } // HasSynced returns true if the initial set of mutating webhook configurations // has been loaded. func (m *mutatingWebhookConfigurationManager) HasSynced() bool { return m.hasSynced() } func (m *mutatingWebhookConfigurationManager) getConfiguration() ([]webhook.WebhookAccessor, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 22:43:12 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/revisions/default_watcher.go
func (p *defaultWatcher) AddHandler(handler DefaultHandler) { p.mu.Lock() defer p.mu.Unlock() p.handlers = append(p.handlers, handler) } func (p *defaultWatcher) HasSynced() bool { return p.queue.HasSynced() } // notifyHandlers notifies all registered handlers on default revision change. // assumes externally locked. func (p *defaultWatcher) notifyHandlers() { for _, handler := range p.handlers {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 09 02:22:47 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/revisions/tag_watcher.go
return } // Notify handlers of initial state p.notifyHandlers() p.queue.Run(stopCh) } // AddHandler registers a new handler for updates to tag changes. func (p *tagWatcher) AddHandler(handler TagHandler) { p.handlers = append(p.handlers, handler) } func (p *tagWatcher) HasSynced() bool { return p.queue.HasSynced() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
tc.Run(stop) retry.UntilOrFail(t, tc.controller.HasSynced, retry.Timeout(2*time.Second)) } type informerHandler[T controllers.ComparableObject] struct { client kclient.Client[T] } func (i *informerHandler[T]) Close() { i.client.ShutdownHandlers() } func (i *informerHandler[T]) HasSynced() bool { return i.client.HasSynced() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/kube/kclient/crdwatcher.go
log.Infof("CRD %v version %v is below minimum version %v, ignoring", crd.Name, fv, mv) return false } return true } // HasSynced returns whether the underlying cache has synced and the callback has been called at least once. func (c *crdWatcher) HasSynced() bool { return c.queue.HasSynced() } // Run starts the controller. This must be called. func (c *crdWatcher) Run(stop <-chan struct{}) { c.mutex.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go
// ExportedServices returns the list of services that are exported in this cluster. Used for debugging. ExportedServices() []exportedService Run(stop <-chan struct{}) // HasSynced indicates whether the kube createClient has synced for the watched resources. HasSynced() bool } // newServiceExportCache creates a new serviceExportCache that observes the given cluster. func newServiceExportCache(c *Controller) serviceExportCache {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
} if !kube.WaitForCacheSync("multicluster remote secrets", stopCh, c.secrets.HasSynced) { return } log.Infof("multicluster remote secrets controller cache synced in %v", time.Since(t0)) c.queue.Run(stopCh) c.handleDelete(c.configClusterID) }() return nil } func (c *Controller) HasSynced() bool { if !c.queue.HasSynced() { log.Debug("secret controller did not sync secrets presented at startup")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/kube/kclient/interfaces.go
AddEventHandler(h cache.ResourceEventHandler) // HasSynced returns true when the informer is initially populated and that all handlers added // via AddEventHandler have been called with the initial state. // note: this differs from a standard informer HasSynced, which does not check handlers have been called. HasSynced() bool // ShutdownHandlers terminates all handlers added by AddEventHandler.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:09:57 UTC 2024 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 15:27:39 UTC 2023 - 34.6K bytes - Viewed (0) -
pilot/pkg/config/memory/controller_test.go
var v int32 ctl := memory.NewController(store) ctl.RegisterHasSyncedHandler(func() bool { return atomic.LoadInt32(&v) > 0 }) if ctl.HasSynced() { t.Error("has synced but should not") } atomic.StoreInt32(&v, 1) if !ctl.HasSynced() { t.Error("has not synced but should") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 18 15:37:45 UTC 2021 - 1.8K bytes - Viewed (0)