loop

Feb 27, 2024

Changes in this version

+ type Loop struct

+ func NewLoop() *Loop

+ func (l *Loop) Do(tf TaskFunc, opts ...TaskOptions)

+ func (l *Loop) DoAndWait(tf TaskFunc, opts ...TaskOptions) (interface{}, error)

+ func (l *Loop) Repeat(tf TaskFunc, opts ...TaskOptions)

+ func (l *Loop) Run(ctx context.Context) (context.Context, context.CancelFunc)

+ type RepeatIntervalFunc func(result interface{}, err error) time.Duration

+ type TaskFunc func(ctx context.Context, l *Loop) (ret interface{}, err error)

+ type TaskOption struct

+ RepeatIntervalFunc RepeatIntervalFunc

+ type TaskOptions func(opt *TaskOption)

+ func ExponentialRepeatIntervalOnError(init time.Duration, factor float64) TaskOptions

+ func FixedRepeatInterval(interval time.Duration) TaskOptions