- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 571 for retryOn (0.16 sec)
-
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/telemetry/tracing/zipkin/server_tracing_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.3K bytes - Viewed (0) -
tests/integration/operator/switch_cr_test.go
} } return nil }, retry.Timeout(retryTimeOut), retry.Delay(retryDelay)) // test operator remove command by purge scopes.Framework.Infof("checking operator remove command") removeCmd = []string{ "operator", "remove", "--skip-confirmation", "--purge", } istioCtl.InvokeOrFail(t, removeCmd) retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 17.5K bytes - Viewed (0) -
src/testing/testing_other.go
// license that can be found in the LICENSE file. //go:build !windows package testing import "time" // isWindowsRetryable reports whether err is a Windows error code // that may be fixed by retrying a failed filesystem operation. func isWindowsRetryable(err error) bool { return false } // highPrecisionTime represents a single point in time. // On all systems except Windows, using time.Time is fine.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Apr 27 19:42:36 UTC 2024 - 876 bytes - Viewed (0) -
pkg/test/framework/components/echo/common/call.go
} return result, err } if opts.Retry.NoRetry { // Retry is disabled, just send once. t0 := time.Now() defer func() { scopes.Framework.Debugf("echo call complete with duration %v", time.Since(t0)) }() return sendAndValidate() } // Retry the call until it succeeds or times out. var result echo.CallResult var err error _, _ = retry.UntilComplete(func() (any, bool, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 6.7K bytes - Viewed (0) -
pkg/istio-agent/health/health_check_test.go
} cont <- struct{}{} eventNum.Inc() }, quitChan) retry.UntilSuccessOrFail(t, func() error { if int(eventNum.Load()) != len(expectedTCPEvents) { return fmt.Errorf("waiting for %v events", len(expectedTCPEvents)-int(eventNum.Load())) } return nil }, retry.Delay(time.Millisecond*10), retry.Timeout(time.Second)) close(quitChan) }) t.Run("http", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 16:50:11 UTC 2023 - 6.3K bytes - Viewed (0) -
tests/integration/telemetry/tracing/zipkin/client_tracing_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.4K bytes - Viewed (0) -
tests/integration/pilot/analysis/analysis_test.go
hosts: - reviews http: - route: - destination: host: reviews `).ApplyOrFail(t) // Status should report error retry.UntilSuccessOrFail(t, func() error { return expectVirtualServiceStatus(t, ns, true) }, retry.Timeout(time.Minute*5)) // Apply config to make this not invalid t.ConfigIstio().YAML(ns.Name(), ` apiVersion: networking.istio.io/v1alpha3 kind: Gateway
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.7K 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)