- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 3,352 for Retries (0.18 sec)
-
pkg/controller/volume/pvprotection/pv_protection_controller_test.go
name: "PVC with finalizer -> no action", updatedPV: withProtectionFinalizer(pv()), expectedActions: []clienttesting.Action{}, }, { name: "saving PVC finalizer fails -> controller retries", updatedPV: pv(), reactors: []reaction{ { verb: "update", resource: "persistentvolumes", reactorfn: generateUpdateErrorFunc(t, 2 /* update fails twice*/), }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 12:57:29 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/webhooks/monitoring.go
"webhook_patch_attempts_total", "Webhook patching attempts", ) metricWebhookPatchRetries = monitoring.NewSum( "webhook_patch_retries_total", "Webhook patching retries", ) metricWebhookPatchFailures = monitoring.NewSum( "webhook_patch_failures_total", "Webhook patching total failures", ) ) const ( // webhook patching failure reasons
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/helpers.go
if err == nil { return crd, nil } if !errors.IsConflict(err) { return nil, fmt.Errorf("failed to update CustomResourceDefinition %q: %v", name, err) } } return nil, fmt.Errorf("too many retries after conflicts updating CustomResourceDefinition %q", name) } // UpdateV1CustomResourceDefinitionWithRetry updates a CRD, retrying up to 5 times on version conflict errors.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 30 11:46:49 UTC 2021 - 7.2K bytes - Viewed (0) -
pkg/security/retry.go
"istio.io/istio/pkg/log" "istio.io/istio/security/pkg/monitoring" ) var caLog = log.RegisterScope("ca", "ca client") // CARetryOptions returns the default retry options recommended for CA calls // This includes 5 retries, with backoff from 100ms -> 1.6s with jitter. var CARetryOptions = []retry.CallOption{ retry.WithMax(5), retry.WithBackoff(wrapBackoffWithMetrics(retry.BackoffExponentialWithJitter(100*time.Millisecond, 0.1))),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.2K bytes - Viewed (0) -
src/os/user/cgo_listgroups_unix.go
return nil, err } } gidsC = gidsC[:n] gids := make([]string, 0, n) for _, g := range gidsC[:n] { gids = append(gids, strconv.Itoa(int(g))) } return gids, nil } // groupRetry retries getGroupList with much larger size for n. The result is // stored in gids. func groupRetry(username string, name []byte, userGID _C_gid_t, gids *[]_C_gid_t, n *_C_int) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 11 04:31:34 UTC 2022 - 1.7K bytes - Viewed (0) -
pkg/backoff/exponential_test.go
c.i += time.Second return t } func TestRetry(t *testing.T) { o := DefaultOption() o.InitialInterval = 1 * time.Microsecond ebf := NewExponentialBackOff(o) // Run a task that fails the first time and retries. wg := sync.WaitGroup{} wg.Add(2) failed := false err := ebf.RetryWithContext(context.TODO(), func() error { defer wg.Done() if failed { return nil } failed = true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 05 16:03:30 UTC 2022 - 2.6K bytes - Viewed (0) -
bin/retry.sh
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # retry.sh retries a command until it succeeds. It accepts a regex pattern to match failures on to # determine if a retry should be attempted. # Example: retry.sh "connection timed out" ./my-flaky-script.sh some args
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 11 16:08:08 UTC 2021 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authorization/authorizerfactory/delegating.go
DenyCacheTTL time.Duration // 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 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 22:41:27 UTC 2024 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storageversion/updater.go
func updateStorageVersionFor(c Client, apiserverID string, gr schema.GroupResource, encodingVersion string, decodableVersions []string, servedVersions []string) error { retries := 3 var retry int var err error for retry < retries { err = singleUpdate(c, apiserverID, gr, encodingVersion, decodableVersions, servedVersions) if err == nil { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 22:40:54 UTC 2023 - 6.9K bytes - Viewed (0) -
src/net/dnsconfig.go
search []string // rooted suffixes to append to local name ndots int // number of dots in name to trigger absolute lookup timeout time.Duration // wait before giving up on a query, including retries attempts int // lost packets before giving up on server rotate bool // round robin among servers unknownOpt bool // anything unknown was encountered
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 2.2K bytes - Viewed (0)