Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for SinceInSeconds (0.34 sec)

  1. 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)
  2. 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)
  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/kubelet/server/server.go

    	startTime := time.Now()
    	defer servermetrics.HTTPRequestsDuration.WithLabelValues(method, path, serverType, longRunning).Observe(servermetrics.SinceInSeconds(startTime))
    
    	handler.ServeHTTP(w, req)
    }
    
    // prometheusHostAdapter adapts the HostInterface to the interface expected by the
    // cAdvisor prometheus collector.
    type prometheusHostAdapter struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
  5. 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)
  6. pkg/kubelet/kubelet.go

    		if !firstSeenTime.IsZero() {
    			// This is the first time we are syncing the pod. Record the latency
    			// since kubelet first saw the pod if firstSeenTime is set.
    			metrics.PodWorkerStartDuration.Observe(metrics.SinceInSeconds(firstSeenTime))
    		} else {
    			klog.V(3).InfoS("First seen time not recorded for pod",
    				"podUID", pod.UID,
    				"pod", klog.KObj(pod))
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top