- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 221 for BackOff (0.09 sec)
-
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) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
// failed: // - If the previous operation has the same // generatedOperations.operationName: // - If the full exponential backoff period is satisfied, the operation is // allowed to proceed. // - Otherwise, an ExponentialBackoff error is returned. // - Otherwise, exponential backoff is reset and operation is allowed to // proceed. // Once the operation is complete, the go routine is terminated. If the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K bytes - Viewed (0) -
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/RetryHttpInitializerWrapper.java
// something specific to authentication, and no backoff is desired. return true; } else if (backoffHandler.handleResponse(request, response, supportsRetry)) { // Otherwise, we defer to the judgement of our internal backoff handler. LOG.info("Retrying {}", request.getUrl()); return true;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
} func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { backoff := wait.Backoff{ Duration: initialDuration, Factor: 3, Jitter: 0, Steps: 4, } return wait.ExponentialBackoff(backoff, fn) } func waitChannelWithTimeout(ch <-chan interface{}, timeout time.Duration) error { timer := time.NewTimer(timeout)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
pkg/util/goroutinemap/exponentialbackoff/exponential_backoff.go
See the License for the specific language governing permissions and limitations under the License. */ // Package exponentialbackoff contains logic for implementing exponential // backoff for GoRoutineMap and NestedPendingOperations. package exponentialbackoff import ( "fmt" "time" ) const ( // initialDurationBeforeRetry is the amount of time after an error occurs
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 19 03:30:46 UTC 2022 - 4.2K 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/scheduler/framework/plugins/nodeunschedulable/node_unschedulable_test.go
oldObj, newObj interface{} expectedHint framework.QueueingHint expectedErr bool }{ { name: "backoff-wrong-new-object", pod: &v1.Pod{}, newObj: "not-a-node", expectedHint: framework.Queue, expectedErr: true, }, { name: "backoff-wrong-old-object", pod: &v1.Pod{}, newObj: &v1.Node{ Spec: v1.NodeSpec{ Unschedulable: true, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 4.3K 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/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/wasm/httpfetcher.go
func (f *HTTPFetcher) Fetch(ctx context.Context, url string, allowInsecure bool) ([]byte, error) { c := f.client if allowInsecure { c = f.insecureClient } attempts := 0 o := backoff.DefaultOption() o.InitialInterval = f.initialBackoff b := backoff.NewExponentialBackOff(o) var lastError error for attempts < f.requestMaxRetry { attempts++ req, err := http.NewRequestWithContext(ctx, http.MethodGet, url, nil) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 5.5K bytes - Viewed (0)