backoff

Documentation

Index

• func BurstNotifier(burst int, minWait, maxWait time.Duration, until <-chan struct{}) <-chan struct{}
• func Notifier(minWait, maxWait time.Duration, until <-chan struct{}) <-chan struct{}

Functions

func BurstNotifier

func BurstNotifier(burst int, minWait, maxWait time.Duration, until <-chan struct{}) <-chan struct{}

func Notifier

func Notifier(minWait, maxWait time.Duration, until <-chan struct{}) <-chan struct{}

Notifier returns a chan that yields a struct{}{} every so often. the wait period between structs is between minWait and maxWait. greedy consumers that continuously read from the returned chan will see the wait period generally increase.

Note: this func panics if minWait is a non-positive value to avoid busy-looping.