- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 68 for syncPod (0.3 sec)
-
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/volume/csi/testing/testing.go
csiDriverLister := csiDriverInformer.Lister() 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(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 07 00:11:50 UTC 2021 - 2.2K 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) -
cmd/kube-controller-manager/app/options/garbagecollectorcontroller.go
fs.BoolVar(&o.EnableGarbageCollector, "enable-garbage-collector", o.EnableGarbageCollector, "Enables the generic garbage collector. MUST be synced with the corresponding flag of the kube-apiserver.") } // ApplyTo fills up GarbageCollectorController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 2K 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) -
pkg/kube/watcher/configmapwatcher/configmapwatcher.go
c.configmaps.Start(stop) if !kube.WaitForCacheSync("configmap "+c.configMapName, stop, c.configmaps.HasSynced) { return } c.queue.Run(stop) } // HasSynced returns whether the underlying cache has synced and the callback has been called at least once. func (c *Controller) HasSynced() bool { return c.queue.HasSynced() } func (c *Controller) processItem(name types.NamespacedName) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 19 07:11:52 UTC 2023 - 2.8K bytes - Viewed (0) -
build/build-image/rsyncd.sh
# Usually it'll be run as non-dockerized UID/GID and end up translating all file # ownership to that. set -o errexit set -o nounset set -o pipefail # The directory that gets sync'd VOLUME=${HOME} # Assume that this is running in Docker on a bridge. Allow connections from # anything on the local subnet. ALLOW=$(ip route | awk '/^default via/ { reg = "^[0-9./]+ dev "$5 } ; $0 ~ reg { print $1 }')
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 04 15:58:52 UTC 2022 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/interface.go
Run(ctx context.Context) error // Retrieves the informer used to back this controller Informer() Informer[T] // Returns true if the informer cache has synced, and all the objects from // the initial list have been reconciled at least once. HasSynced() bool } type NamespacedLister[T any] interface { // List lists all ValidationRuleSets in the indexer for a given namespace.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/kube/informerfactory/factory.go
InformerFor(resource schema.GroupVersionResource, opts kubetypes.InformerOptions, newFunc NewInformerFunc) StartableInformer // WaitForCacheSync blocks until all started informers' caches were synced // or the stop channel gets closed. WaitForCacheSync(stopCh <-chan struct{}) bool // Shutdown marks a factory as shutting down. At that point no new // informers can be started anymore and Start will return without
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0)