- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 328 for retryOn (0.17 sec)
-
tests/integration/telemetry/api/wasmplugin_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 Apr 08 22:02:59 UTC 2024 - 14.4K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
} return nil }, retry.Timeout(time.Second*5), retry.Converge(5)) retry.UntilOrFail(t, func() bool { return store.Get(r.GroupVersionKind(), configMeta.Name, configMeta.Namespace) == nil }, retry.Message("expected no items returned for unknown CRD"), retry.Timeout(time.Second*5), retry.Converge(5)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
tests/integration/telemetry/api/stats_test.go
cltInstance := cltInstance g.Go(func() error { err := retry.UntilSuccess(func() error { if _, err := cltInstance.Call(echo.CallOptions{ Address: "fake.external.com", Scheme: scheme.HTTPS, Port: ports.HTTPS, Count: 1, Retry: echo.Retry{NoRetry: true}, // we do retry in outer loop Check: check.OK(), }); err != nil { return err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.3K bytes - Viewed (0) -
tests/integration/telemetry/api/accesslogs_test.go
defaultOptions := []retry.Option{retry.Delay(100 * time.Millisecond), retry.Timeout(200 * time.Second)} httpOpts := echo.CallOptions{ Address: hostname, Port: echo.Port{ Name: "http", ServicePort: 80, Protocol: protocol.HTTP, }, HTTP: http, Count: 1, Retry: echo.Retry{ Options: append(defaultOptions, retry.Timeout(framework.TelemetryRetryTimeout)),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kubeapiserver/options/authentication.go
authenticationconfigmetrics.RecordAuthenticationConfigAutomaticReloadFailure(apiServerID) // we do not update the tracker here because this error could eventually resolve as we keep retrying return } authConfigData := string(authConfigBytes) if authConfigData == trackedAuthenticationConfigData { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 22:40:22 UTC 2024 - 32.4K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller_test.go
fetch(unpatchedWebhookConfig.Name), webhookConfigAfterCAUpdate, retry.Message("webhook should change after cert change"), LongRetry, ) } // LongRetry is used when comparing webhook values. Apparently the values are so large that with -race // on the comparison can take a few seconds, meaning we never retry with the default settings. var LongRetry = retry.Timeout(time.Second * 20) func TestLoadCaCertPem(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 05 03:21:04 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/kubelet/cm/dra/plugin/noderesources.go
c.queue.Add(driverName) } } // monitorPlugin calls the plugin to retrieve resource information and caches // all responses that it gets for processing in the sync method. It keeps // retrying until an error or EOF response indicates that no further data is // going to be sent, then watch resources of the plugin stops until it // re-registers.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K 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) -
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)