cron

Documentation

Index

• func Done() <-chan struct{}
• func ScheduleTask(task Task)
• func ScheduleTaskNonBlock(task Task)
• type Event
  • func NewEvent(ctx context.Context) (*Event, error)
• type Task

Functions

func Done

func Done() <-chan struct{}

Done returns a channel which is closed when the task is done. Currently, this channel is never closed to support cloudflare.WaitUntil feature.

func ScheduleTask

func ScheduleTask(task Task)

ScheduleTask sets the Task to be executed

func ScheduleTaskNonBlock

func ScheduleTaskNonBlock(task Task)

ScheduleTaskNonBlock sets the Task to be executed but does not signal readiness or block indefinitely. The non-blocking form is meant to be used in conjunction with workers.Serve.

Types

type Event

type Event struct {
	Cron          string
	ScheduledTime time.Time
}

Event represents information about the Cron that invoked this worker.

func NewEvent

func NewEvent(ctx context.Context) (*Event, error)

type Task

type Task func(ctx context.Context) error