- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 431 for syncFn (0.42 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) -
pkg/controller/nodeipam/ipam/sync/sync.go
// // This method is safe to call from multiple goroutines. func (sync *NodeSync) Update(node *v1.Node) { sync.opChan <- &updateOp{node} } // Delete performs the sync operations necessary to remove the node from the // IPAM state. // // This method is safe to call from multiple goroutines. func (sync *NodeSync) Delete(node *v1.Node) { sync.opChan <- &deleteOp{node} close(sync.opChan) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 07:50:01 UTC 2023 - 12.6K 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/deployment/sync.go
if err != nil { return err } allRSs := append(oldRSs, newRS) return dc.syncDeploymentStatus(ctx, allRSs, newRS, d) } // sync is responsible for reconciling deployments on scaling events or when they // are paused. func (dc *DeploymentController) sync(ctx context.Context, d *apps.Deployment, rsList []*apps.ReplicaSet) error { newRS, oldRSs, err := dc.getAllReplicaSetsAndSyncRevision(ctx, d, rsList, false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 24.5K 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)