- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 754 for retryOn (0.12 sec)
-
tests/integration/telemetry/api/istioctl_metrics_test.go
"istio.io/istio/pkg/test/util/retry" ) // TestIstioctlMetrics contains a basic validation of the experimental // metrics command. It validates that values are being returned when there is // traffic and that the expected default output format is matched. func TestIstioctlMetrics(t *testing.T) { framework.NewTest(t). Run(func(t framework.TestContext) { retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.8K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/testing/internal/util/RetryUtil.groovy
* limitations under the License. */ package org.gradle.testing.internal.util final class RetryUtil { private RetryUtil() {} static int retry(int retries = 3, int waitMsBetweenRetries = 0, Closure closure) { int retryCount = 0 Throwable lastException = null while (retryCount++ < retries) { try { closure.call()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.2K bytes - Viewed (0) -
pkg/kube/rpc_creds_test.go
} if !reflect.DeepEqual(m1, m2) { t.Fatalf("Unexpectedly getting a new tokens") } var m3 map[string]string retry.UntilOrFail(t, func() bool { m3, err = perCred.GetRequestMetadata(ctx) return err == nil && !reflect.DeepEqual(m1, m3) }, retry.Delay(refreshSeconds*time.Second), retry.Timeout(expirationSeconds*time.Second), ) if reflect.DeepEqual(m1, m3) { t.Fatalf("Unexpectedly not getting a new token")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 16 06:24:33 UTC 2022 - 2.4K bytes - Viewed (0) -
pkg/kube/controllers/common_test.go
APIVersion: gvk.Deployment.GroupVersion(), Kind: gvk.Deployment.Kind, Name: "deployment", UID: "1234", }}, }, }) retry.UntilOrFail(t, func() bool { return written.Load() == "ns/deployment" }, retry.Timeout(time.Second*5)) written.Store("") handler(&corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod", Namespace: "ns",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 15 15:34:49 UTC 2023 - 4.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 8.1K bytes - Viewed (0) -
tests/integration/pilot/cni_race_test.go
} } } return fmt.Errorf("cannot find any pod with wanted exit code %v", constants.ValidationErrorCode) }, retry.Delay(1*time.Second), retry.Timeout(80*time.Second)) } func waitForRepairOrFail(t framework.TestContext, cluster cluster.Cluster, ns namespace.Instance) { retry.UntilSuccessOrFail(t, func() error { pods, err := cluster.Kube().CoreV1().Pods(ns.Name()).List(context.TODO(), metav1.ListOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 16:52:52 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/kube/controllers/queue_test.go
"istio.io/istio/pkg/test/util/retry" ) func TestQueue(t *testing.T) { handles := atomic.NewInt32(0) q := NewQueue("custom", WithReconciler(func(key types.NamespacedName) error { handles.Inc() return nil })) q.Add(types.NamespacedName{Name: "something"}) stop := make(chan struct{}) go q.Run(stop) retry.UntilOrFail(t, q.HasSynced, retry.Delay(time.Microsecond)) assert.Equal(t, handles.Load(), 1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 15 16:18:19 UTC 2023 - 1.3K bytes - Viewed (0) -
pkg/test/framework/telemetry.go
// limitations under the License. package framework import ( "flag" "time" ) var ( // TelemetryRetryDelay is the retry delay used in tests. TelemetryRetryDelay time.Duration // TelemetryRetryTimeout is the retry timeout used in tests. TelemetryRetryTimeout time.Duration // UseRealStackdriver controls whether to use real stackdriver backend for testing or not. UseRealStackdriver bool )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 07 19:57:17 UTC 2022 - 1.4K bytes - Viewed (0) -
tests/integration/pilot/piggyback_test.go
import ( "fmt" "strings" "testing" "istio.io/istio/pkg/test/framework" "istio.io/istio/pkg/test/framework/components/echo" "istio.io/istio/pkg/test/framework/components/istioctl" "istio.io/istio/pkg/test/util/retry" ) func TestPiggyback(t *testing.T) { // nolint: staticcheck framework. NewTest(t).RequiresSingleCluster(). RequiresLocalControlPlane(). RequireIstioVersion("1.10.0").
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 3.3K bytes - Viewed (0) -
cmd/batch-expire_gen.go
} case "NotificationCfg": err = z.NotificationCfg.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "NotificationCfg") return } case "Retry": err = z.Retry.DecodeMsg(dc) if err != nil { err = msgp.WrapError(err, "Retry") return } case "Rules": var zb0002 uint32 zb0002, err = dc.ReadArrayHeader() if err != nil { err = msgp.WrapError(err, "Rules") return
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 02 10:51:33 UTC 2023 - 19.8K bytes - Viewed (0)