- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 165 for Backoff (0.22 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
if backoff < 1 || backoff > 2 { t.Errorf("backoff out of range: %d", backoff) } } // negative jitter, shall be a fixed backoff backoffMgr = NewJitteredBackoffManager(1, -1, testingclock.NewFakeClock(time.Now())) backoff := backoffMgr.(*jitteredBackoffManagerImpl).getNextBackoff() if backoff != 1 { t.Errorf("backoff should be 1, but got %d", backoff) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop_test.go
// estimate how long this delay can be intervalMax := func(backoff Backoff) time.Duration { d := backoff.Duration if backoff.Jitter > 0 { d += time.Duration(backoff.Jitter * float64(d)) } return d } // estimate how short this delay can be intervalMin := func(backoff Backoff) time.Duration { d := backoff.Duration return d }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:48:08 UTC 2023 - 15.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/repositories/transport/NetworkOperationBackOffAndRetry.java
} else { LOGGER.info("Error in '{}'. Waiting {}ms before next retry, {} retries left", operation, backoff, maxDeployAttempts - retries); LOGGER.debug("Network operation failed", 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: Thu Dec 07 04:09:56 UTC 2023 - 2.9K 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) -
pkg/kubelet/images/image_manager.go
} // imageManager provides the functionalities for image pulling. type imageManager struct { recorder record.EventRecorder imageService kubecontainer.ImageService backOff *flowcontrol.Backoff // It will check the presence of the image, and report the 'image pulling', image pulled' events correspondingly. puller imagePuller podPullingTimeRecorder ImagePodPullingTimeRecorder }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 00:30:31 UTC 2024 - 8.9K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultFileLockManager.java
if (fileLockContentionHandler.maybePingOwner(lockInfo.port, lockInfo.lockId, displayName, backoff.getTimer().getElapsedMillis() - lastPingTime, backoff.getSignal())) { lastPingTime = backoff.getTimer().getElapsedMillis();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:32 UTC 2024 - 22.3K 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) -
staging/src/k8s.io/apiserver/pkg/authorization/authorizerfactory/delegating.go
DenyCacheTTL time.Duration // WebhookRetryBackoff specifies the backoff parameters for the authorization webhook retry logic. // This allows us to configure the sleep time at each iteration and the maximum number of retries allowed // before we fail the webhook call in order to limit the fan out that ensues when the system is degraded. WebhookRetryBackoff *wait.Backoff }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 22:41:27 UTC 2024 - 2.1K bytes - Viewed (0)