- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,244 for syncFn (0.23 sec)
-
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) -
build/build-image/rsyncd.sh
# limitations under the License. # This script will set up and run rsyncd to allow data to move into and out of # our dockerized build system. This is used for syncing sources and changes of # sources into the docker-build-container. It is also used to transfer built binaries # and generated files back out. # # When run as root (rare) it'll preserve the file ids as sent from the client.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 04 15:58:52 UTC 2022 - 2.2K bytes - Viewed (0) -
docs/bucket/replication/DESIGN.md
...
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.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) -
cmd/kube-controller-manager/app/options/namespacecontroller.go
if o == nil { return } fs.DurationVar(&o.NamespaceSyncPeriod.Duration, "namespace-sync-period", o.NamespaceSyncPeriod.Duration, "The period for syncing namespace life-cycle updates") fs.Int32Var(&o.ConcurrentNamespaceSyncs, "concurrent-namespace-syncs", o.ConcurrentNamespaceSyncs, "The number of namespace objects that are allowed to sync concurrently. Larger number = more responsive namespace termination, but more CPU (and network) load") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 1.9K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/resourcequotacontroller.go
return } fs.DurationVar(&o.ResourceQuotaSyncPeriod.Duration, "resource-quota-sync-period", o.ResourceQuotaSyncPeriod.Duration, "The period for syncing quota usage status in the system") fs.Int32Var(&o.ConcurrentResourceQuotaSyncs, "concurrent-resource-quota-syncs", o.ConcurrentResourceQuotaSyncs, "The number of resource quotas that are allowed to sync concurrently. Larger number = more responsive quota management, but more CPU (and network) load") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 2K 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) -
pkg/kube/krt/core.go
// using krt), registering directly is expected. Register(f func(o Event[T])) Syncer // Synced returns a Syncer which can be used to determine if the collection has synced. Once its synced, all dependencies have // been processed, and all handlers have been called with the results. Synced() Syncer // RegisterBatch registers a handler that accepts multiple events at once. This can be useful as an optimization.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 6.9K 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)