- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 601 for syncAt (0.27 sec)
-
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/strategy/Version.java
*/ package org.gradle.api.internal.artifacts.ivyservice.ivyresolve.strategy; import org.gradle.util.internal.VersionNumber; /** * A parsed version. * * This should be synced with {@link VersionNumber} and {@link org.gradle.util.GradleVersion} at some point. */ public interface Version { /** * Returns the original {@link String} representation of the version. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 1.8K bytes - Viewed (0) -
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) -
cmd/kube-controller-manager/app/options/replicasetcontroller.go
func (o *ReplicaSetControllerOptions) AddFlags(fs *pflag.FlagSet) { if o == nil { return } fs.Int32Var(&o.ConcurrentRSSyncs, "concurrent-replicaset-syncs", o.ConcurrentRSSyncs, "The number of replica sets that are allowed to sync concurrently. Larger number = more responsive replica management, but more CPU (and network) load") } // ApplyTo fills up ReplicaSetController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 1.7K bytes - Viewed (0) -
pkg/volume/csi/testing/testing.go
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(), "fakeNode", csiDriverLister,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 07 00:11:50 UTC 2021 - 2.2K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/dsl/org.gradle.api.tasks.Sync.xml
Laura Kassovic <******@****.***> 1701107622 -0800
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 795 bytes - Viewed (0) -
pkg/kube/krt/internal.go
// registerHandlerAsBatched is a helper to register the provided handler as a batched handler. This allows collections to // only implement RegisterBatch. func registerHandlerAsBatched[T any](c internalCollection[T], f func(o Event[T])) Syncer { return c.RegisterBatch(func(events []Event[T], initialSync bool) { for _, o := range events { f(o) } }, true) } // castEvent converts an Event[I] to Event[O].
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 5.6K bytes - Viewed (0) -
src/internal/pkgbits/syncmarker_string.go
_ = x[SyncFuncExt-30] _ = x[SyncVarExt-31] _ = x[SyncTypeExt-32] _ = x[SyncPragma-33] _ = x[SyncExprList-34] _ = x[SyncExprs-35] _ = x[SyncExpr-36] _ = x[SyncExprType-37] _ = x[SyncAssign-38] _ = x[SyncOp-39] _ = x[SyncFuncLit-40] _ = x[SyncCompLit-41] _ = x[SyncDecl-42] _ = x[SyncFuncBody-43] _ = x[SyncOpenScope-44] _ = x[SyncCloseScope-45] _ = x[SyncCloseAnotherScope-46] _ = x[SyncDeclNames-47]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:24:07 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
key, quit := q.queue.Get() if quit { // We are done, signal to exit the queue return false } // We got the sync signal. This is not a real event, so we exit early after signaling we are synced if key == defaultSyncSignal { q.log.Debugf("synced") q.initialSync.Store(true) return true } q.log.Debugf("handling update: %v", formatKey(key))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K 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) -
cmd/kube-controller-manager/app/options/validatingadmissionpolicycontroller.go
if o == nil { return } fs.Int32Var(&o.ConcurrentPolicySyncs, "concurrent-validating-admission-policy-status-syncs", o.ConcurrentPolicySyncs, "The number of ValidatingAdmissionPolicyStatusController workers that are allowed to sync concurrently.") } // ApplyTo fills up ValidatingAdmissionPolicyStatusController config with options.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 20:41:50 UTC 2023 - 2.2K bytes - Viewed (0)