- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 303 for retryOn (0.25 sec)
-
pkg/util/async/bounded_frequency_runner_test.go
lock sync.Mutex run bool retryFn func() } func (r *receiver) F() { r.lock.Lock() defer r.lock.Unlock() r.run = true if r.retryFn != nil { r.retryFn() r.retryFn = nil } } func (r *receiver) reset() bool { r.lock.Lock() defer r.lock.Unlock() was := r.run r.run = false return was } func (r *receiver) setRetryFn(retryFn func()) { r.lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 09:36:26 UTC 2022 - 12.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/RetryConditions.groovy
if (!checkDaemonLogs) { println "Retrying test because socket disappeared." return cleanProjectDir(specification) } for (def daemon : daemonsFixture.allDaemons) { if (daemonStoppedWithSocketExceptionOnWindows(daemon)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/test/framework/components/echo/calloptions.go
CaCertFile string // Skip verifying peer's certificate. InsecureSkipVerify bool } // Retry settings type Retry struct { // NoRetry if true, no retry will be attempted. NoRetry bool // Options to be used when retrying. If not specified, defaults will be used. Options []retry.Option } // TCP settings type TCP struct { // ExpectedResponse asserts this is in the response for TCP requests.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 13K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
controllers.WithReconciler(c.Reconcile), // Webhook patching has to be retried forever. But the retries would be rate limited. controllers.WithMaxAttempts(math.MaxInt), // Retry with backoff. Failures could be from conflicts of other instances (quick retry helps), or // longer lasting concerns which will eventually be retried on 1min interval. // Unlike the mutating webhook controller, we do not use NewItemFastSlowRateLimiter. This is because
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultWagonManager.java
boolean retry = true; // this will run at most twice. The first time, the firstRun flag is turned off, and if the retry flag // is set on the first run, it will be turned off and not re-set on the second try. This is because the // only way the retry flag can be set is if ( firstRun == true ). while (firstRun || retry) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Sep 14 11:48:15 UTC 2023 - 29.9K 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) -
istioctl/pkg/describe/testdata/describe/http_config.json
"route": { "cluster": "outbound|9080||productpage.default.svc.cluster.local", "timeout": "0s", "retry_policy": { "retry_on": "connect-failure,refused-stream,unavailable,cancelled,retriable-status-codes", "num_retries": 2, "retry_host_predicate": [ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 13.7K 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) -
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)