- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 226 for Backoff (0.11 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
// backoff will not exceed the given max. If the backoff is not called within resetDuration, the backoff is reset. // This backoff manager is used to reduce load during upstream unhealthiness. // // Deprecated: Will be removed when the legacy Poll methods are removed. Callers should construct a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/backoff/exponential.go
// limitations under the License. // Package backoff is a wrapper of `github.com/cenkalti/backoff/v4`. // It is to prevent misuse of `github.com/cenkalti/backoff/v4`, // thus application could fall into dead loop. package backoff import ( "context" "fmt" "time" "github.com/cenkalti/backoff/v4" ) // BackOff is a backoff policy for retrying an operation. type BackOff interface {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 25 01:53:48 UTC 2023 - 3.1K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go
const defaultRequestTimeout = 30 * time.Second // DefaultRetryBackoffWithInitialDelay returns the default backoff parameters for webhook retry from a given initial delay. // Handy for the client that provides a custom initial delay only. func DefaultRetryBackoffWithInitialDelay(initialBackoffDelay time.Duration) wait.Backoff { return wait.Backoff{ Duration: initialBackoffDelay, Factor: 1.5, Jitter: 0.2, Steps: 5, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 6.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) -
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)