- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for StartOnce (0.2 sec)
-
pkg/kubelet/server/stats/fs_resource_analyzer.go
} // fsResourceAnalyzer provides stats about fs resource usage type fsResourceAnalyzer struct { statsProvider Provider calcPeriod time.Duration cachedVolumeStats atomic.Value startOnce sync.Once eventRecorder record.EventRecorder } var _ fsResourceAnalyzerInterface = &fsResourceAnalyzer{} // newFsResourceAnalyzer returns a new fsResourceAnalyzer implementation
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 09 16:16:37 UTC 2021 - 3.3K bytes - Viewed (0) -
pkg/kubelet/server/stats/volume_stat_calculator.go
jitterPeriod: jitterPeriod, pod: pod, stopChannel: make(chan struct{}), eventRecorder: eventRecorder, } } // StartOnce starts pod volume calc that will occur periodically in the background until s.StopOnce is called func (s *volumeStatCalculator) StartOnce() *volumeStatCalculator { s.startO.Do(func() { go wait.JitterUntil(func() { s.calcAndStoreStats() }, s.jitterPeriod, 1.0, true, s.stopChannel)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 29 00:55:10 UTC 2022 - 7.1K bytes - Viewed (0) -
internal/event/targetlist.go
list.sendSync(av.ev, av.targetSet) case <-list.ctx.Done(): return } } }() } wk.Wait() } var startOnce sync.Once // Init initialize target send workers. func (list *TargetList) Init(workers int) *TargetList { startOnce.Do(func() { go list.startSendWorkers(workers) }) return list } // NewTargetList - creates TargetList.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0)