Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ResetMetricsForTest (0.35 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/options/authenticationconfig/metrics/metrics.go

    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(authenticationConfigAutomaticReloadsTotal)
    		legacyregistry.MustRegister(authenticationConfigAutomaticReloadLastTimestampSeconds)
    	})
    }
    
    func ResetMetricsForTest() {
    	authenticationConfigAutomaticReloadsTotal.Reset()
    	authenticationConfigAutomaticReloadLastTimestampSeconds.Reset()
    }
    
    func RecordAuthenticationConfigAutomaticReloadFailure(apiServerID string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 22:40:22 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/authorization/metrics/metrics.go

    	)
    )
    
    var registerMetrics sync.Once
    
    func RegisterMetrics() {
    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(authorizationDecisionsTotal)
    	})
    }
    
    func ResetMetricsForTest() {
    	authorizationDecisionsTotal.Reset()
    }
    
    func RecordAuthorizationDecision(authorizerType, authorizerName, decision string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 13:20:59 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/options/authorizationconfig/metrics/metrics.go

    				return sha256.New()
    			},
    		}
    		legacyregistry.MustRegister(authorizationConfigAutomaticReloadsTotal)
    		legacyregistry.MustRegister(authorizationConfigAutomaticReloadLastTimestampSeconds)
    	})
    }
    
    func ResetMetricsForTest() {
    	authorizationConfigAutomaticReloadsTotal.Reset()
    	authorizationConfigAutomaticReloadLastTimestampSeconds.Reset()
    }
    
    func RecordAuthorizationConfigAutomaticReloadFailure(apiServerID string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 13:20:59 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/authorization/cel/metrics_test.go

    			apiserver_authorization_match_condition_exclusions_total{name="wh1.example.com",type="Webhook"} 1
    			`,
    		},
    	}
    
    	for _, tt := range testCases {
    		t.Run(tt.desc, func(t *testing.T) {
    			ResetMetricsForTest()
    			m := NewMatcherMetrics()
    			m.RecordAuthorizationMatchConditionEvaluationFailure(context.Background(), tt.authztype, tt.name)
    			m.RecordAuthorizationMatchConditionExclusion(context.Background(), tt.authztype, tt.name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 22:41:27 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/authorization/cel/metrics.go

    		legacyregistry.MustRegister(authorizationMatchConditionExclusionsTotal)
    		legacyregistry.MustRegister(authorizationMatchConditionEvaluationSeconds)
    	})
    }
    
    func ResetMetricsForTest() {
    	authorizationMatchConditionEvaluationErrorsTotal.Reset()
    	authorizationMatchConditionExclusionsTotal.Reset()
    	authorizationMatchConditionEvaluationSeconds.Reset()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 22:41:27 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/metrics/metrics.go

    	registerWebhookMetrics.Do(func() {
    		legacyregistry.MustRegister(webhookEvaluations)
    		legacyregistry.MustRegister(webhookDuration)
    		legacyregistry.MustRegister(webhookFailOpen)
    	})
    }
    
    func ResetMetricsForTest() {
    	webhookEvaluations.Reset()
    	webhookDuration.Reset()
    	webhookFailOpen.Reset()
    }
    
    const (
    	namespace = "apiserver"
    	subsystem = "authorization"
    )
    
    var (
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook_v1_test.go

    					`, "wh1.example.com", "Webhook", "wh2.example.com", "Webhook"),
    		},
    	}
    
    	for _, tt := range testCases {
    		t.Run(tt.name, func(t *testing.T) {
    			celmetrics.ResetMetricsForTest()
    			defer celmetrics.ResetMetricsForTest()
    			wh1, err := newV1Authorizer(s.URL, clientCert, clientKey, caCert, 0, celAuthorizerMetrics(), tt.expressions1, "wh1.example.com")
    			if err != nil {
    				t.Fatal(err)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 43.2K bytes
    - Viewed (0)
Back to top