rutil

Documentation

Index

• func ContinueWorking(ctx context.Context, logger logs.Logger, ...)
• type ContinueWorkerOptionFunc
  • func WithContinueWorkingDefaultRetryInterval(interval time.Duration) ContinueWorkerOptionFunc
• type ContinueWorkingOption
• type WaitDuration
  • func ContinueWorkingWithCustomInterval(d time.Duration) WaitDuration

Functions

func ContinueWorking

func ContinueWorking(ctx context.Context, logger logs.Logger, f func(ctx context.Context) WaitDuration, opFuncs ...ContinueWorkerOptionFunc)

Types

type ContinueWorkerOptionFunc

type ContinueWorkerOptionFunc func(*ContinueWorkingOption)

func WithContinueWorkingDefaultRetryInterval

func WithContinueWorkingDefaultRetryInterval(interval time.Duration) ContinueWorkerOptionFunc

type ContinueWorkingOption

type ContinueWorkingOption struct {
	DefaultRetryInterval time.Duration
}

type WaitDuration

type WaitDuration time.Duration

var (
	ContinueWorkingAbort               WaitDuration = -3 // negative numbers are reserved for loop control.
	ContinueWorkingImmediately         WaitDuration = -2
	ContinueWorkingWithDefaultInterval WaitDuration = -1
)

func ContinueWorkingWithCustomInterval

func ContinueWorkingWithCustomInterval(d time.Duration) WaitDuration