Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for RecordAttemptRegisterNode (0.34 sec)

  1. pkg/kubelet/util/node_startup_latency_tracker_test.go

    			kubeletStartTime: frozenTime,
    			clock:            fakeClock,
    		}
    
    		fakeClock.Step(600 * time.Millisecond)
    		tracker.RecordAttemptRegisterNode()
    
    		fakeClock.Step(300 * time.Millisecond)
    		tracker.RecordAttemptRegisterNode()
    
    		assert.Equal(t, frozenTime.Add(600*time.Millisecond), tracker.firstRegistrationAttemptTime)
    		assert.True(t, tracker.firstRegisteredNewNodeTime.IsZero())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 05:54:25 UTC 2023
    - 18K bytes
    - Viewed (0)
  2. pkg/kubelet/util/node_startup_latency_tracker.go

    import (
    	"sync"
    	"time"
    
    	"k8s.io/kubernetes/pkg/kubelet/metrics"
    	"k8s.io/utils/clock"
    )
    
    type NodeStartupLatencyTracker interface {
    	// This function may be called across Kubelet restart.
    	RecordAttemptRegisterNode()
    	// This function should not be called across Kubelet restart.
    	RecordRegisteredNewNode()
    	// This function may be called across Kubelet restart.
    	RecordNodeReady()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 05:54:25 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_node_status.go

    // not locked).
    func (kl *Kubelet) registerWithAPIServer() {
    	if kl.registrationCompleted {
    		return
    	}
    
    	kl.nodeStartupLatencyTracker.RecordAttemptRegisterNode()
    
    	step := 100 * time.Millisecond
    
    	for {
    		time.Sleep(step)
    		step = step * 2
    		if step >= 7*time.Second {
    			step = 7 * time.Second
    		}
    
    		node, err := kl.initialNode(context.TODO())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
Back to top