- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for SinceInSeconds (0.25 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) -
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/kubelet/pod_workers.go
p.cleanupUnstartedPod(update.Options.Pod, status) status.working = false if start := update.Options.StartTime; !start.IsZero() { metrics.PodWorkerDuration.WithLabelValues("terminated").Observe(metrics.SinceInSeconds(start)) } klog.V(4).InfoS("Pod cannot start ever", "pod", klog.KObj(update.Options.Pod), "podUID", podUID, "updateType", update.WorkType) return ctx, update, canStart, canEverStart, true case !canStart:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K 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) -
pkg/proxy/winkernel/proxier.go
return } // Keep track of how long syncs take. start := time.Now() defer func() { metrics.SyncProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) klog.V(4).InfoS("Syncing proxy rules complete", "elapsed", time.Since(start)) }() hnsNetworkName := proxier.network.name hns := proxier.hns var gatewayHnsendpoint *endpointInfo
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
var s *framework.Status pod := pInfo.Pod startTime := p.clock.Now() defer func() { metrics.FrameworkExtensionPointDuration.WithLabelValues(preEnqueue, s.Code().String(), pod.Spec.SchedulerName).Observe(metrics.SinceInSeconds(startTime)) }() shouldRecordMetric := rand.Intn(100) < p.pluginMetricsSamplePercent for _, pl := range p.preEnqueuePluginMap[pod.Spec.SchedulerName] { s = p.runPreEnqueuePlugin(ctx, pl, pod, shouldRecordMetric)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)