Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for SinceInSeconds (0.29 sec)

  1. pkg/kubelet/server/metrics/metrics.go

    		legacyregistry.MustRegister(HTTPRequestsDuration)
    		legacyregistry.MustRegister(HTTPInflightRequests)
    		legacyregistry.MustRegister(VolumeStatCalDuration)
    	})
    }
    
    // SinceInSeconds gets the time since the specified start in seconds.
    func SinceInSeconds(start time.Time) float64 {
    	return time.Since(start).Seconds()
    }
    
    // CollectVolumeStatCalDuration collects the duration in seconds to calculate volume stats.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 19 14:33:37 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/value/metrics.go

    	if err != nil {
    		dataKeyGenerationFailuresTotal.Inc()
    		return
    	}
    
    	dataKeyGenerationLatencies.Observe(sinceInSeconds(start))
    }
    
    // sinceInSeconds gets the time since the specified start in seconds.
    func sinceInSeconds(start time.Time) float64 {
    	return time.Since(start).Seconds()
    }
    
    type gRPCError interface {
    	GRPCStatus() *status.Status
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 22:44:02 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/framework.go

    	skipPlugins := sets.New[string]()
    	defer func() {
    		state.SkipFilterPlugins = skipPlugins
    		metrics.FrameworkExtensionPointDuration.WithLabelValues(metrics.PreFilter, status.Code().String(), f.profileName).Observe(metrics.SinceInSeconds(startTime))
    	}()
    	var result *framework.PreFilterResult
    	var pluginsWithNodes []string
    	logger := klog.FromContext(ctx)
    	verboseLogs := logger.V(4).Enabled()
    	if verboseLogs {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics.go

    }
    
    // Reset resets the etcd_request_duration_seconds metric.
    func Reset() {
    	etcdRequestLatency.Reset()
    }
    
    // sinceInSeconds gets the time since the specified start in seconds.
    //
    // This is a variable to facilitate testing.
    var sinceInSeconds = func(start time.Time) float64 {
    	return time.Since(start).Seconds()
    }
    
    // UpdateEtcdDbSize sets the etcd_db_total_size_in_bytes metric.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 21:15:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. pkg/queue/metrics.go

    	latency      monitoring.Metric
    	workDuration monitoring.Metric
    	id           string
    	clock        clock.WithTicker
    }
    
    // Gets the time since the specified start in seconds.
    func (m *queueMetrics) sinceInSeconds(start time.Time) float64 {
    	return m.clock.Since(start).Seconds()
    }
    
    func newQueueMetrics(id string) *queueMetrics {
    	return &queueMetrics{
    		id:           id,
    		depth:        depth.With(queueIDTag.Value(id)),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jul 21 16:30:36 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/runtime/util_windows_test.go

    import (
    	"testing"
    )
    
    func checkLatency(t *testing.T, value float64) {
    	// On Windows, time.Now() is not as precise, 2 consecutive calls may return the same timestamp,
    	// thus, the latency metric may be 0 (SinceInSeconds will return 0).
    	// See: https://github.com/golang/go/issues/8687
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Nov 29 16:32:26 UTC 2022
    - 917 bytes
    - Viewed (0)
  7. pkg/queue/metrics_test.go

    	for n := 0; n < b.N; n++ {
    		q.depth.Record(100)
    	}
    }
    
    func BenchmarkMetricsQueueSinceInSeconds(b *testing.B) {
    	q := newQueueMetrics("test")
    	dt := time.Now()
    	for n := 0; n < b.N; n++ {
    		q.sinceInSeconds(dt)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jul 21 16:30:36 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  8. pkg/kubelet/kuberuntime/instrumented_services.go

    func recordOperation(operation string, start time.Time) {
    	metrics.RuntimeOperations.WithLabelValues(operation).Inc()
    	metrics.RuntimeOperationsDuration.WithLabelValues(operation).Observe(metrics.SinceInSeconds(start))
    }
    
    // recordError records error for metric if an error occurred.
    func recordError(operation string, err error) {
    	if err != nil {
    		metrics.RuntimeOperationsErrors.WithLabelValues(operation).Inc()
    	}
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 10:46:06 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  9. pkg/scheduler/schedule_one.go

    	metrics.PodScheduled(fwk.ProfileName(), metrics.SinceInSeconds(start))
    	metrics.PodSchedulingAttempts.Observe(float64(assumedPodInfo.Attempts))
    	if assumedPodInfo.InitialAttemptTimestamp != nil {
    		metrics.PodSchedulingDuration.WithLabelValues(getAttemptsLabel(assumedPodInfo)).Observe(metrics.SinceInSeconds(*assumedPodInfo.InitialAttemptTimestamp))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  10. pkg/proxy/metrics/metrics.go

    		case kubeproxyconfig.ProxyModeKernelspace:
    			// currently no winkernel-specific metrics
    		}
    	})
    }
    
    // SinceInSeconds gets the time since the specified start in seconds.
    func SinceInSeconds(start time.Time) float64 {
    	return time.Since(start).Seconds()
    }
    
    var _ metrics.StableCollector = &nfacctMetricCollector{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.7K bytes
    - Viewed (0)
Back to top