Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for SinceInSeconds (0.22 sec)

  1. 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)
  2. 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)
  3. pkg/kubelet/cm/devicemanager/manager.go

    		klog.V(3).InfoS("Making allocation request for device plugin", "devices", devs, "resourceName", resource)
    		resp, err := eI.e.allocate(devs)
    		metrics.DevicePluginAllocationDuration.WithLabelValues(resource).Observe(metrics.SinceInSeconds(startRPCTime))
    		if err != nil {
    			// In case of allocation failure, we want to restore m.allocatedDevices
    			// to the actual allocated state from m.podDevices.
    			m.mutex.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
  4. 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)
  5. 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