- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 754 for retryOn (0.17 sec)
-
istioctl/pkg/writer/envoy/configdump/testdata/routes/k8s-gateway-http-route-path-prefix/configdump.json
"retry_policy": { "retry_on": "connect-failure,refused-stream,unavailable,cancelled,retriable-status-codes", "num_retries": 2, "retry_host_predicate": [ { "name": "envoy.retry_host_predicates.previous_hosts", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.retry.host.previous_hosts.v3.PreviousHostsPredicate" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 3.1K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/ServerSentEventIteratorTest.kt
consumeEvents( """ |retry: 22 | |retry: hey | """.trimMargin(), ) assertThat(callbacks.remove()).isEqualTo(22L) } @Test fun namePrefixIgnored() { consumeEvents( """ |data: a |eventually |database |identity |retrying | | """.trimMargin(), )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/testdata/routes/istio-gateway-http-route-prefix/configdump.json
"retry_policy": { "retry_on": "connect-failure,refused-stream,unavailable,cancelled,retriable-status-codes", "num_retries": 2, "retry_host_predicate": [ { "name": "envoy.retry_host_predicates.previous_hosts", "typed_config": { "@type": "type.googleapis.com/envoy.extensions.retry.host.previous_hosts.v3.PreviousHostsPredicate" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 2.9K 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) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/webhook/webhook.go
PluginName = "webhook" // DefaultInitialBackoffDelay is the default amount of time to wait before // retrying sending audit events through a webhook. DefaultInitialBackoffDelay = 10 * time.Second ) func init() { install.Install(audit.Scheme) } // retryOnError enforces the webhook client to retry requests // on error regardless of its nature. // The default implementation considers a very limited set of
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 07 21:13:31 UTC 2022 - 4.5K 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) -
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/RetryHttpInitializerWrapper.java
} 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; } else { return false; } } });
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/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) -
cmd/kubeadm/app/phases/upgrade/health.go
klog.V(2).Infof("could not get Job %q in the namespace %q, retrying: %v", jobName, ns, err) return false, nil } for _, cond := range job.Status.Conditions { if cond.Type == batchv1.JobComplete { return true, nil } } lastError = errors.Errorf("no condition of type %v", batchv1.JobComplete) klog.V(2).Infof("Job %q in the namespace %q is not yet complete, retrying", jobName, ns) return false, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 09:18:02 UTC 2024 - 8.8K bytes - Viewed (0) -
docs/batch-jobs/README.md
token: "Bearer xxxxx" # optional authentication token for the notification endpoint retry: attempts: 10 # number of retries for the job before giving up delay: "500ms" # least amount of delay between each retry ``` You can create and run multiple 'replication' jobs at a time there are no predefined limits set. ## Batch Jobs Terminology ### Job
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Oct 06 06:00:43 UTC 2022 - 4.8K bytes - Viewed (0)