- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for RecordRequestTotal (0.29 sec)
-
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) -
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) -
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/webhook/metrics_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 29 07:49:14 UTC 2021 - 3.7K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)