- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 378 for syncFn (0.22 sec)
-
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
AddFunc: c.addCustomResourceDefinition, UpdateFunc: c.updateCustomResourceDefinition, DeleteFunc: c.deleteCustomResourceDefinition, }) c.syncFn = c.sync return c } func (c *DiscoveryController) sync(version schema.GroupVersion) error { apiVersionsForDiscovery := []metav1.GroupVersionForDiscovery{} apiResourcesForDiscovery := []metav1.APIResource{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K 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) -
testing/integ-test/src/integTest/groovy/org/gradle/integtests/SyncTaskIntegrationTest.groovy
then: executedAndNotSkipped ':sync' } @NotYetImplemented def 'sync is not up to date when files are added to the destination dir'() { given: defaultSourceFileTree() file('dest').create {} buildScript ''' task sync(type: Sync) { from 'source' into 'dest' }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 18.9K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
if c.ID != "c1" { c.Synced.Store(true) } } assert.EventuallyEqual(t, c.controller.ListRemoteClusters, []cluster.DebugInfo{ {ID: "config", SyncStatus: "synced"}, {ID: "c0", SecretName: "istio-system/s0", SyncStatus: "synced"}, {ID: "c1", SecretName: "istio-system/s1", SyncStatus: "syncing"}, }) // Sync the last one c.component.ForCluster("c1").Synced.Store(true)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/kube/krt/collection.go
type multiIndex[I, O any] struct { outputs map[Key[O]]O inputs map[Key[I]]I mappings map[Key[I]]sets.Set[Key[O]] } func (h *manyCollection[I, O]) Synced() Syncer { return channelSyncer{ name: h.collectionName, synced: h.synced, } } // nolint: unused // (not true, its to implement an interface) func (h *manyCollection[I, O]) dump() { h.recomputeMu.Lock() defer h.recomputeMu.Unlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/proxy/metrics/metrics.go
}, ) // SyncProxyRulesLastTimestamp is the timestamp proxy rules were last // successfully synced. SyncProxyRulesLastTimestamp = metrics.NewGauge( &metrics.GaugeOpts{ Subsystem: kubeProxySubsystem, Name: "sync_proxy_rules_last_timestamp_seconds", Help: "The last time proxy rules were successfully synced", StabilityLevel: metrics.ALPHA, }, )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set.go
setListerSynced cache.InformerSynced // pvcListerSynced returns true if the pvc shared informer has synced at least once pvcListerSynced cache.InformerSynced // revListerSynced returns true if the rev shared informer has synced at least once revListerSynced cache.InformerSynced // StatefulSets that need to be synced. queue workqueue.TypedRateLimitingInterface[string]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 18.5K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
configCluster := "syncing" if kube.AllSynced(c.configClusterSyncers) { configCluster = "synced" } out := []cluster.DebugInfo{{ ID: c.configClusterID, SyncStatus: configCluster, }} // Append each cluster derived from secrets for secretName, clusters := range c.cs.All() { for clusterID, c := range clusters { syncStatus := "syncing" if c.Closed() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
if err := rq.resyncMonitors(ctx, newResources); err != nil { utilruntime.HandleError(fmt.Errorf("failed to sync resource monitors: %v", err)) return } // at this point, we've synced the new resources to our monitors, so record that fact. oldResources = newResources // wait for caches to fill for a while (our sync period).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0)