- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 115 for newCounter (0.27 sec)
-
pkg/monitoring/counter.go
baseMetric c api.Float64Counter // precomputedAddOption is just a precomputation to avoid allocations on each record call precomputedAddOption []api.AddOption } var _ Metric = &counter{} func newCounter(o options) *counter { c, err := meter().Float64Counter(o.name, api.WithDescription(o.description), api.WithUnit(string(o.unit))) if err != nil { log.Fatalf("failed to create counter: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/metrics.go
}, []string{"type"}, ) // clusterIPRepairReconcileErrors indicates the number of times the repair loop has failed to repair // the errors it detected. clusterIPRepairReconcileErrors = metrics.NewCounter( &metrics.CounterOpts{ Namespace: namespace, Subsystem: subsystem, Name: "reconcile_errors_total",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 2K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/metrics/metrics.go
retroactiveStorageClassMetric = metrics.NewCounter( &metrics.CounterOpts{ Name: "retroactive_storageclass_total", Help: "Total number of retroactive StorageClass assignments to persistent volume claim", StabilityLevel: metrics.ALPHA, }) retroactiveStorageClassErrorMetric = metrics.NewCounter( &metrics.CounterOpts{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 25 13:09:16 UTC 2022 - 10.5K bytes - Viewed (0) -
pkg/kubelet/certificate/kubelet.go
certDirectory, kubeCfg.TLSCertFile, kubeCfg.TLSPrivateKeyFile) if err != nil { return nil, fmt.Errorf("failed to initialize server certificate store: %v", err) } var certificateRenewFailure = compbasemetrics.NewCounter( &compbasemetrics.CounterOpts{ Subsystem: metrics.KubeletSubsystem, Name: "server_expiration_renew_errors", Help: "Counter of certificate renewal errors.",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 03:07:16 UTC 2024 - 10.3K bytes - Viewed (0) -
src/cmd/go/internal/help/help.go
import ( "bufio" "fmt" "io" "os" "strings" "text/template" "unicode" "unicode/utf8" "cmd/go/internal/base" "cmd/internal/telemetry" ) var counterErrorsHelpUnknownTopic = telemetry.NewCounter("go/errors:help-unknown-topic") // Help implements the 'help' command. func Help(w io.Writer, args []string) { // 'go help documentation' generates doc.go. if len(args) == 1 && args[0] == "documentation" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 4.7K bytes - Viewed (0) -
src/cmd/cover/cover.go
func atomicCounterStmt(f *File, counter string) string { return fmt.Sprintf("%sAddUint32(&%s, 1)", atomicPackagePrefix(), counter) } // newCounter creates a new counter expression of the appropriate form. func (f *File) newCounter(start, end token.Pos, numStmt int) string { var stmt string if *pkgcfg != "" { slot := len(f.fn.units) + coverage.FirstCtrOffset if f.fn.counterVar == "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 34.5K bytes - Viewed (0) -
src/cmd/go/internal/work/buildid.go
if err != nil { return "" } return buildid.HashToString(sum) } var ( counterCacheHit = telemetry.NewCounter("go/buildcache/hit") counterCacheMiss = telemetry.NewCounter("go/buildcache/miss") onceIncStdlibRecompiled sync.Once stdlibRecompiled = telemetry.NewCounter("go/buildcache/stdlib-recompiled") ) // useCache tries to satisfy the action a, which has action ID actionHash,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:31:25 UTC 2024 - 26.2K bytes - Viewed (0) -
pkg/scheduler/metrics/metrics.go
// we think #victims>64 is pretty rare, therefore [64, +Inf) is considered a single bucket. Buckets: metrics.ExponentialBuckets(1, 2, 7), StabilityLevel: metrics.STABLE, }) PreemptionAttempts = metrics.NewCounter( &metrics.CounterOpts{ Subsystem: SchedulerSubsystem, Name: "preemption_attempts_total", Help: "Total preemption attempts in the cluster till now", StabilityLevel: metrics.STABLE,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 08:22:53 UTC 2024 - 11.1K bytes - Viewed (0) -
src/cmd/go/internal/toolchain/switch.go
fmt.Fprintf(os.Stderr, "go: %v requires go >= %v; switching to %v\n", s.TooNew.What, s.TooNew.GoVersion, tv) counterSwitchExec.Inc() Exec(tv) panic("unreachable") } var counterSwitchExec = telemetry.NewCounter("go/toolchain/switch-exec") // SwitchOrFatal attempts a toolchain switch based on the information in err // and otherwise falls back to base.Fatal(err). func SwitchOrFatal(ctx context.Context, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 7K bytes - Viewed (0) -
pkg/monitoring/monitoring.go
Name: name, Type: "Sum", Description: description, }) o, dm := createOptions(name, description, opts...) if dm != nil { return dm } return newCounter(o) } // NewGauge creates a new Gauge Metric. That means that data collected by the new // Metric will export only the last recorded value. func NewGauge(name, description string, opts ...Options) Metric {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 9.5K bytes - Viewed (0)