Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 69 for newCounter (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top