Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for RecordNodeReady (0.58 sec)

  1. pkg/kubelet/util/node_startup_latency_tracker.go

    	RecordAttemptRegisterNode()
    	// This function should not be called across Kubelet restart.
    	RecordRegisteredNewNode()
    	// This function may be called across Kubelet restart.
    	RecordNodeReady()
    }
    
    type basicNodeStartupLatencyTracker struct {
    	lock sync.Mutex
    
    	bootTime                     time.Time
    	kubeletStartTime             time.Time
    	firstRegistrationAttemptTime time.Time
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 05:54:25 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  2. pkg/kubelet/util/node_startup_latency_tracker_test.go

    		tracker.RecordAttemptRegisterNode()
    
    		fakeClock.Step(200 * time.Millisecond)
    		tracker.RecordRegisteredNewNode()
    
    		fakeClock.Step(300 * time.Millisecond)
    		tracker.RecordNodeReady()
    
    		fakeClock.Step(700 * time.Millisecond)
    		tracker.RecordNodeReady()
    
    		assert.Equal(t, frozenTime.Add(600*time.Millisecond), tracker.firstNodeReadyTime)
    
    		wants := `
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 05:54:25 UTC 2023
    - 18K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_node_status.go

    	readyIdx, readyCondition := nodeutil.GetNodeCondition(&updatedNode.Status, v1.NodeReady)
    	if readyIdx >= 0 && readyCondition.Status == v1.ConditionTrue {
    		kl.nodeStartupLatencyTracker.RecordNodeReady()
    	}
    
    	return updatedNode, nil
    }
    
    // markVolumesFromNode updates volumeManager with VolumesInUse status from node.
    //
    // In the case of node status update being unnecessary, call with the fetched node.
    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