- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 226 for Backoff (0.1 sec)
-
pkg/registry/rbac/rest/storage_rbac.go
} func isConflictOrServiceUnavailable(err error) bool { return apierrors.IsConflict(err) || apierrors.IsServiceUnavailable(err) } func retryOnConflictOrServiceUnavailable(backoff wait.Backoff, fn func() error) error { return retry.OnError(backoff, isConflictOrServiceUnavailable, fn) } func (p *PolicyData) EnsureRBACPolicy() genericapiserver.PostStartHookFunc { return func(hookContext genericapiserver.PostStartHookContext) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 14 03:25:19 UTC 2022 - 18.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/error.go
// Until loop exited for any reason besides the condition returning true or an // error. A loop is considered interrupted if the calling context is cancelled, // the context reaches its deadline, or a backoff reaches its maximum allowed // steps. // // Callers should use this method instead of comparing the error value directly to // ErrWaitTimeout, as methods that cancel a context may not return that error. // // Instead of:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 3K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/lockedfile_plan9.go
// second open is attempted, it draws an error.” // // So we can try to open a locked file, but if it fails we're on our own to // figure out when it becomes available. We'll use exponential backoff with // some jitter and an arbitrary limit of 500ms. // If the file was unpacked or created by some other program, it might not // have the ModeExclusive bit set. Set it before we call OpenFile, so that we
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:34:30 UTC 2022 - 2.5K bytes - Viewed (0) -
src/net/tcpsockopt_solaris.go
} if interval < 0 && count < 0 { abortIdle = -1 } if abortIdle > 0 { // Note that the consequent probes will not be sent at equal intervals on Solaris, // but will be sent using the exponential backoff algorithm. err := fd.pfd.SetsockoptInt(syscall.IPPROTO_TCP, syscall.TCP_KEEPALIVE_ABORT_THRESHOLD, abortIdle) runtime.KeepAlive(fd) return wrapSyscallError("setsockopt", err) } return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 03:10:07 UTC 2024 - 3.3K bytes - Viewed (0) -
plugin/pkg/admission/imagepolicy/config.go
type AdmissionConfig struct { ImagePolicyWebhook imagePolicyWebhookConfig `json:"imagePolicy"` } func normalizeWebhookConfig(config *imagePolicyWebhookConfig) (err error) { config.RetryBackoff, err = normalizeConfigDuration("backoff", time.Millisecond, config.RetryBackoff, minRetryBackoff, maxRetryBackoff, defaultRetryBackoff) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 25 04:07:36 UTC 2022 - 3.1K bytes - Viewed (0) -
src/net/lookup_test.go
cname, srvs, err := LookupSRV(tt.service, tt.proto, tt.name) if err != nil { testenv.SkipFlakyNet(t) if attempts < len(backoffDuration) { dur := backoffDuration[attempts] t.Logf("backoff %v after failure %v\n", dur, err) time.Sleep(dur) attempts++ i-- continue } t.Fatal(err) } if len(srvs) == 0 { t.Error("got no record") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 41.4K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
log.Infof("Waiting for data to be populated in %s", secret.Name) err = backoff.Retry( func() error { secret, err = client.Kube().CoreV1().Secrets(secret.Namespace).Get(context.TODO(), secret.Name, metav1.GetOptions{}) if err != nil { return err } ca, token, err = tokenDataFromSecret(secret) return err }, backoff.WithMaxRetries(backoff.NewConstantBackOff(tokenWaitBackoff), 5)) return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 11 01:43:17 UTC 2023 - 24K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
// These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 sconfig.Producer.Retry.Max = 2 sconfig.Producer.Retry.Backoff = (10 * time.Second) sconfig.Producer.Return.Successes = true sconfig.Producer.Return.Errors = true sconfig.Producer.RequiredAcks = 1 sconfig.Producer.Timeout = (10 * time.Second)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/adsc/delta.go
mutex: sync.RWMutex{}, } for _, o := range opts { o(c) } return c } func NewDeltaWithBackoffPolicy(discoveryAddr string, config *DeltaADSConfig, backoffPolicy backoff.BackOff, opts ...Option) *Client { if config == nil { config = &DeltaADSConfig{} } delta := NewDelta(discoveryAddr, config, opts...) delta.cfg.BackoffPolicy = backoffPolicy return delta }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 09:32:41 UTC 2024 - 20.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/ErrorHandlingModuleComponentRepositoryTest.groovy
private ErrorHandlingModuleComponentRepository.ErrorHandlingModuleComponentRepositoryAccess createAccess(int maxRetries = 1, int backoff = 0) { new ErrorHandlingModuleComponentRepository.ErrorHandlingModuleComponentRepositoryAccess(delegate, 'abc', repositoryBlacklister, maxRetries, backoff, 'abc') } private static HttpErrorStatusCodeException status(int statusCode) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 00:21:07 UTC 2024 - 13.5K bytes - Viewed (0)