- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for SinceInSeconds (0.29 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)