cronHandler

Documentation

Index

• func DelayIfStillRunning(ctx context.Context, name string) cron.JobWrapper
• func Recover(ctx context.Context, name string) cron.JobWrapper
• func SkipIfStillRunning(ctx context.Context, name string) cron.JobWrapper
• type Handler
  • func New(this *Handler) *Handler
  • func (h *Handler) Register(ctx context.Context) (*cron.Cron, error)
  • func (h *Handler) Run(ctx context.Context) error

Functions

func DelayIfStillRunning

func DelayIfStillRunning(ctx context.Context, name string) cron.JobWrapper

DelayIfStillRunning serializes jobs, delaying subsequent runs until the previous one is complete. Jobs running after a delay of more than a minute have the delay logged at Info.

func Recover

func Recover(ctx context.Context, name string) cron.JobWrapper

Recover panics in wrapped jobs and log them with the provided logger.

func SkipIfStillRunning

func SkipIfStillRunning(ctx context.Context, name string) cron.JobWrapper

SkipIfStillRunning skips an invocation of the Job if a previous invocation is still running. It logs skips to the given logger at Info level.

Types

type Handler

type Handler struct {
	Cfg        *config.ServiceConfig
	Interactor *cronRouters.CronInteractor
}

func New

func New(this *Handler) *Handler

func (*Handler) Register

func (h *Handler) Register(ctx context.Context) (*cron.Cron, error)

func (*Handler) Run

func (h *Handler) Run(ctx context.Context) error