wait

Documentation

Index

• func NewBackoff() aMW.Backoff
• func WaitForWithRetryable(backoff aMW.Backoff, condition aMW.ConditionFunc, retryableErrors []string) error

Functions

func NewBackoff

func NewBackoff() aMW.Backoff

NewBackoff creates a new API Machinery backoff parameter set suitable for use with AWS services, with values based loosely on https://github.com/Netflix/edda/blob/master/src/main/scala/com/netflix/edda/Crawler.scala#L159

func WaitForWithRetryable

func WaitForWithRetryable(backoff aMW.Backoff, condition aMW.ConditionFunc, retryableErrors []string) error

WaitForWithRetryable repeats a condition check with exponential backoff.

It takes a list of string slice of AWS API errors that can be considered as retriable.

It checks the condition up to Steps times.

If Jitter is greater than zero, a random amount of each duration is added (between duration and duration*(1+jitter)).

If it receives a RequestLimitExceeded or Throttling error, then we multiply the delay by the specified factor.

If the condition never returns true, ErrWaitTimeout is returned. All other errors terminate immediately.