- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 3,352 for Retries (0.37 sec)
-
pkg/wasm/httpfetcher.go
initialBackoff time.Duration requestMaxRetry int } // NewHTTPFetcher create a new HTTP remote wasm module fetcher. // requestTimeout is a timeout for each HTTP/HTTPS request. // requestMaxRetry is # of maximum retries of HTTP/HTTPS requests. func NewHTTPFetcher(requestTimeout time.Duration, requestMaxRetry int) *HTTPFetcher { if requestTimeout == 0 { requestTimeout = 5 * time.Second }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Nov 14 20:23:34 UTC 2022 - 5.5K bytes - Viewed (0) -
pkg/test/framework/components/echo/common/call.go
func getProtoALPN(alpn []string) *proto.Alpn { if alpn != nil { return &proto.Alpn{ Value: alpn, } } return nil } // EchoClientProvider provides dynamic creation of Echo clients. This allows retries to potentially make // use of different (ready) workloads for forward requests. type EchoClientProvider func() (*echoclient.Client, error)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 6.7K bytes - Viewed (0) -
pkg/kubelet/runonce.go
return fmt.Errorf("error syncing pod %q: %v", format.Pod(pod), err) } if retry >= runOnceMaxRetries { return fmt.Errorf("timeout error: pod %q containers not running after %d retries", format.Pod(pod), runOnceMaxRetries) } // TODO(proppy): health checking would be better than waiting + checking the state at the next iteration.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0) -
src/runtime/os_aix.go
sigprocmask(_SIG_SETMASK, &sigset_all, &oset) var ret int32 for tries := 0; tries < 20; tries++ { // pthread_create can fail with EAGAIN for no reasons // but it will be ok if it retries. ret = pthread_create(&tid, &attr, fn, nil) if ret != _EAGAIN { break } usleep(uint32(tries+1) * 1000) // Milliseconds. } sigprocmask(_SIG_SETMASK, &oset, nil) if ret != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/visitor_test.go
}, { name: "Test that 500s are retried", httpRetries: func(url string) (int, string, io.ReadCloser, error) { assert.Equal(t, "hello", url) i++ return 501, "Status", io.NopCloser(new(bytes.Buffer)), nil }, args: httpArgs{ duration: 0, u: "hello", attempts: 3, }, count: 3, }, { name: "Test that 300s are not retried",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 09:47:52 UTC 2023 - 9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
if emitEventFunc != nil { emitEventFunc(args.NamespacedName) } var err error for i := 0; i < retries; i++ { err = addConditionAndDeletePod(ctx, c, name, ns) if err == nil { metrics.PodDeletionsTotal.Inc() metrics.PodDeletionsLatency.Observe(float64(time.Since(fireAt) * time.Second)) break } time.Sleep(10 * time.Millisecond) } return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
cluster/gce/gci/configure.sh
echo "Supported architecture(s): amd64 and arm64." >&2 echo "Bailing out." >&2 exit 2 ;; esac } # Retries a command forever with a delay between retries. # Args: # $1 : delay between retries, in seconds. # $2... : the command to run. function retry-forever { local -r delay="$1" shift 1 until "$@"; do
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 04:14:02 UTC 2024 - 36.5K bytes - Viewed (0) -
pkg/test/framework/suite.go
scopes.Framework.Infof("Wrote trace to %v", prow.ArtifactsURL(traceFile)) _ = appendToFile(ctx.marshalTraceEvent(), traceFile) }() attempt := 0 for attempt <= ctx.settings.Retries { attempt++ scopes.Framework.Infof("=== BEGIN: Test Run: '%s' ===", ctx.Settings().TestID) errLevel = s.mRun(ctx) if errLevel == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/kubeapiserver/authorizer/config.go
// Options for ModeWebhook // WebhookRetryBackoff specifies the backoff parameters for the authorization webhook retry logic. // This allows us to configure the sleep time at each iteration and the maximum number of retries allowed // before we fail the webhook call in order to limit the fan out that ensues when the system is degraded. WebhookRetryBackoff *wait.Backoff VersionedInformerFactory versionedinformers.SharedInformerFactory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 8K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/dep-man/01-core-dependency-management/dependency_resolution.adoc
That last point is important for reproducibility. If the build was allowed to continue, ignoring the faulty repository, subsequent builds could have a different result once the repository is back online. [[sub:http-retries]] ==== HTTP Retries Gradle will make several attempts to connect to a given repository before disabling it.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 07 01:37:51 UTC 2023 - 22.1K bytes - Viewed (0)