Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 115 for newCounter (0.2 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/metrics.go

    limitations under the License.
    */
    
    package aggregated
    
    import (
    	"k8s.io/component-base/metrics"
    	"k8s.io/component-base/metrics/legacyregistry"
    )
    
    var (
    	regenerationCounter = metrics.NewCounter(
    		&metrics.CounterOpts{
    			Name:           "aggregator_discovery_aggregation_count_total",
    			Help:           "Counter of number of times discovery was aggregated",
    			StabilityLevel: metrics.ALPHA,
    		},
    	)
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 09 17:24:02 UTC 2023
    - 1009 bytes
    - Viewed (0)
  2. 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)
  3. staging/src/k8s.io/apiserver/pkg/storage/value/metrics.go

    			StabilityLevel: metrics.ALPHA,
    		},
    		[]string{"transformation_type", "transformer_prefix", "status"},
    	)
    
    	envelopeTransformationCacheMissTotal = metrics.NewCounter(
    		&metrics.CounterOpts{
    			Namespace:      namespace,
    			Subsystem:      subsystem,
    			Name:           "envelope_transformation_cache_misses_total",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 22:44:02 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/audit/metrics.go

     * involves explicitly acknowledging support for the metric across multiple releases, in accordance with
     * the metric stability policy.
     */
    var (
    	eventCounter = metrics.NewCounter(
    		&metrics.CounterOpts{
    			Subsystem:      subsystem,
    			Name:           "event_total",
    			Help:           "Counter of audit events generated and sent to the audit backend.",
    			StabilityLevel: metrics.ALPHA,
    		})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 13 00:46:24 UTC 2021
    - 3.6K bytes
    - Viewed (0)
  5. 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)
  6. pkg/controller/garbagecollector/metrics/metrics.go

    	"k8s.io/component-base/metrics"
    	"k8s.io/component-base/metrics/legacyregistry"
    )
    
    const GarbageCollectorControllerSubsystem = "garbagecollector_controller"
    
    var (
    	GarbageCollectorResourcesSyncError = metrics.NewCounter(
    		&metrics.CounterOpts{
    			Subsystem:      GarbageCollectorControllerSubsystem,
    			Name:           "resources_sync_error_total",
    			Help:           "Number of garbage collector resources sync errors",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 04 19:21:30 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  7. pkg/registry/core/service/portallocator/controller/metrics.go

    		},
    		[]string{"type"},
    	)
    	// nodePortRepairReconcileErrors indicates the number of times the repair loop has failed to repair
    	// the errors it detected.
    	nodePortRepairReconcileErrors = metrics.NewCounter(
    		&metrics.CounterOpts{
    			Namespace:      namespace,
    			Subsystem:      subsystem,
    			Name:           "reconcile_errors_total",
    			Help:           "Number of reconciliation failures on the nodeport repair reconcile loop",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/util/x509metrics/server_cert_deprecations_test.go

    			counterIncrease: true,
    		},
    		{
    			name:       "with SAN",
    			serverCert: serverCert,
    		},
    	}
    
    	// register the test metrics
    	x509MissingSANCounter := metrics.NewCounter(&metrics.CounterOpts{Name: "Test_checkForHostnameError"})
    	registry := testutil.NewFakeKubeRegistry("0.0.0")
    	registry.MustRegister(x509MissingSANCounter)
    	sanChecker := NewSANDeprecatedChecker(x509MissingSANCounter)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 25.5K bytes
    - Viewed (0)
  9. pkg/controller/tainteviction/metrics/metrics.go

    )
    
    const taintEvictionControllerSubsystem = "taint_eviction_controller"
    
    var (
    	// PodDeletionsTotal counts the number of Pods deleted by TaintEvictionController since its start.
    	PodDeletionsTotal = metrics.NewCounter(
    		&metrics.CounterOpts{
    			Subsystem:      taintEvictionControllerSubsystem,
    			Name:           "pod_deletions_total",
    			Help:           "Total number of Pods deleted by TaintEvictionController since its start.",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:23:56 UTC 2023
    - 2K bytes
    - Viewed (0)
  10. 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)
Back to top