Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SinceInSeconds (0.42 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/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)
  4. 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)
  5. 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)
  6. 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