- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 69 for newCounter (0.18 sec)
-
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
// we can just do that work here. AtomicInteger newCounter = new AtomicInteger(occurrences); if ((countMap.putIfAbsent(element, newCounter) == null) || countMap.replace(element, existingCounter, newCounter)) { return 0; } break; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 20.9K bytes - Viewed (0) -
pkg/proxy/metrics/metrics.go
StabilityLevel: metrics.ALPHA, }, ) // EndpointChangesTotal is the number of endpoint changes that the proxy // has seen. EndpointChangesTotal = metrics.NewCounter( &metrics.CounterOpts{ Subsystem: kubeProxySubsystem, Name: "sync_proxy_rules_endpoint_changes_total", Help: "Cumulative proxy rules Endpoint changes",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/kubelet/metrics/metrics.go
StartedPodsTotal = metrics.NewCounter( &metrics.CounterOpts{ Subsystem: KubeletSubsystem, Name: StartedPodsTotalKey, Help: "Cumulative number of pods started", StabilityLevel: metrics.ALPHA, }, ) // StartedPodsErrorsTotal is a counter that tracks the number of errors creating pod sandboxes StartedPodsErrorsTotal = metrics.NewCounter( &metrics.CounterOpts{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 15:13:25 UTC 2024 - 45.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/ConcurrentHashMultiset.java
// we can just do that work here. AtomicInteger newCounter = new AtomicInteger(occurrences); if ((countMap.putIfAbsent(element, newCounter) == null) || countMap.replace(element, existingCounter, newCounter)) { return 0; } break; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 20.9K bytes - Viewed (0) -
src/cmd/internal/telemetry/telemetry_bootstrap.go
func Start() {} func StartWithUpload() {} func Inc(name string) {} func NewCounter(name string) dummyCounter { return dummyCounter{} } func NewStackCounter(name string, depth int) dummyCounter { return dummyCounter{} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 20:16:39 UTC 2024 - 1.1K bytes - Viewed (0) -
src/cmd/internal/telemetry/telemetry.go
TelemetryDir: os.Getenv("TEST_TELEMETRY_DIR"), }) } // Inc increments the counter with the given name. func Inc(name string) { counter.Inc(name) } // NewCounter returns a counter with the given name. func NewCounter(name string) *counter.Counter { return counter.New(name) } // NewStackCounter returns a new stack counter with the given name and depth.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 15:47:30 UTC 2024 - 3.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/counter/file.go
return expire, cleanup } func (f *file) newCounter(name string) *atomic.Uint64 { v, cleanup := f.newCounter1(name) cleanup() return v } func (f *file) newCounter1(name string) (v *atomic.Uint64, cleanup func()) { f.mu.Lock() defer f.mu.Unlock() current := f.current.Load() if current == nil { return nil, nop } debugPrintf("newCounter %s in %s\n", name, current.f.Name())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 18.2K 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)