Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for SinceInSeconds (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top