- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 649 for syncFn (0.33 sec)
-
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/static.go
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] { return 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/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/kube/krt/informer.go
var _ internalCollection[controllers.Object] = &informer[controllers.Object]{} func (i *informer[I]) _internalHandler() {} func (i *informer[I]) Synced() Syncer { return channelSyncer{ name: i.collectionName, synced: i.synced, } } // nolint: unused // (not true, its to implement an interface) func (i *informer[I]) dump() { i.log.Errorf(">>> BEGIN DUMP") for _, obj := range i.inf.List(metav1.NamespaceAll, klabels.Everything()) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K 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) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/MonotonicClock.java
* All syncing timestamps will be the same as the previously issued timestamp. * The rate by which this clock slows, and therefore the time it takes to resync, * is determined by how frequently the clock is read. * If timestamps are only requested at a rate greater than the sync interval,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 5K bytes - Viewed (0)