Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for RecordAuthorizationConfigAutomaticReloadSuccess (0.53 sec)

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

    	authorizationConfigAutomaticReloadLastTimestampSeconds.WithLabelValues("failure", apiServerIDHash).SetToCurrentTime()
    }
    
    func RecordAuthorizationConfigAutomaticReloadSuccess(apiServerID string) {
    	apiServerIDHash := getHash(apiServerID)
    	authorizationConfigAutomaticReloadsTotal.WithLabelValues("success", apiServerIDHash).Inc()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 13:20:59 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/options/authorizationconfig/metrics/metrics_test.go

    	`
    	metrics := []string{
    		namespace + "_" + subsystem + "_automatic_reloads_total",
    	}
    
    	authorizationConfigAutomaticReloadsTotal.Reset()
    	RegisterMetrics()
    
    	RecordAuthorizationConfigAutomaticReloadSuccess(testAPIServerID)
    	if err := testutil.GatherAndCompare(legacyregistry.DefaultGatherer, strings.NewReader(expectedValue), metrics...); err != nil {
    		t.Fatal(err)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 23:09:15 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. pkg/kubeapiserver/authorizer/reload.go

    // Blocks until ctx is complete.
    func (r *reloadableAuthorizerResolver) runReload(ctx context.Context) {
    	metrics.RegisterMetrics()
    	metrics.RecordAuthorizationConfigAutomaticReloadSuccess(r.apiServerID)
    
    	filesystem.WatchUntil(
    		ctx,
    		r.reloadInterval,
    		r.initialConfig.ReloadFile,
    		func() {
    			r.checkFile(ctx)
    		},
    		func(err error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 9.3K bytes
    - Viewed (0)
Back to top