Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for RecordRequestTotal (0.19 sec)

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