- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for SinceInSeconds (0.15 sec)
-
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/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) -
pkg/scheduler/metrics/metrics.go
// GatedPods returns the pending pods metrics with the label gated func GatedPods() metrics.GaugeMetric { return pendingPods.With(metrics.Labels{"queue": "gated"}) } // SinceInSeconds gets the time since the specified start in seconds. func SinceInSeconds(start time.Time) float64 { return time.Since(start).Seconds() } func UnschedulableReason(plugin string, profile string) metrics.GaugeMetric {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 08:22:53 UTC 2024 - 11.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/metrics/metrics_test.go
t.Fatal(err) } }) } } func TestRecordEtcdRequest(t *testing.T) { registry := metrics.NewKubeRegistry() // modify default sinceInSeconds to constant NOW sinceInSeconds = func(t time.Time) float64 { return time.Unix(0, 300*int64(time.Millisecond)).Sub(t).Seconds() } testedMetrics := []metrics.Registerable{ etcdRequestCounts, etcdRequestErrorCounts,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 21:15:32 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
if lastRelistTime := g.getRelistTime(); !lastRelistTime.IsZero() { metrics.PLEGRelistInterval.Observe(metrics.SinceInSeconds(lastRelistTime)) } timestamp := g.clock.Now() defer func() { metrics.PLEGRelistDuration.Observe(metrics.SinceInSeconds(timestamp)) }() // Get all the pods. podList, err := g.runtime.GetPods(ctx, true) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
// Keep track of how long syncs take. start := time.Now() defer func() { metrics.SyncProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) if tryPartialSync { metrics.SyncPartialProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) } else { metrics.SyncFullProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) } proxier.logger.V(2).Info("SyncProxyRules complete", "elapsed", time.Since(start)) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
// Below this point we will not return until we try to write the nftables rules. // // Keep track of how long syncs take. start := time.Now() defer func() { metrics.SyncProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) proxier.logger.V(2).Info("SyncProxyRules complete", "elapsed", time.Since(start)) }() serviceUpdateResult := proxier.svcPortMap.Update(proxier.serviceChanges)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
// and the mutex is held. defer func() { proxier.initialSync = false }() // Keep track of how long syncs take. start := time.Now() defer func() { metrics.SyncProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) proxier.logger.V(4).Info("syncProxyRules complete", "elapsed", time.Since(start)) }() // We assume that if this was called, we really want to sync them,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0)