- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 436 for retryOn (0.15 sec)
-
pkg/envoy/agent.go
if err != nil { log.Errorf(err.Error()) retryCount++ // Max retry 5 times if retryCount > 4 { a.abortCh <- errAbort log.Warnf("Graceful termination logic ended prematurely, error while obtaining downstream_cx_active stat (Max retry %d exceeded)", retryCount) break graceful_loop } log.Warnf("Retrying (%d attempt) to obtain active connections...", retryCount) continue graceful_loop
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
cmd/batch-handlers.go
ri.RetryAttempts = batchReplJobDefaultRetries if job.Replicate.Flags.Retry.Attempts > 0 { ri.RetryAttempts = job.Replicate.Flags.Retry.Attempts } case job.KeyRotate != nil: ri.RetryAttempts = batchKeyRotateJobDefaultRetries if job.KeyRotate.Flags.Retry.Attempts > 0 { ri.RetryAttempts = job.KeyRotate.Flags.Retry.Attempts } case job.Expire != nil:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
cluster/gce/gci/configure.sh
if ! curl ${curl_headers:+-H "${curl_headers}"} -f --ipv4 -Lo "${file}" --connect-timeout 20 --max-time 300 --retry 6 --retry-delay 10 --retry-connrefused "${url}"; then echo "== Failed to download ${url}. Retrying. ==" elif [[ -n "${hash}" ]] && ! validate-hash "${file}" "${hash}"; then echo "== Hash validation of ${url} failed. Retrying. ==" else if [[ -n "${hash}" ]]; then
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 04:14:02 UTC 2024 - 36.5K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
} <-stopCh } // runOnce verifies the state of the ClusterIP allocations and returns an error if an unrecoverable problem occurs. func (r *RepairIPAddress) runOnce() error { return retry.RetryOnConflict(retry.DefaultBackoff, r.doRunOnce) } // doRunOnce verifies the state of the ClusterIP allocations and returns an error if an unrecoverable problem occurs. func (r *RepairIPAddress) doRunOnce() error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
} // WaitForClusterAvailable returns true if all endpoints in the cluster are available after retry attempts, an error is returned otherwise func (c *Client) WaitForClusterAvailable(retries int, retryInterval time.Duration) (bool, error) { for i := 0; i < retries; i++ { if i > 0 { klog.V(1).Infof("[etcd] Waiting %v until next retry\n", retryInterval) time.Sleep(retryInterval) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/test/util/assert/tracker.go
} return nil }, retry.Timeout(time.Second), retry.BackoffDelay(time.Millisecond)) if err != nil { t.t.Fatal(err) } t.Empty() } // WaitCompare waits for an event to happen and ensures it meets a custom comparison function func (t *Tracker[T]) WaitCompare(f func(T) bool) { t.t.Helper() var err error retry.UntilSuccessOrFail(t.t, func() error { t.mu.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 3.6K bytes - Viewed (0) -
tests/integration/telemetry/api/wasmplugin_test.go
} return nil } func sendTraffic(ctx framework.TestContext, checker echo.Checker, options ...retry.Option) { ctx.Helper() if len(GetClientInstances()) == 0 { ctx.Fatal("there is no client") } cltInstance := GetClientInstances()[0] defaultOptions := []retry.Option{retry.Delay(100 * time.Millisecond), retry.Timeout(200 * time.Second)} httpOpts := echo.CallOptions{ To: GetTarget(), Port: echo.Port{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 14.4K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
} return nil }, retry.Timeout(time.Second*5), retry.Converge(5)) retry.UntilOrFail(t, func() bool { return store.Get(r.GroupVersionKind(), configMeta.Name, configMeta.Namespace) == nil }, retry.Message("expected no items returned for unknown CRD"), retry.Timeout(time.Second*5), retry.Converge(5)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
tests/integration/telemetry/api/stats_test.go
cltInstance := cltInstance g.Go(func() error { err := retry.UntilSuccess(func() error { if _, err := cltInstance.Call(echo.CallOptions{ Address: "fake.external.com", Scheme: scheme.HTTPS, Port: ports.HTTPS, Count: 1, Retry: echo.Retry{NoRetry: true}, // we do retry in outer loop Check: check.OK(), }); err != nil { return err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.3K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
} defer svmc.queue.Done(key) err := svmc.sync(ctx, key) if err == nil { svmc.queue.Forget(key) return true } klog.FromContext(ctx).V(2).Info("Error syncing SVM resource, retrying", "svm", key, "err", err) svmc.queue.AddRateLimited(key) return true } func (svmc *SVMController) sync(ctx context.Context, key string) error { logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0)