package repeater

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/repeater"

Index ¶

• func New( interval time.Duration, task func(ctx context.Context) (err error), opts ...option, ) *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()
}

Source Files ¶

repeater.go