Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 277 for epmetrics (0.14 sec)

  1. cmd/metrics-realtime.go

    			aggr.Merge(&disk)
    		}
    		m.Aggregated.Disk = &aggr
    	}
    
    	if types.Contains(madmin.MetricsScanner) {
    		metrics := globalScannerMetrics.report()
    		m.Aggregated.Scanner = &metrics
    	}
    	if types.Contains(madmin.MetricsOS) {
    		metrics := globalOSMetrics.report()
    		m.Aggregated.OS = &metrics
    	}
    	if types.Contains(madmin.MetricsBatchJobs) {
    		m.Aggregated.BatchJobs = globalBatchJobsMetrics.report(opts.jobID)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/authorization/authorizerfactory/metrics.go

    package authorizerfactory
    
    import (
    	"context"
    	"sync"
    
    	celmetrics "k8s.io/apiserver/pkg/authorization/cel"
    	webhookmetrics "k8s.io/apiserver/plugin/pkg/authorizer/webhook/metrics"
    	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() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. cmd/metrics-v3-system-memory.go

    // loadMemoryMetrics - `MetricsLoaderFn` for node memory metrics.
    func loadMemoryMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	memMetrics, err := c.memoryMetrics.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    		return err
    	}
    
    	m.Set(memTotal, float64(memMetrics.Total))
    	m.Set(memUsed, float64(memMetrics.Used))
    	usedPerc := float64(memMetrics.Used) * 100 / float64(memMetrics.Total)
    	m.Set(memUsedPerc, usedPerc)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Apr 17 05:10:25 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cache.go

    import (
    	"context"
    	"sync"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/cachevalue"
    )
    
    // metricsCache - cache for metrics.
    //
    // When serving metrics, this cache is passed to the MetricsLoaderFn.
    //
    // This cache is used for metrics that would result in network/storage calls.
    type metricsCache struct {
    	dataUsageInfo       *cachevalue.Cache[DataUsageInfo]
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  5. cmd/metrics-v3-system-cpu.go

    // loadCPUMetrics - `MetricsLoaderFn` for system CPU metrics.
    func loadCPUMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	cpuMetrics, _ := c.cpuMetrics.Get()
    
    	if cpuMetrics.LoadStat != nil {
    		m.Set(sysCPULoad, cpuMetrics.LoadStat.Load1)
    		perc := cpuMetrics.LoadStat.Load1 * 100 / float64(cpuMetrics.CPUCount)
    		m.Set(sysCPULoadPerc, math.Round(perc*100)/100)
    	}
    
    	ts := cpuMetrics.TimesStat
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Apr 23 23:56:12 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. pkg/kubelet/metrics/metrics.go

    			StabilityLevel: metrics.ALPHA,
    		},
    	)
    
    	NodeStartupDuration = metrics.NewGauge(
    		&metrics.GaugeOpts{
    			Subsystem:      KubeletSubsystem,
    			Name:           NodeStartupKey,
    			Help:           "Duration in seconds of node startup in total.",
    			StabilityLevel: metrics.ALPHA,
    		},
    	)
    
    	ImageGarbageCollectedTotal = metrics.NewCounterVec(
    		&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)
  7. staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/metrics/metrics.go

    limitations under the License.
    */
    
    package metrics
    
    import (
    	"context"
    	"sync"
    
    	"k8s.io/apiserver/pkg/authorization/cel"
    	compbasemetrics "k8s.io/component-base/metrics"
    	"k8s.io/component-base/metrics/legacyregistry"
    )
    
    // AuthorizerMetrics specifies a set of methods that are used to register various metrics for the webhook authorizer
    type AuthorizerMetrics interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:01:15 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/options/authenticationconfig/metrics/metrics.go

    limitations under the License.
    */
    
    package metrics
    
    import (
    	"crypto/sha256"
    	"fmt"
    	"sync"
    
    	"k8s.io/component-base/metrics"
    	"k8s.io/component-base/metrics/legacyregistry"
    )
    
    const (
    	namespace = "apiserver"
    	subsystem = "authentication_config_controller"
    )
    
    var (
    	authenticationConfigAutomaticReloadsTotal = metrics.NewCounterVec(
    		&metrics.CounterOpts{
    			Namespace:      namespace,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 22:40:22 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/metrics.go

    	"sync"
    	"time"
    
    	"k8s.io/apiserver/pkg/authentication/authenticator"
    	"k8s.io/component-base/metrics"
    	"k8s.io/component-base/metrics/legacyregistry"
    	"k8s.io/utils/clock"
    )
    
    const (
    	namespace = "apiserver"
    	subsystem = "authentication"
    )
    
    var (
    	jwtAuthenticatorLatencyMetric = metrics.NewHistogramVec(
    		&metrics.HistogramOpts{
    			Namespace:      namespace,
    			Subsystem:      subsystem,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 19:29:33 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    				MetricV2{
    					Description: getMinioProcessIOReadBytesMD(),
    					Value:       float64(io.ReadBytes),
    				})
    		}
    
    		if io.WriteBytes > 0 {
    			metrics = append(metrics,
    				MetricV2{
    					Description: getMinioProcessIOWriteBytesMD(),
    					Value:       float64(io.WriteBytes),
    				})
    		}
    
    		if io.RChar > 0 {
    			metrics = append(metrics,
    				MetricV2{
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 131.9K bytes
    - Viewed (0)
Back to top