- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 823 for syncAt (0.2 sec)
-
pkg/kubelet/cm/dra/plugin/noderesources.go
} } // run is running in the background. It handles blocking initialization (like // syncing the informer) and then syncs the actual with the desired state. func (c *nodeResourcesController) run(ctx context.Context) { logger := klog.FromContext(ctx) // When kubelet starts, we have two choices: // - Sync immediately, which in practice will delete all ResourceSlices
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// pod workers have synced (syncPod could be called). Once the pod workers // have synced it returns false if the pod has a sync status until // SyncTerminatedPod completes successfully. If the pod workers have synced, // but the pod does not have a status it returns true. // // Intended for use by subsystem sync loops to avoid performing background setup
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
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) -
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) -
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) -
pkg/kubelet/status/status_manager.go
kubeClient clientset.Interface podManager PodManager // Map from pod UID to sync status of the corresponding pod. podStatuses map[types.UID]versionedPodStatus podStatusesLock sync.RWMutex podStatusChannel chan struct{} // Map from (mirror) pod UID to latest status version successfully sent to the API server. // apiStatusVersions must only be accessed from the sync thread. apiStatusVersions map[kubetypes.MirrorPodUID]uint64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
defer klog.Info("Stopping ServiceCIDR Allocator Controllerr") // Wait for all involved caches to be synced, before processing items from the queue is started if !cache.WaitForCacheSync(c.internalStopCh, c.serviceCIDRSynced, c.ipAddressSynced) { runtime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // this is single threaded only one serviceCIDR at a time
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0)