Repeater calls a function until it returns no error, up to some number of iterations and delays defined by strategy. It terminates immediately on err from the provided (optional) list of critical errors.
Install and update¶
go get -u github.com/go-pkgz/repeater
How to use¶
New Repeater created by
New(strtg strategy.Interface) or shortcut for default -
NewDefault(repeats int, delay time.Duration) *Repeater.
To activate invoke
Do repeats func until no error returned. Predefined (optional) errors terminate the loop immediately.
func (r Repeater) Do(ctx context.Context, fun func() error, errors ...error) (err error)
User can provide his own strategy implementing the interface:
Returned channels used as “ticks,” i.e., for each repeat or initial operation one read from this channel needed. Closing the channel indicates “done with retries.” It is pretty much the same idea as
time.Tick implements. Note - the first (technically not-repeated-yet) call won’t happen until something sent to the channel. For this reason, the typical strategy sends the first “tick” before the first wait/sleep.
Three strategies provided byt the package:
- Fixed delay, up to max number of attempts. It is the default strategy used by
- BackOff with jitter provides an exponential backoff. It starts from
Durationinterval and goes in steps with
last * math.Pow(factor, attempt). Optional jitter randomizes intervals a little. Factor = 1 effectively makes this strategy fixed with
- Once strategy does not do any repeats and mainly used for tests/mocks`.