Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 58 for registerMetric (4.24 sec)

  1. src/internal/godebug/godebug.go

    // (due to use of os.Setenv, for example).
    //
    //go:linkname setUpdate
    func setUpdate(update func(string, string))
    
    // registerMetric is provided by package runtime.
    // It forwards registrations to runtime/metrics.
    //
    //go:linkname registerMetric
    func registerMetric(name string, read func() uint64)
    
    // setNewIncNonDefault is provided by package runtime.
    // The runtime can do
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Mar 09 14:19:39 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. src/runtime/metrics.go

    type metricReader func() uint64
    
    func (f metricReader) compute(_ *statAggregate, out *metricValue) {
    	out.kind = metricKindUint64
    	out.scalar = f()
    }
    
    //go:linkname godebug_registerMetric internal/godebug.registerMetric
    func godebug_registerMetric(name string, read func() uint64) {
    	metricsLock()
    	initMetrics()
    	d, ok := metrics[name]
    	if !ok {
    		throw("runtime: unexpected metric registration for " + name)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 08 21:03:13 UTC 2024
    - 26K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/metrics.go

    			Buckets: []float64{.001, .005, .01, .025, .05, .1, .25, .5, 1, 2.5, 5, 10},
    		},
    		[]string{"result", "jwt_issuer_hash"},
    	)
    )
    
    var registerMetrics sync.Once
    
    func RegisterMetrics() {
    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(jwtAuthenticatorLatencyMetric)
    	})
    }
    
    func recordAuthenticationLatency(result, jwtIssuerHash string, duration time.Duration) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 19:29:33 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/authorization/authorizerfactory/metrics.go

    	compbasemetrics "k8s.io/component-base/metrics"
    	"k8s.io/component-base/metrics/legacyregistry"
    )
    
    var registerMetrics sync.Once
    
    // RegisterMetrics registers authorizer metrics.
    func RegisterMetrics() {
    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(requestTotal)
    		legacyregistry.MustRegister(requestLatency)
    	})
    }
    
    var (
    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/pkg/authorization/cel/metrics.go

    			Buckets:        []float64{0.001, 0.005, 0.01, 0.025, 0.1, 0.2, 0.25},
    			StabilityLevel: metrics.ALPHA,
    		},
    		[]string{"type", "name"},
    	)
    )
    
    var registerMetrics sync.Once
    
    func RegisterMetrics() {
    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(authorizationMatchConditionEvaluationErrorsTotal)
    		legacyregistry.MustRegister(authorizationMatchConditionExclusionsTotal)
    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/pkg/server/options/authenticationconfig/metrics/metrics.go

    			StabilityLevel: metrics.ALPHA,
    		},
    		[]string{"status", "apiserver_id_hash"},
    	)
    )
    
    var registerMetrics sync.Once
    
    func RegisterMetrics() {
    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(authenticationConfigAutomaticReloadsTotal)
    		legacyregistry.MustRegister(authenticationConfigAutomaticReloadLastTimestampSeconds)
    	})
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 22:40:22 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/options/authenticationconfig/metrics/metrics_test.go

    	`
    	metrics := []string{
    		namespace + "_" + subsystem + "_automatic_reloads_total",
    	}
    
    	authenticationConfigAutomaticReloadsTotal.Reset()
    	RegisterMetrics()
    
    	RecordAuthenticationConfigAutomaticReloadFailure(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: Sat Mar 09 22:40:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/authorization/metrics/metrics.go

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

    	`
    	metrics := []string{
    		namespace + "_" + subsystem + "_automatic_reloads_total",
    	}
    
    	authorizationConfigAutomaticReloadsTotal.Reset()
    	RegisterMetrics()
    
    	RecordAuthorizationConfigAutomaticReloadFailure(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)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/metrics/metrics.go

    			// apiserver limit.
    			Buckets:        metrics.LinearBuckets(50000, 100000, 31),
    			StabilityLevel: metrics.ALPHA,
    		},
    		[]string{"resource", "verb"},
    	)
    )
    
    var registerMetrics sync.Once
    
    // Register all metrics.
    func Register() {
    	registerMetrics.Do(func() {
    		legacyregistry.MustRegister(RequestBodySizes)
    	})
    }
    
    func RecordRequestBodySize(ctx context.Context, resource string, verb RequestBodyVerb, size int) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 02:06:01 UTC 2023
    - 1.8K bytes
    - Viewed (0)
Back to top