- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 193 for retryOn (0.15 sec)
-
pilot/pkg/networking/core/route/retry/retry_test.go
g.Expect(policy).To(Not(BeNil())) g.Expect(policy.RetryOn).To(Equal(retry.DefaultPolicy().RetryOn)) g.Expect(policy.RetriableStatusCodes).To(Equal(retry.DefaultPolicy().RetriableStatusCodes)) }, }, { name: "TestMissingPerTryTimeoutShouldReturnNil", // Create a route with a retry policy without per try timeout. route: &networking.HTTPRoute{ Retries: &networking.HTTPRetry{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 7.7K bytes - Viewed (0) -
pilot/pkg/networking/core/route/retry/retry.go
out.RetryOn, out.RetriableStatusCodes = parseRetryOn(in.RetryOn) // If user has just specified HTTP status codes in retryOn but have not specified "retriable-status-codes", let us add it. if len(out.RetriableStatusCodes) > 0 && !strings.Contains(out.RetryOn, "retriable-status-codes") { out.RetryOn += ",retriable-status-codes" } } if in.PerTryTimeout != nil { out.PerTryTimeout = in.PerTryTimeout }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 5K bytes - Viewed (0) -
pkg/test/util/retry/retry.go
// limitations under the License. package retry import ( "errors" "fmt" "time" "istio.io/istio/pkg/log" "istio.io/istio/pkg/test" ) var scope = log.RegisterScope("retry", "logs for retries") const ( // DefaultTimeout the default timeout for the entire retry operation DefaultTimeout = time.Second * 30 // DefaultDelay the default delay between successive retry attempts
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 5.6K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
} in 15..17 -> { type = null // 'event' on a line of its own } in 18..19 -> { val retryMs = source.readRetryMs() if (retryMs != -1L) { callback.onRetryChange(retryMs) } } -1 -> { val lineEnd = source.indexOfElement(CRLF) if (lineEnd != -1L) { // Skip the line and newline
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.3K bytes - Viewed (0) -
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) -
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) -
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) -
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)