Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for RecordRequestTotal (0.29 sec)

  1. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/metrics.go

    package webhook
    
    import (
    	"context"
    )
    
    // AuthenticatorMetrics specifies a set of methods that are used to register various metrics
    type AuthenticatorMetrics struct {
    	// RecordRequestTotal increments the total number of requests for webhooks
    	RecordRequestTotal func(ctx context.Context, code string)
    
    	// RecordRequestLatency measures request latency in seconds for webhooks. Broken down by status code.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 29 07:49:14 UTC 2021
    - 1.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/authentication/authenticatorfactory/metrics.go

    			StabilityLevel: compbasemetrics.ALPHA,
    		},
    		[]string{"code"},
    	)
    
    	metrics = registerables{
    		requestTotal,
    		requestLatency,
    	}
    )
    
    // RecordRequestTotal increments the total number of requests for the delegated authentication.
    func RecordRequestTotal(ctx context.Context, code string) {
    	requestTotal.WithContext(ctx).WithLabelValues(code).Inc()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 29 07:49:14 UTC 2021
    - 2.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/metrics_test.go

    				t.Errorf("%s: failed to create server: %v", scenario.name, err)
    				return
    			}
    			defer server.Close()
    
    			fakeAuthnMetrics := &fakeAuthenticatorMetrics{}
    			authnMetrics := AuthenticatorMetrics{
    				RecordRequestTotal:   fakeAuthnMetrics.RequestTotal,
    				RecordRequestLatency: fakeAuthnMetrics.RequestLatency,
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 29 07:49:14 UTC 2021
    - 3.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/authorization/authorizerfactory/metrics.go

    }
    
    func NewDelegatingAuthorizerMetrics() delegatingAuthorizerMetrics {
    	RegisterMetrics()
    	return delegatingAuthorizerMetrics{}
    }
    
    // RecordRequestTotal increments the total number of requests for the delegated authorization.
    func (delegatingAuthorizerMetrics) RecordRequestTotal(ctx context.Context, code string) {
    	requestTotal.WithContext(ctx).WithLabelValues(code).Add(1)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/metrics/metrics.go

    }
    
    type NoopAuthorizerMetrics struct {
    	NoopRequestMetrics
    	NoopWebhookMetrics
    	cel.NoopMatcherMetrics
    }
    
    type RequestMetrics interface {
    	// RecordRequestTotal increments the total number of requests for the webhook authorizer
    	RecordRequestTotal(ctx context.Context, code string)
    
    	// RecordRequestLatency measures request latency in seconds for webhooks. Broken down by status code.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/authentication/authenticatorfactory/delegating.go

    		}
    		tokenAuth, err := webhooktoken.NewFromInterface(c.TokenAccessReviewClient, c.APIAudiences, *c.WebhookRetryBackoff, c.TokenAccessReviewTimeout, webhooktoken.AuthenticatorMetrics{
    			RecordRequestTotal:   RecordRequestTotal,
    			RecordRequestLatency: RecordRequestLatency,
    		})
    		if err != nil {
    			return nil, nil, err
    		}
    		cachingTokenAuth := cache.New(tokenAuth, false, c.CacheTTL, c.CacheTTL)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 29 07:49:14 UTC 2021
    - 5.1K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/metrics_test.go

    					t.Errorf("expected error making authorization request: %v", err)
    				}
    			}
    
    			if fakeAuthzMetrics.totalCode != scenario.expectedRegisteredStatusCode {
    				t.Errorf("incorrect status code recorded for RecordRequestTotal method, expected = %v, got %v", scenario.expectedRegisteredStatusCode, fakeAuthzMetrics.totalCode)
    			}
    
    			if fakeAuthzMetrics.latencyCode != scenario.expectedRegisteredStatusCode {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook.go

    		latency := time.Since(start)
    
    		if statusCode != 0 {
    			w.metrics.RecordRequestTotal(ctx, strconv.Itoa(statusCode))
    			w.metrics.RecordRequestLatency(ctx, strconv.Itoa(statusCode), latency.Seconds())
    			return tokenReviewErr
    		}
    
    		if tokenReviewErr != nil {
    			w.metrics.RecordRequestTotal(ctx, "<error>")
    			w.metrics.RecordRequestLatency(ctx, "<error>", latency.Seconds())
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 18 00:47:42 UTC 2022
    - 11.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook.go

    			if statusCode != 0 {
    				w.metrics.RecordRequestTotal(ctx, strconv.Itoa(statusCode))
    				w.metrics.RecordRequestLatency(ctx, strconv.Itoa(statusCode), latency.Seconds())
    				return sarErr
    			}
    
    			if sarErr != nil {
    				w.metrics.RecordRequestTotal(ctx, "<error>")
    				w.metrics.RecordRequestLatency(ctx, "<error>", latency.Seconds())
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/webhook_v1beta1_test.go

    	if err != nil {
    		return nil, err
    	}
    
    	authn, err := newWithBackoff(c, testRetryBackoff, implicitAuds, 10*time.Second, AuthenticatorMetrics{
    		RecordRequestTotal:   noopMetrics{}.RequestTotal,
    		RecordRequestLatency: noopMetrics{}.RequestLatency,
    	})
    	if err != nil {
    		return nil, err
    	}
    
    	return cache.New(authn, false, cacheTime, cacheTime), nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 18 00:47:42 UTC 2022
    - 19.2K bytes
    - Viewed (0)
Back to top