- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 229 for syncPod (0.22 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/client/informers/externalversions/factory.go
// genericInformer := factory.ForResource(resource) // typedInformer := factory.SomeAPIGroup().V1().SomeType() // factory.Start(ctx.Done()) // Start processing these informers. // synced := factory.WaitForCacheSync(ctx.Done()) // for v, ok := range synced { // if !ok { // fmt.Fprintf(os.Stderr, "caches failed to sync: %v", v) // return // } // } //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 18:31:26 UTC 2023 - 9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/strategy/Version.java
*/ package org.gradle.api.internal.artifacts.ivyservice.ivyresolve.strategy; import org.gradle.util.internal.VersionNumber; /** * A parsed version. * * This should be synced with {@link VersionNumber} and {@link org.gradle.util.GradleVersion} at some point. */ public interface Version { /** * Returns the original {@link String} representation of the version. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 1.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
} func (a *index) SyncAll() { a.networkUpdateTrigger.TriggerRecomputation() } func (a *index) HasSynced() bool { return a.services.Synced().HasSynced() && a.workloads.Synced().HasSynced() && a.waypoints.Synced().HasSynced() && a.authorizationPolicies.Synced().HasSynced() } type LookupNetwork func(endpointIP string, labels labels.Instance) network.ID
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/queue/instance.go
// HasSynced returns true once the queue has synced. // Syncing indicates that all items in the queue *before* Run was called have been processed. HasSynced() bool } type queueImpl struct { delay time.Duration tasks []*queueTask cond *sync.Cond closing bool closed chan struct{} closeOnce *sync.Once // initialSync indicates the queue has initially "synced". initialSync *atomic.Bool id string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/kube/kclient/crdwatcher.go
if fv.LessThan(mv) { 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.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
defer gb.monitorLock.Unlock() if len(gb.monitors) == 0 { logger.V(4).Info("garbage controller monitor not synced: no monitors") return false } for resource, monitor := range gb.monitors { if !monitor.controller.HasSynced() { logger.V(4).Info("garbage controller monitor not yet 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 - 36.9K bytes - Viewed (0) -
pkg/kube/krt/static.go
} func (s *staticList[T]) List() []T { return maps.Values(s.vals) } func (s *staticList[T]) Register(f func(o Event[T])) Syncer { return registerHandlerAsBatched(s, f) } func (s *staticList[T]) Synced() Syncer { return alwaysSynced{} } func (s *staticList[T]) RegisterBatch(f func(o []Event[T], initialSync bool), runExistingState bool) Syncer { if runExistingState { f(slices.Map(s.List(), func(e T) Event[T] {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 2.1K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
rqClient corev1client.ResourceQuotasGetter // A lister/getter of resource quota objects rqLister corelisters.ResourceQuotaLister // A list of functions that return true when their caches have synced informerSyncedFuncs []cache.InformerSynced // ResourceQuota objects that need to be synchronized queue workqueue.TypedRateLimitingInterface[string]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
architecture/networking/controllers.md
A queue is used to give a few properties: * Ability to serially process updates received from a variety of different sources. This avoids need for other synchronization mechanisms like mutexes. * Correctness at startup; with the sequencing above, items are only processed once all informers are synced. This means queries will not return stale data at startup.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K 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)