- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 382 for jitter (0.17 sec)
-
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) -
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/controller/podautoscaler/replica_calculator_test.go
totalRequestedCPUOfAllPods := int32(2 * totalUsedCPUOfAllPods) requestedToUsed := float64(totalRequestedCPUOfAllPods / int32(totalUsedCPUOfAllPods)) // Spread the amount we ask over 10 pods. We can add some jitter later in reportedLevels. perPodRequested := totalRequestedCPUOfAllPods / startPods // Force a minimal scaling event by satisfying (tolerance < 1 - resourcesUsedRatio).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 19 03:31:34 UTC 2023 - 68.4K bytes - Viewed (0) -
common/scripts/metallb-native.yaml
--- apiVersion: rbac.authorization.k8s.io/v1 kind: RoleBinding metadata: labels: app: metallb name: pod-lister namespace: metallb-system roleRef: apiGroup: rbac.authorization.k8s.io kind: Role name: pod-lister subjects: - kind: ServiceAccount name: speaker namespace: metallb-system --- apiVersion: rbac.authorization.k8s.io/v1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 23:56:31 UTC 2024 - 63.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
} } func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { backoff := wait.Backoff{ Duration: initialDuration, Factor: 3, Jitter: 0, Steps: 6, } return wait.ExponentialBackoff(backoff, fn) } func createTestClient(attachedVolumes ...v1.AttachedVolume) *fake.Clientset { fakeClient := &fake.Clientset{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
cmd/kubelet/app/server.go
runtimeConfig, err = kubeDeps.RemoteRuntimeService.RuntimeConfig(ctx) if err != nil { s, ok := status.FromError(err) if !ok || s.Code() != codes.Unimplemented { // We could introduce a backoff delay or jitter, but this is largely catching cases // where the runtime is still starting up and we request too early. // Give it a little more time. time.Sleep(time.Second * 2) continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
informerFactory := informers.NewSharedInformerFactory(fakeKubeClient, controller.NoResyncPeriodFunc()) nsu := statusupdater.NewNodeStatusUpdater( fakeKubeClient, informerFactory.Core().V1().Nodes().Lister(), asw) nodeLister := informerFactory.Core().V1().Nodes().Lister() reconciler := NewReconciler( reconcilerLoopPeriod, maxWaitForUnmountDuration, syncLoopPeriod, false, false, dsw, asw, ad, nsu, nodeLister, fakeRecorder) // Act
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/img/copy-with-deep-filter-example.png
copy-with-deep-filter-example.png...
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 27 16:19:30 UTC 2024 - 70.5K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/img/copy-with-flat-filter-example.png
copy-with-flat-filter-example.png...
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 27 16:19:30 UTC 2024 - 62.8K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/parser.go
if p.tok == _Semi { semi.pos = p.pos() semi.lit = p.lit p.next() } else { // asking for a '{' rather than a ';' here leads to a better error message p.want(_Lbrace) if p.tok != _Lbrace { p.advance(_Lbrace, _Rbrace) // for better synchronization (e.g., go.dev/issue/22581) } } if keyword == _For { if p.tok != _Semi { if p.tok == _Lbrace {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 62.9K bytes - Viewed (0)