Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for WithExponentialBackoff (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top