repeater

Documentation

Index

• func New(interval time.Duration, task func(ctx context.Context) (err error), ...) *repeater
• func WithClock(clock clockwork.Clock) option
• func WithInterval(interval time.Duration) option
• func WithName(name string) option
• func WithTrace(trace *trace.Driver) option
• type Repeater

Functions

func New

func New(
	interval time.Duration,
	task func(ctx context.Context) (err error),
	opts ...option,
) *repeater

New creates and begins to execute task periodically.

func WithClock

func WithClock(clock clockwork.Clock) option

func WithInterval

func WithInterval(interval time.Duration) option

func WithName

func WithName(name string) option

func WithTrace

func WithTrace(trace *trace.Driver) option

Types

type Repeater

type Repeater interface {
	Stop()
	Force()
}