- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 76 for Backoff (0.24 sec)
-
pkg/controller/job/backoff_utils.go
if len(newFailedPods) == 0 { return *backoff } backoff.failuresAfterLastSuccess = backoff.failuresAfterLastSuccess + int32(len(newFailedPods)) lastFailureTime := getFinishedTime(newFailedPods[len(newFailedPods)-1]) backoff.lastFailureTime = &lastFailureTime return *backoff } else { if len(newFailedPods) == 0 { backoff.failuresAfterLastSuccess = 0 backoff.lastFailureTime = nil return *backoff
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/controller/job/backoff_utils_test.go
failuresAfterLastSuccess: 0, }, }, "Empty backoff store with no success/failure": { storeInitializer: emptyStoreInitializer, newSucceededPods: []metav1.Time{}, newFailedPods: []metav1.Time{}, wantBackoffRecord: backoffRecord{ key: "key", failuresAfterLastSuccess: 0, }, }, "Empty backoff store with one success": { storeInitializer: emptyStoreInitializer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 16.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/ErrorHandlingModuleComponentRepository.java
LOGGER.debug("Error while accessing remote repository {}. Waiting {}ms before next retry. {} retries left", repositoryName, backoff, maxTentativesCount - retries, failure); try { Thread.sleep(backoff); backoff *= 2; } catch (InterruptedException e) { throw UncheckedException.throwAsUncheckedException(e);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 00:21:07 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
const ( // queueSkip indicates that the scheduling queue should skip requeuing the Pod to activeQ/backoffQ. queueSkip queueingStrategy = iota // queueAfterBackoff indicates that the scheduling queue should requeue the Pod after backoff is completed. queueAfterBackoff // queueImmediately indicates that the scheduling queue should skip backoff and requeue the Pod immediately to activeQ. queueImmediately )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/kubelet/events/event.go
StartedContainer = "Started" FailedToCreateContainer = "Failed" FailedToStartContainer = "Failed" KillingContainer = "Killing" PreemptContainer = "Preempting" BackOffStartContainer = "BackOff" ExceededGracePeriod = "ExceededGracePeriod" ) // Pod event reason list const ( FailedToKillPod = "FailedKillPod" FailedToCreatePodContainer = "FailedCreatePodContainer"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
t.Errorf("pod %v is not in the backoff queue", podID) } // Check backoff duration. deadline := q.getBackoffTime(podInfo) backoff := deadline.Sub(timestamp) if backoff != step.wantBackoff { t.Errorf("got backoff %s, want %s", backoff, step.wantBackoff) } // Simulate routine that continuously flushes the backoff queue. cl.Step(time.Millisecond)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/plugin_manager_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) { defer cleanup(t) pluginManager := newTestPluginManager(socketDir)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 4.4K bytes - Viewed (0) -
security/pkg/nodeagent/sds/sdsservice.go
// server in these cases. go func() { // TODO: do we need max timeout for retry, seems meaningless to retry forever if it never succeed b := backoff.NewExponentialBackOff(backoff.DefaultOption()) // context for both timeout and channel, whichever stops first, the context will be done ctx, cancel := context.WithCancel(context.Background()) go func() { select {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 25 00:20:04 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
default: // This is a problem, report it and retry. logger.Error(err, "Creating gRPC stream for node resources failed") select { case <-time.After(backOff.Get(backOffID)): backOff.Next(backOffID, time.Now()) case <-ctx.Done(): } } continue } for { response, err := stream.Recv() if err != nil { switch {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
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)