- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 3,352 for Retries (0.19 sec)
-
pkg/test/framework/resource/flags.go
"Skips deploying and using workloads not included in the given comma-separated classes (e.g. vm, proxyless, etc.)") flag.IntVar(&settingsFromCommandLine.Retries, "istio.test.retries", settingsFromCommandLine.Retries, "Number of times to retry tests") flag.BoolVar(&settingsFromCommandLine.StableNamespaces, "istio.test.stableNamespaces", settingsFromCommandLine.StableNamespaces,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 14K bytes - Viewed (0) -
cmd/batch-expire_test.go
endpoint: https://notify.endpoint # notification endpoint to receive job completion status token: Bearer xxxxx # optional authentication token for the notification endpoint retry: attempts: 10 # number of retries for the job before giving up delay: 500ms # least amount of delay between each retry ` var job BatchJobRequest err := yaml.UnmarshalStrict([]byte(expireYaml), &job) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 3K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/config/types.go
FlexVolumePluginDir string } // PersistentVolumeRecyclerConfiguration contains elements describing persistent volume plugins. type PersistentVolumeRecyclerConfiguration struct { // maximumRetry is number of retries the PV recycler will execute on failure to recycle // PV. MaximumRetry int32 // minimumTimeoutNFS is the minimum ActiveDeadlineSeconds to use for an NFS Recycler // pod. MinimumTimeoutNFS int32
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 02:59:09 UTC 2024 - 3.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
/** * Returns a timeout that spans the entire call: resolving DNS, connecting, writing the request * body, server processing, and reading the response body. If the call requires redirects or * retries all must complete within one timeout period. * * Configure the client's default timeout with [OkHttpClient.Builder.callTimeout]. */ fun timeout(): Timeout /**
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook_v1_test.go
{ description: "an0th3r_t0k3n, 500 response, disallowed, should be called again with retries", token: "an0th3r_t0k3n", allow: false, code: 500, expectError: true, expectOk: false, expectCalls: 5, }, { description: "an0th3r_t0k3n, 429 response, disallowed, should be called again with retries", token: "an0th3r_t0k3n", allow: false, code: 429,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 18 00:47:42 UTC 2022 - 19.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook_v1beta1_test.go
{ description: "an0th3r_t0k3n, 500 response, disallowed, should be called again with retries", token: "an0th3r_t0k3n", allow: false, code: 500, expectError: true, expectOk: false, expectCalls: 5, }, { description: "an0th3r_t0k3n, 429 response, disallowed, should be called again with retries", token: "an0th3r_t0k3n", allow: false, code: 429,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 18 00:47:42 UTC 2022 - 19.2K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
func (c *Client) WaitForClusterAvailable(retries int, retryInterval time.Duration) (bool, error) { for i := 0; i < retries; i++ { if i > 0 { klog.V(1).Infof("[etcd] Waiting %v until next retry\n", retryInterval) time.Sleep(retryInterval) } klog.V(2).Infof("[etcd] attempting to see if all cluster endpoints (%s) are available %d/%d", c.Endpoints, i+1, retries) _, err := c.getClusterStatus() if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/ExponentialBackoff.java
this.signal = signal; this.slotTime = slotTime; restartTimer(); } public void restartTimer() { timer = Time.startCountdownTimer(timeoutMs); } /** * Retries the given query until it returns a 'sucessful' result. * * @param query which returns non-null value when successful. * @param <T> the result type. * @return the last value returned by the query.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:49:35 UTC 2024 - 4.8K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/nodelifecyclecontroller.go
"Amount of time which we allow running Node to be unresponsive before marking it unhealthy. "+ "Must be N times more than kubelet's nodeStatusUpdateFrequency, "+ "where N means number of retries allowed for kubelet to post node status.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 09:25:51 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/kubelet/config/http.go
config := &sourceURL{ url: url, header: header, nodeName: nodeName, updates: updates, data: nil, // Timing out requests leads to retries. This client is only used to // read the manifest URL passed to kubelet. client: &http.Client{Timeout: 10 * time.Second}, } klog.V(1).InfoS("Watching URL", "URL", url) go wait.Until(config.run, period, wait.NeverStop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 01 07:19:44 UTC 2021 - 4.1K bytes - Viewed (0)