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