- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for RecordNodeReady (0.58 sec)
-
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) -
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) -
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)