- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of about 10,000 for jitter (0.12 sec)
-
src/syscall/ztypes_linux_amd64.go
Freq int64 Maxerror int64 Esterror int64 Status int32 Pad_cgo_1 [4]byte Constant int64 Precision int64 Tolerance int64 Time Timeval Tick int64 Ppsfreq int64 Jitter int64 Shift int32 Pad_cgo_2 [4]byte Stabil int64 Jitcnt int64 Calcnt int64 Errcnt int64 Stbcnt int64 Tai int32 Pad_cgo_3 [44]byte } type Time_t int64
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:49 UTC 2023 - 12K bytes - Viewed (0) -
pkg/kubeapiserver/options/authentication_test.go
ConfigFile: "configfile", Version: "v1", CacheTTL: 60 * time.Second, RetryBackoff: &wait.Backoff{ Duration: 500 * time.Millisecond, Factor: 1.5, Jitter: 0.2, Steps: 0, }, }, expectErr: "number of webhook retry attempts must be greater than 0, but is: 0", }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 36.5K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
return f.syncTerminatedPod(ctx, pod, podStatus) } const ( // jitter factor for resyncInterval workerResyncIntervalJitterFactor = 0.5 // jitter factor for backOffPeriod and backOffOnTransientErrorPeriod workerBackOffPeriodJitterFactor = 0.5 // backoff period when transient error occurred.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/util/goroutinemap/goroutinemap_test.go
return func() error { return nil } } func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { backoff := wait.Backoff{ Duration: initialDuration, Factor: 3, Jitter: 0, Steps: 4, } return wait.ExponentialBackoff(backoff, fn) } func waitChannelWithTimeout(ch <-chan interface{}, timeout time.Duration) error { timer := time.NewTimer(timeout)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 11 14:09:48 UTC 2017 - 14.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
} c.incoming <- *event } func (c *Cacher) dispatchEvents() { // Jitter to help level out any aggregate load. bookmarkTimer := c.clock.NewTimer(wait.Jitter(time.Second, 0.25)) defer bookmarkTimer.Stop() // The internal informer populates the RV as soon as it conducts // The first successful sync with the underlying store.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/registry/core/pod/storage/eviction.go
// EvictionsRetry is the retry for a conflict where multiple clients // are making changes to the same resource. var EvictionsRetry = wait.Backoff{ Steps: 20, Duration: 500 * time.Millisecond, Factor: 1.0, Jitter: 0.1, } func newEvictionStorage(store rest.StandardStorage, podDisruptionBudgetClient policyclient.PodDisruptionBudgetsGetter) *EvictionREST {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 11:58:48 UTC 2023 - 18.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/authentication.go
// both authentication and authorization webhook used by the apiserver. func DefaultAuthWebhookRetryBackoff() *wait.Backoff { return &wait.Backoff{ Duration: 500 * time.Millisecond, Factor: 1.5, Jitter: 0.2, Steps: 5, } } type RequestHeaderAuthenticationOptions struct { // ClientCAFile is the root certificate bundle to verify client certificates on incoming requests
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 21 14:51:22 UTC 2023 - 19.9K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
utilruntime.Must(logsapi.AddFeatureGates(utilfeature.DefaultMutableFeatureGate)) utilruntime.Must(metricsfeatures.AddFeatureGates(utilfeature.DefaultMutableFeatureGate)) } const ( // ControllerStartJitter is the Jitter used when starting controller managers ControllerStartJitter = 1.0 // ConfigzName is the name used for register kube-controller manager /configz, same with GroupName. ConfigzName = "kubecontrollermanager.config.k8s.io" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0) -
cmd/erasure.go
bucketResults := make(chan dataUsageEntryInfo, len(disks)) // Start async collector/saver. // This goroutine owns the cache. var saverWg sync.WaitGroup saverWg.Add(1) go func() { // Add jitter to the update time so multiple sets don't sync up. updateTime := 30*time.Second + time.Duration(float64(10*time.Second)*rand.Float64()) t := time.NewTicker(updateTime) defer t.Stop() defer saverWg.Done()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 16K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
resyncPeriod = time.Duration(10 * time.Minute) retryPeriod = 5 * time.Second maxRetryPeriod = 180 * time.Second backoffFactor = 2.0 // Introduce a backoff multiplier as jitter factor ) // nodeResourcesController collects resource information from all registered // plugins and synchronizes that information with ResourceSlice objects. type nodeResourcesController struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0)