scheduler

Documentation

Index

• func Healthcheck(ctx context.Context) error
• func NewService(log *zap.Logger, d dispatcher, interval time.Duration) *service
• func OnInterval(ii ...string) bool
• func OnTimestamp(tt ...string) bool
• func Service() *service
• func Setup(log *zap.Logger, d dispatcher, interval time.Duration)

Functions

func Healthcheck

func Healthcheck(ctx context.Context) error

Healtcheck for (global) scheduler

func NewService

func NewService(log *zap.Logger, d dispatcher, interval time.Duration) *service

func OnInterval

func OnInterval(ii ...string) bool

OnInterval parses all given strings as crontab expressions (ii) and returns true if any of them matches current time

func OnTimestamp

func OnTimestamp(tt ...string) bool

OnTimestamp parses all given strings as RFC3339 timestamps and returns true if any of them matches current time

func Service

func Service() *service

func Setup

func Setup(log *zap.Logger, d dispatcher, interval time.Duration)

Setup configures global scheduling service