- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for backoffDuration (0.35 sec)
-
pkg/controller/job/backoff_utils.go
if failuresCount == 0 { return 0 } backoffDuration := defaultBackoff for i := 1; i < int(failuresCount); i++ { backoffDuration = backoffDuration * 2 if backoffDuration >= maxBackoff { backoffDuration = maxBackoff break } } timeElapsedSinceLastFailure := clock.Since(*lastFailureTime) if backoffDuration < timeElapsedSinceLastFailure { return 0 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 8.3K bytes - Viewed (0) -
src/net/lookup_test.go
tt := lookupGoogleSRVTests[i] cname, srvs, err := LookupSRV(tt.service, tt.proto, tt.name) if err != nil { testenv.SkipFlakyNet(t) if attempts < len(backoffDuration) { dur := backoffDuration[attempts] t.Logf("backoff %v after failure %v\n", dur, err) time.Sleep(dur) attempts++ i-- continue } t.Fatal(err) } if len(srvs) == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.4K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
duration := p.calculateBackoffDuration(podInfo) backoffTime := podInfo.Timestamp.Add(duration) return backoffTime } // calculateBackoffDuration is a helper function for calculating the backoffDuration // based on the number of attempts the pod has made. func (p *PriorityQueue) calculateBackoffDuration(podInfo *framework.QueuedPodInfo) time.Duration { duration := p.podInitialBackoffDuration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)