- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 754 for retryOn (0.18 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) -
pkg/controller/statefulset/stateful_set_status_updater.go
ctx context.Context, set *apps.StatefulSet, status *apps.StatefulSetStatus) error { // don't wait due to limited number of clients, but backoff after the default number of steps return retry.RetryOnConflict(retry.DefaultRetry, func() error { set.Status = *status // TODO: This context.TODO should use a real context once we have RetryOnConflictWithContext
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 2.9K 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) -
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) -
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) -
pkg/controller/garbagecollector/operations.go
err := retry.RetryOnConflict(retry.DefaultBackoff, func() error { ownerObject, err := gc.getObject(owner.identity) if errors.IsNotFound(err) { return nil } if err != nil { return fmt.Errorf("cannot finalize owner %s, because cannot get it: %v. The garbage collector will retry later", owner.identity, err) } accessor, err := meta.Accessor(ownerObject)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 13:37:56 UTC 2023 - 4.9K 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) -
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) -
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)