wait

type AsyncActionCheck ¶

type AsyncActionCheck[T any] func() (waitFinished bool, response *T, err error)

AsyncActionCheck reports whether a specific async action has finished.

• waitFinished == true if the async action is finished, false otherwise.
• response contains data regarding the current state of the resource targeted by the async action, if applicable. If not applicable, T should be struct{}.
• err != nil if there was an error checking if the async action finished, or if it finished unsuccessfully.

type AsyncActionHandler ¶

type AsyncActionHandler[T any] struct {
	IntermediateStateReached bool
	// contains filtered or unexported fields
}

AsyncActionHandler handles waiting for a specific async action to be finished.

func New[T any](f AsyncActionCheck[T]) *AsyncActionHandler[T]

func (h *AsyncActionHandler[T]) SetSleepBeforeWait(d time.Duration) *AsyncActionHandler[T]

func (h *AsyncActionHandler[T]) SetTempErrRetryLimit(l int) *AsyncActionHandler[T]

func (h *AsyncActionHandler[T]) SetThrottle(d time.Duration) *AsyncActionHandler[T]

func (h *AsyncActionHandler[T]) SetTimeout(d time.Duration) *AsyncActionHandler[T]

func (h *AsyncActionHandler[T]) WaitWithContext(ctx context.Context) (res *T, err error)