- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 823 for syncAt (0.17 sec)
-
pkg/proxy/healthcheck/proxier_health.go
// or the proxier is fully synced. continue } if currentTime.Sub(hs.oldestPendingQueuedMap[ipFamily]) < hs.healthTimeout { // there's an unprocessed update queued for this proxier, but it's not late yet. continue } return false, proxierLastUpdated } return true, lastUpdated } // SyncNode syncs the node and determines if it is eligible or not. Eligible is
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
// Added as a member to the struct to allow injection for testing. servicesSynced cache.InformerSynced // podLister is able to list/get pods and is populated by the // shared informer passed to NewController podLister corelisters.PodLister // podsSynced returns true if the pod shared informer has been synced at least once.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
if !c.shouldMirror(endpoints) { logger.V(5).Info("Skipping mirroring", "endpoints", klog.KObj(endpoints)) return } c.queueEndpoints(obj) } // onEndpointSliceAdd queues a sync for the relevant Endpoints resource for a // sync if the EndpointSlice resource version does not match the expected // version in the endpointSliceTracker. func (c *Controller) onEndpointSliceAdd(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go
return false } defer ec.queue.Done(key) err := ec.syncFn(key) if err == nil { ec.queue.Forget(key) return true } utilruntime.HandleError(fmt.Errorf("%v failed with: %v", key, err)) ec.queue.AddRateLimited(key) return true } // sync is used to turn CRDs into the Established state. func (ec *EstablishingController) sync(key string) error { cachedCRD, err := ec.crdLister.Get(key)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 4.4K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/MonotonicClock.java
* and keeping in sync with the system wall clock so that time values make sense in comparison with the system wall clock, * including timestamps generated from other processes. * <p> * This clock effectively measures time by duration (according to System.nanoTime()), * in between syncs with the system wall clock. * When issuing the first timestamp after the sync interval has expired,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 5K bytes - Viewed (0) -
pkg/controller/job/metrics/metrics.go
limitations under the License. */ package metrics import ( "sync" "k8s.io/component-base/metrics" "k8s.io/component-base/metrics/legacyregistry" ) // JobControllerSubsystem - subsystem name used for this controller. const JobControllerSubsystem = "job_controller" var ( // JobSyncDurationSeconds tracks the latency of Job syncs. Possible label // values: // completion_mode: Indexed, NonIndexed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 17:25:15 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
} if !podWorkers.CouldHaveRunningContainers(types.UID("abc")) { t.Errorf("Expected pod to potentially have running containers (does not exist but not yet synced)") } if podWorkers.ShouldPodContentBeRemoved(types.UID("abc")) { t.Errorf("Expected pod to not be suitable for removal (does not exist but not yet synced)") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/apiapproval/apiapproval_controller.go
// To allow injection for testing. syncFn func(key string) error queue workqueue.TypedRateLimitingInterface[string] // last protectedAnnotation value this controller updated the condition per CRD name (to avoid two // different version of the apiextensions-apiservers in HA to fight for the right message) lastSeenProtectedAnnotationLock sync.Mutex lastSeenProtectedAnnotation map[string]string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
crdsSynced cache.InformerSynced // To allow injection for testing. syncFn func(string) error queue workqueue.TypedRateLimitingInterface[string] staticSpec *spec.Swagger openAPIService *handler.OpenAPIService // specs by name. The specs are lazily constructed on request. // The lock is for the map only. lock sync.Mutex specsByName map[string]*specCache }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0)