- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 754 for retryOn (0.28 sec)
-
pkg/kubelet/lifecycle/handlers.go
if err != nil { return err } resp, err := hr.httpDoer.Do(req) discardHTTPRespBody(resp) if isHTTPResponseError(err) { klog.V(1).ErrorS(err, "HTTPS request to lifecycle hook got HTTP response, retrying with HTTP.", "pod", klog.KObj(pod), "host", req.URL.Host) req := req.Clone(context.Background()) req.URL.Scheme = "http" req.Header.Del("Authorization") resp, httpErr := hr.httpDoer.Do(req)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 11:40:52 UTC 2024 - 8.2K 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) -
staging/src/k8s.io/apiserver/pkg/server/filters/with_retry_after_test.go
}{ { name: "retry-after disabled", shutdownDelayDurationElapsedFn: func() <-chan struct{} { return newChannel(false) }, requestURL: "/api/v1/namespaces", userAgent: "foo", handlerInvoked: 1, closeExpected: "", retryAfterExpected: "", statusCodeExpected: http.StatusOK, }, { name: "retry-after enabled, request is not exempt",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 31 14:10:46 UTC 2021 - 6.1K bytes - Viewed (0) -
tests/integration/ambient/cacert_rotation_test.go
} // perform one retry to handle race condition where ztunnel cert is refreshed before Istiod certificates are reloaded retry.UntilSuccess(func() error { newWorkloadCert := waitForWorkloadCertUpdate(t, ztunnelPod, sa, istioCtl, originalWorkloadSecret) return verifyWorkloadCert(t, newWorkloadCert, newX509) }, retry.MaxAttempts(2), retry.Timeout(5*time.Minute)) }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 6.1K bytes - Viewed (0) -
testing/smoke-test/src/smokeTest/groovy/org/gradle/smoketests/TestRetryPluginSmokeTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.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) -
src/crypto/ecdsa/ecdsa_s390x.s
BVS loop // branch back if interrupted BGT retry // signing unsuccessful, but retry with new CSPRN BLT error // condition code of 1 indicates a failure success: MOVD $0, errn+16(FP) // return 0 - sign/verify was successful RET error: MOVD $1, errn+16(FP) // return 1 - sign/verify failed RET retry:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:29:44 UTC 2024 - 891 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) -
tests/integration/telemetry/api/customize_metrics_test.go
_, err = util.QueryPrometheus(t, cluster, grpcDestinationQuery, promInst) if err != nil { util.PromDiff(t, promInst, cluster, grpcDestinationQuery) return err } return nil }, retry.Delay(1*time.Second), retry.Timeout(300*time.Second)) // check tag removed if strings.Contains(httpMetricVal, removedTag) { t.Errorf("failed to remove tag: %v", removedTag) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 5.5K 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)