- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 754 for retryOn (0.11 sec)
-
pilot/pkg/xds/vm_test.go
}, } ds.Connect(ds.SetupProxy(proxy), nil, nil) var we *config.Config retry.UntilSuccessOrFail(t, func() error { we = ds.Store().Get(gvk.WorkloadEntry, "wg-1.1.1.1-network1", "namespace") if we == nil { return fmt.Errorf("no WE found") } return nil }, retry.Timeout(time.Second*10)) assert.Equal(t, we.Spec.(*v1alpha3.WorkloadEntry).Labels, map[string]string{ "merge": "meta",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/repositories/transport/NetworkOperationBackOffAndRetry.java
import java.util.concurrent.Callable; public class NetworkOperationBackOffAndRetry<T> { private final static String MAX_ATTEMPTS = "org.gradle.internal.network.retry.max.attempts"; private final static String INITIAL_BACKOFF_MS = "org.gradle.internal.network.retry.initial.backOff"; private static final Logger LOGGER = LoggerFactory.getLogger(NetworkOperationBackOffAndRetry.class); private final int maxDeployAttempts;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 07 04:09:56 UTC 2023 - 2.9K bytes - Viewed (0) -
tests/integration/ambient/untaint/untaint_test.go
"istio.io/istio/pkg/test/framework" "istio.io/istio/pkg/test/util/retry" ) func TestTaintsRemoved(t *testing.T) { framework. NewTest(t). Run(func(ctx framework.TestContext) { // make cni not deploy to one of the nodes taintNodes(ctx) // make sure all nodes were untainted retry.UntilSuccessOrFail(t, func() error { nodeC := ctx.Clusters().Default().Kube().CoreV1().Nodes()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 1.5K bytes - Viewed (0) -
pkg/lazy/lazy.go
// Get returns the value, computing it if necessary. Get() (T, error) } type lazyImpl[T any] struct { getter func() (T, error) // retry, if true, will ensure getter() is called for each Get() until a non-nil error is returned. retry bool // Cached responses. Note: with retry enabled, this will be unset until a non-nil error res T err error done uint32 m sync.Mutex } var _ Lazy[any] = &lazyImpl[any]{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 17 22:54:10 UTC 2022 - 2.2K bytes - Viewed (0) -
tests/integration/pilot/istioctl_test.go
return err } if !describeSvcAOutput.MatchString(output) { return fmt.Errorf("output:\n%v\n does not match regex:\n%v", output, describeSvcAOutput) } return nil }, retry.Timeout(time.Second*20)) retry.UntilSuccessOrFail(t, func() error { podID, err := getPodID(apps.A[0]) if err != nil { return fmt.Errorf("could not get Pod ID: %v", err) } args := []string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 15K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
var tlsConnectDelayNanos = 0L var tlsConnectThrowable: Throwable? = null var connectTlsNextPlan: FakePlan? = null fun createRetry(): FakePlan { check(retry == null) return FakePlan(nextPlanId++) .also { retry = it } } fun createConnectTcpNextPlan(): FakePlan { check(connectTcpNextPlan == null) return FakePlan(nextPlanId++) .also {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 6.2K bytes - Viewed (0) -
tests/integration/security/cacert_rotation/main_test.go
retry.UntilOrFail(t, func() bool { updateTime, err := getWorkloadCertLastUpdateTime(t, from, istioCtl) if err != nil { t.Logf("failed to get workload cert last update time: %v", err) return false } // retry when workload cert is not updated if updateTime.After(lastUpdateTime) { lastUpdateTime = updateTime
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 6.6K bytes - Viewed (0) -
cmd/os-reliable.go
if err = osMkdirAll(dirPath, mode, baseDir); err != nil { // Retry only for the first retryable error. if osIsNotExist(err) && i == 0 { i++ // Determine if os.NotExist error is because of // baseDir's parent being present, retry it once such // that the MkdirAll is retried once for the parent // of dirPath. // Because it is worth a retry to skip a different // baseDir which is slightly higher up the depth.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Apr 22 17:49:30 UTC 2024 - 5.8K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_test.go
waitDisconnect := func() { retry.UntilSuccessOrFail(t, func() error { proxy.connectedMutex.Lock() defer proxy.connectedMutex.Unlock() if proxy.connected != nil { return fmt.Errorf("still connected") } return nil }, retry.Timeout(time.Second), retry.Delay(time.Millisecond)) } expectCondition := func(expected string) { t.Helper() retry.UntilSuccessOrFail(t, func() error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 04:48:02 UTC 2024 - 18.6K 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)