persister/whisper.go
func (p *Whisper) Start() error {
	return p.StartFunc(func() error {

		p.throttleTicker = NewThrottleTicker(p.maxUpdatesPerSecond)
		if p.hardMaxCreatesPerSecond {
			p.maxCreatesTicker = NewHardThrottleTicker(p.maxCreatesPerSecond)
		} else {
			p.maxCreatesTicker = NewThrottleTicker(p.maxCreatesPerSecond)
		}

		for i := 0; i < p.workersCount; i++ {
			p.Go(p.worker)
		}

		return nil
	})
}
func (p *Whisper) Start() error {
	return p.StartFunc(func() error {

		p.throttleTicker = NewThrottleTicker(p.maxUpdatesPerSecond)
		if p.hardMaxCreatesPerSecond {
			p.maxCreatesTicker = NewHardThrottleTicker(p.maxCreatesPerSecond)
		} else {
			p.maxCreatesTicker = NewThrottleTicker(p.maxCreatesPerSecond)
		}

		for i := 0; i < p.workersCount; i++ {
			p.Go(p.worker)
		}

		return nil
	})
}
func ( p * Whisper ) Start ( ) error { return p . StartFunc ( func ( ) error { p . throttleTicker = NewThrottleTicker ( p . maxUpdatesPerSecond ) if p . hardMaxCreatesPerSecond { p . maxCreatesTicker = NewHardThrottleTicker ( p . maxCreatesPerSecond ) } else { p . maxCreatesTicker = NewThrottleTicker ( p . maxCreatesPerSecond ) } for i := 0 ; i < p . workersCount ; i ++ { p . Go ( p . worker ) } return nil } ) }
// Start worker
Start worker