- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,199 for syncAt (0.56 sec)
-
pkg/controller/resourcequota/resource_quota_monitor.go
qm.monitorLock.RLock() defer qm.monitorLock.RUnlock() if len(qm.monitors) == 0 { logger.V(4).Info("quota monitor not synced: no monitors") return false } for resource, monitor := range qm.monitors { if !monitor.controller.HasSynced() { logger.V(4).Info("quota monitor not synced", "resource", resource) return false } } return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/replicasetcontroller.go
func (o *ReplicaSetControllerOptions) AddFlags(fs *pflag.FlagSet) { if o == nil { return } fs.Int32Var(&o.ConcurrentRSSyncs, "concurrent-replicaset-syncs", o.ConcurrentRSSyncs, "The number of replica sets that are allowed to sync concurrently. Larger number = more responsive replica management, but more CPU (and network) load") } // ApplyTo fills up ReplicaSetController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 1.7K bytes - Viewed (0) -
pkg/volume/csi/testing/testing.go
factory.Start(wait.NeverStop) syncedTypes := factory.WaitForCacheSync(wait.NeverStop) if len(syncedTypes) != 1 { t.Fatalf("informers are not synced") } for ty, ok := range syncedTypes { if !ok { t.Fatalf("failed to sync: %#v", ty) } } host := volumetest.NewFakeVolumeHostWithCSINodeName(t, tmpDir, client, csi.ProbeVolumePlugins(), "fakeNode", csiDriverLister,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 07 00:11:50 UTC 2021 - 2.2K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/dsl/org.gradle.api.tasks.Sync.xml
Laura Kassovic <******@****.***> 1701107622 -0800
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 795 bytes - Viewed (0) -
pkg/kube/krt/internal.go
// registerHandlerAsBatched is a helper to register the provided handler as a batched handler. This allows collections to // only implement RegisterBatch. func registerHandlerAsBatched[T any](c internalCollection[T], f func(o Event[T])) Syncer { return c.RegisterBatch(func(events []Event[T], initialSync bool) { for _, o := range events { f(o) } }, true) } // castEvent converts an Event[I] to Event[O].
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
crdInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, }) c.syncFn = c.sync return c } func (c *CRDFinalizer) sync(key string) error { cachedCRD, err := c.crdLister.Get(key) if apierrors.IsNotFound(err) { return nil } if err != nil { return err } // no work to do
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c } func (c *NamingConditionController) getAcceptedNamesForGroup(group string) (allResources sets.String, allKinds sets.String) { allResources = sets.String{} allKinds = sets.String{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
src/internal/pkgbits/syncmarker_string.go
_ = x[SyncFuncExt-30] _ = x[SyncVarExt-31] _ = x[SyncTypeExt-32] _ = x[SyncPragma-33] _ = x[SyncExprList-34] _ = x[SyncExprs-35] _ = x[SyncExpr-36] _ = x[SyncExprType-37] _ = x[SyncAssign-38] _ = x[SyncOp-39] _ = x[SyncFuncLit-40] _ = x[SyncCompLit-41] _ = x[SyncDecl-42] _ = x[SyncFuncBody-43] _ = x[SyncOpenScope-44] _ = x[SyncCloseScope-45] _ = x[SyncCloseAnotherScope-46] _ = x[SyncDeclNames-47]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:24:07 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
key, quit := q.queue.Get() if quit { // We are done, signal to exit the queue return false } // We got the sync signal. This is not a real event, so we exit early after signaling we are synced if key == defaultSyncSignal { q.log.Debugf("synced") q.initialSync.Store(true) return true } q.log.Debugf("handling update: %v", formatKey(key))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager.go
func (m *InformerManager) GetTrustAnchorsByName(name string, allowMissing bool) ([]byte, error) { if !m.ctbInformer.HasSynced() { return nil, fmt.Errorf("ClusterTrustBundle informer has not yet synced") } cacheKey := cacheKeyType{ctbName: name} if cachedAnchors, ok := m.normalizationCache.Get(cacheKey); ok { return cachedAnchors.([]byte), nil } ctb, err := m.ctbLister.Get(name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 8.3K bytes - Viewed (0)