- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 457 for retryOn (0.43 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/config/validation/validation_test.go
}, valid: false}, {name: "invalid policy retryOn", in: &networking.HTTPRetry{ Attempts: 10, PerTryTimeout: &durationpb.Duration{Seconds: 2}, RetryOn: "5xx,invalid policy", }, valid: false}, {name: "invalid http status retryOn", in: &networking.HTTPRetry{ Attempts: 10, PerTryTimeout: &durationpb.Duration{Seconds: 2}, RetryOn: "600,connect-failure", }, valid: false},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 03:11:45 UTC 2024 - 196K bytes - Viewed (0) -
pkg/config/validation/validation.go
if retries.Attempts == 0 && (retries.PerTryTimeout != nil || retries.RetryOn != "" || retries.RetryRemoteLocalities != nil) { errs = appendErrors(errs, errors.New("http retry policy configured when attempts are set to 0 (disabled)")) } if retries.PerTryTimeout != nil { errs = appendErrors(errs, agent.ValidateDuration(retries.PerTryTimeout)) } if retries.RetryOn != "" { retryOnPolicies := strings.Split(retries.RetryOn, ",")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/crd-all.gen.yaml
retryOn: description: Specifies the conditions under which retry takes place. type: string retryRemoteLocalities: description: Flag to specify whether the retries should retry to other localities.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:42 UTC 2024 - 671.7K bytes - Viewed (0) -
tests/integration/pilot/common/routing.go
}, }, }, workloadAgnostic: true, }) // Retry conditions have been added to just check that config is correct. // Retries are not specifically tested. TODO if we actually test retries, include proxyless t.RunTraffic(TrafficTestCase{ name: "retry conditions", config: ` apiVersion: networking.istio.io/v1alpha3 kind: VirtualService metadata:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.9K bytes - Viewed (0) -
manifests/charts/base/crds/crd-all.gen.yaml
retryOn: description: Specifies the conditions under which retry takes place. type: string retryRemoteLocalities: description: Flag to specify whether the retries should retry to other localities.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:42 UTC 2024 - 671.6K 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/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)