// initiateThrottlerMetrics initiates the various processes that collect measurements
// that may affect throttling. There are several components, all running independently,
// that collect such metrics.
initiateThrottlerMetrics initiates the various processes that collect measurements
that may affect throttling. There are several components, all running independently,
that collect such metrics.
// initiateThrottlerMetrics initiates the various processes that collect measurements // that may affect throttling . There are several components all running independently // that collect such metrics .
func (this *Throttler) initiateThrottlerCollection(firstThrottlingCollected chan<- bool) {
	go this.collectHeartbeat()
	go this.collectControlReplicasLag()
	go func() {
		throttlerMetricsTick := time.Tick(1 * time.Second)
		this.collectGeneralThrottleMetrics()
		firstThrottlingCollected <- true
		for range throttlerMetricsTick {
			this.collectGeneralThrottleMetrics()
		}
	}()
}
func ( this * Throttler ) initiateThrottlerCollection ( firstThrottlingCollected chan <- bool ) { go this . collectHeartbeat ( ) go this . collectControlReplicasLag ( ) go func ( ) { throttlerMetricsTick := time . Tick ( 1 * time . Second ) this . collectGeneralThrottleMetrics ( ) firstThrottlingCollected <- true for range throttlerMetricsTick { this . collectGeneralThrottleMetrics ( ) } } ( ) }
initiateThrottlerMetrics initiates the various processes that collect measurements
that may affect throttling.
initiateThrottlerMetrics initiates the various processes that collect measurements that may affect throttling .