- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 226 for Backoff (0.12 sec)
-
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go
pod *v1.Pod oldObj, newObj interface{} expectedHint framework.QueueingHint expectedErr bool }{ "backoff-wrong-old-object": { pod: &v1.Pod{}, oldObj: "not-a-pod", expectedHint: framework.Queue, expectedErr: true, }, "backoff-wrong-new-object": { pod: &v1.Pod{}, newObj: "not-a-pod", expectedHint: framework.Queue, expectedErr: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.7K bytes - Viewed (0) -
internal/rest/client.go
func (c *Client) LastError() error { c.RLock() defer c.RUnlock() return fmt.Errorf("[%s] %w", c.lastErrTime.Format(time.RFC3339), c.lastErr) } // computes the exponential backoff duration according to // https://www.awsarchitectureblog.com/2015/03/backoff.html func exponentialBackoffWait(r *rand.Rand, unit, cap time.Duration) func(uint) time.Duration { if unit > time.Hour { // Protect against integer overflow
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 14.4K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher_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 TestPluginRegistration(t *testing.T) { socketDir := initTempDir(t) defer os.RemoveAll(socketDir)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 8K bytes - Viewed (0) -
pkg/scheduler/metrics/metrics.go
func ActivePods() metrics.GaugeMetric { return pendingPods.With(metrics.Labels{"queue": "active"}) } // BackoffPods returns the pending pods metrics with the label backoff func BackoffPods() metrics.GaugeMetric { return pendingPods.With(metrics.Labels{"queue": "backoff"}) } // UnschedulablePods returns the pending pods metrics with the label unschedulable func UnschedulablePods() metrics.GaugeMetric {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 08:22:53 UTC 2024 - 11.1K bytes - Viewed (0) -
platforms/software/security/src/main/java/org/gradle/security/internal/PublicKeyDownloadService.java
Deque<URI> serversLeft = new ArrayDeque<>(baseUris); try { ExponentialBackoff<ExponentialBackoff.Signal> backoff = ExponentialBackoff.of(5, TimeUnit.SECONDS, 50, TimeUnit.MILLISECONDS); backoff.retryUntil(() -> { URI baseUri = serversLeft.poll(); if (baseUri == null) { // no more servers left despite retries
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:49:35 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/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) } type DummyImpl struct{} func NewDummyImpl() *DummyImpl { return &DummyImpl{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:21:15 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/adsc/adsc.go
// InsecureSkipVerify skips client verification the server's certificate chain and host name. InsecureSkipVerify bool // BackoffPolicy determines the reconnect policy. Based on MCP client. BackoffPolicy backoff.BackOff GrpcOpts []grpc.DialOption } // ADSConfig for the ADS connection. type ADSConfig struct { Config
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
security/pkg/nodeagent/cache/secretcache.go
// TODO(ramaraochavali): Think about tieing these failures to liveness probe with a // reasonable threshold (when the problem is not transient) and restart the pod. go func() { b := backoff.NewExponentialBackOff(backoff.DefaultOption()) _ = b.RetryWithContext(context.TODO(), func() error { err := sc.tryAddFileWatcher(file, resourceName) return err }) }() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 08:29:46 UTC 2024 - 28.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
func (m *Multicluster) checkShouldLead(client kubelib.Client, systemNamespace string, stop <-chan struct{}) bool { var res bool if features.ExternalIstiod { b := backoff.NewExponentialBackOff(backoff.DefaultOption()) ctx, cancel := context.WithCancel(context.Background()) go func() { select { case <-stop: cancel() case <-ctx.Done(): } }() defer cancel()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go
} } // TestWithExponentialBackoff ensures that the webhook's exponential backoff support works as expected func TestWithExponentialBackoff(t *testing.T) { count := 0 // To keep track of the requests gr := schema.GroupResource{ Group: "webhook.util.k8s.io", Resource: "test", } // Handler that will handle all backoff CONDITIONS ebHandler := func(w http.ResponseWriter, r *http.Request) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 25.8K bytes - Viewed (0)