- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 571 for retryOn (0.44 sec)
-
pkg/config/mesh/kubemesh/watcher_test.go
}) t.Run("only core", func(t *testing.T) { cms, w := setup(t) if _, err := cms.Create(context.Background(), cmCore, metav1.CreateOptions{}); err != nil { t.Fatal(err) } retry.UntilOrFail(t, func() bool { return w.Mesh().GetIngressClass() == "core" }, retry.Delay(time.Millisecond), retry.Timeout(time.Second)) }) t.Run("invalid user config", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.7K bytes - Viewed (0) -
tests/integration/pilot/gw_topology_test.go
--- `).ApplyOrFail(t, apply.NoCleanup) cs := t.Clusters().Default().(*kubecluster.Cluster) retry.UntilSuccessOrFail(t, func() error { _, err := kubetest.CheckPodsAreReady(kubetest.NewPodFetch(cs, gatewayNs.Name(), "istio=ingressgateway")) return err }, retry.Timeout(time.Minute*2), retry.Delay(time.Second))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
gotLeader.Store(true) }) stop := make(chan struct{}) go l.Run(stop) t.Cleanup(func() { close(stop) }) // Need to retry until Run() starts to execute in the goroutine. retry.UntilOrFail(t, gotLeader.Load, retry.Converge(5), retry.Delay(time.Millisecond*100), retry.Timeout(time.Second*10)) if !l.isLeader() { t.Errorf("isLeader()=false, want true") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
tokens, err := e.listTokenSecrets(serviceAccount) if err != nil { // don't retry on cache lookup errors return false, err } retry := false errs := []error{} for _, token := range tokens { r, err := e.deleteToken(token.Namespace, token.Name, token.UID) if err != nil { errs = append(errs, err) } if r { retry = true } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
testing/internal-testing/src/test/groovy/org/gradle/testing/internal/util/RetryUtilTest.groovy
class RetryUtilTest extends Specification { def "exceed retry count of #retryCount throws last exception"() { given: def closure = Mock(Closure) when: RetryUtil.retry(retryCount, closure) then: def exception = thrown(Exception) exception.message == "Exception for retry #${retryCount - 1}" interaction { retryCount.times { retryIndex ->
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
// If the problem was a CertificateException from the X509TrustManager, // do not retry. if (e.cause is CertificateException) { return false } } if (e is SSLPeerUnverifiedException) { // e.g. a certificate pinning error. return false } // An example of one we might want to retry with a different route is a problem connecting to a
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 13:24:48 UTC 2024 - 12.1K bytes - Viewed (0) -
tests/integration/pilot/multicluster_test.go
"istio.io/istio/pkg/test/framework/components/echo" "istio.io/istio/pkg/test/framework/components/echo/check" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/pkg/test/util/tmpl" ) var ( multiclusterRetryTimeout = retry.Timeout(1 * time.Minute) multiclusterRetryDelay = retry.Delay(500 * time.Millisecond) ) func TestClusterLocal(t *testing.T) { // nolint: staticcheck framework.NewTest(t).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 8.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy
lock2.doIsLockedByCurrentThread() == (!lock1Locked && !lock2Locked) where: lock1Locked | lock2Locked | expectedDisposition true | true | RETRY true | false | RETRY false | true | RETRY false | false | FINISHED } def "can unlock resources with unlock"() { def lock1 = resourceLock("lock1", lock1Locked, true)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/model/network_test.go
} }) workingDNSServer.setFailure(false) t.Run("resolution recovered", func(t *testing.T) { // addresses should be updated retry.UntilOrFail(t, func() bool { return !reflect.DeepEqual(env.NetworkManager.AllGateways(), gateways) }, retry.Timeout(10*model.MinGatewayTTL), retry.Delay(time.Millisecond*10)) xdsUpdater.WaitOrFail(t, "xds full") }) workingDNSServer.setHosts(make(sets.String))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 6.9K bytes - Viewed (0) -
tests/integration/ambient/wasm_test.go
} return nil } func sendTraffic(ctx framework.TestContext, checker echo.Checker, options ...retry.Option) { ctx.Helper() if len(GetClientInstances()) == 0 { ctx.Fatal("there is no client") } cltInstance := GetClientInstances()[0] defaultOptions := []retry.Option{retry.Delay(100 * time.Millisecond), retry.Timeout(200 * time.Second)} httpOpts := echo.CallOptions{ To: GetTarget(), Port: echo.Port{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 21:02:05 UTC 2024 - 7.2K bytes - Viewed (0)