- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 113 for retryOn (0.35 sec)
-
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) -
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) -
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) -
pkg/kubelet/cm/dra/plugin/noderesources.go
c.queue.Add(driverName) } } // monitorPlugin calls the plugin to retrieve resource information and caches // all responses that it gets for processing in the sync method. It keeps // retrying until an error or EOF response indicates that no further data is // going to be sent, then watch resources of the plugin stops until it // re-registers.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
return err } func (spc *StatefulPodControl) UpdateStatefulPod(ctx context.Context, set *apps.StatefulSet, pod *v1.Pod) error { attemptedUpdate := false err := retry.RetryOnConflict(retry.DefaultBackoff, func() error { // assume the Pod is consistent consistent := true // if the Pod does not conform to its identity, update the identity and dirty the Pod if !identityMatches(set, pod) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
tests/integration/ambient/waypoint_test.go
} } return nil }, retry.Timeout(15*time.Second), retry.BackoffDelay(time.Millisecond*100)) // delete all waypoints in namespace, so w3 should be deleted istioctl.NewOrFail(t, t, istioctl.Config{}).InvokeOrFail(t, []string{ "waypoint", "-n", nsConfig.Name(), "delete", "--all", }) retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0) -
tests/integration/pilot/ingress_test.go
fmt.Sprintf(ingressConfigTemplate, "ingress", "istio-test", c.path, c.path, c.prefixPath)). Apply(); err != nil { t.Fatal(err) } c.call.Retry.Options = []retry.Option{ retry.Delay(500 * time.Millisecond), retry.Timeout(time.Minute * 2), } ingr.CallOrFail(t, c.call) }) } }) } defaultIngress := istio.DefaultIngressOrFail(t, t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 19.5K bytes - Viewed (0) -
cni/test/install_cni.go
return nil } // compareConfResult does a string compare of 2 test files. func compareConfResult(result, expected string, t *testing.T) { t.Helper() retry.UntilSuccessOrFail(t, func() error { return checkResult(result, expected) }, retry.Delay(time.Millisecond*10), retry.Timeout(time.Second*3)) } // checkBinDir verifies the presence/absence of test files.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
for _, override := range configOverrides { override(fakeRestConfig) } return kube.NewFakeClient(), nil } client.RunAndWait(stopCh) assert.NoError(t, c.Run(stopCh)) retry.UntilOrFail(t, c.HasSynced, retry.Timeout(2*time.Second)) secret0 := makeSecret(secretNamespace, "s0", clusterCredential{"c0", []byte("kubeconfig0-0")}) secrets := clienttest.NewWriter[*v1.Secret](t, client)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
tests/integration/telemetry/api/dashboard_test.go
if err != nil { t.Fatalf("Failed to extract queries: %v", err) } for _, query := range queries { retry.UntilSuccessOrFail(t, func() error { return checkMetric(cl, p, query, d.excluded) }, retry.Timeout(time.Minute)) } } }) } }) } // Some templates use replacement variables. Instead, replace those with wildcard
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 11.4K bytes - Viewed (0)