- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for WithExponentialBackoff (0.16 sec)
-
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go
// then the default one is used (DefaultShouldRetry). func (g *GenericWebhook) WithExponentialBackoff(ctx context.Context, webhookFn func() rest.Result) rest.Result { var result rest.Result shouldRetry := g.ShouldRetry if shouldRetry == nil { shouldRetry = DefaultShouldRetry } WithExponentialBackoff(ctx, g.RetryBackoff, func() error { result = webhookFn() return result.Error() }, shouldRetry)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 20 19:02:55 UTC 2023 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go
} result := wh.WithExponentialBackoff(context.Background(), func() rest.Result { return wh.RestClient.Get().Do(context.TODO()) }) var statusCode int result.StatusCode(&statusCode) if statusCode != http.StatusNotAcceptable { t.Errorf("unexpected status code: %d", statusCode) } result = wh.WithExponentialBackoff(context.Background(), func() rest.Result {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 25.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook.go
if w.requestTimeout > 0 { ctx, cancel = context.WithTimeout(ctx, w.requestTimeout) defer cancel() } // WithExponentialBackoff will return tokenreview create error (tokenReviewErr) if any. if err := webhook.WithExponentialBackoff(ctx, w.retryBackoff, func() error { var tokenReviewErr error var statusCode int start := time.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 18 00:47:42 UTC 2022 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/webhook/webhook.go
return true } func (b *backend) processEvents(ev ...*auditinternal.Event) error { var list auditinternal.EventList for _, e := range ev { list.Items = append(list.Items, *e) } return b.w.WithExponentialBackoff(context.Background(), func() rest.Result { ctx, span := tracing.Start(context.Background(), "Call Audit Events webhook", attribute.String("name", b.name), attribute.Int("event-count", len(list.Items)), )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 07 21:13:31 UTC 2022 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook.go
r.Status = entry.(authorizationv1.SubjectAccessReviewStatus) } else { var result *authorizationv1.SubjectAccessReview var metricsResult string // WithExponentialBackoff will return SAR create error (sarErr) if any. if err := webhook.WithExponentialBackoff(ctx, w.retryBackoff, func() error { var sarErr error var statusCode int start := time.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 18.4K bytes - Viewed (0) -
plugin/pkg/admission/imagepolicy/admission.go
if err != nil { return err } if entry, ok := a.responseCache.Get(string(cacheKey)); ok { review.Status = entry.(v1alpha1.ImageReviewStatus) } else { result := a.webhook.WithExponentialBackoff(ctx, func() rest.Result { return a.webhook.RestClient.Post().Body(review).Do(ctx) }) if err := result.Error(); err != nil { return a.webhookError(pod, attributes, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 02 06:05:06 UTC 2023 - 9.8K bytes - Viewed (0)