cron

Documentation

Index

• Variables
• func MakeJobFunc(f func() error) func()
• func MakeOnceJob(key lock.Key, f func() error) func()
• func PublishTask(task nats.Task) func()
• func PublishTaskWithMakePayload[T nats.PayloadType](task nats.Task, makePayload func() (T, error)) func()
• func PublishTaskWithPayload[T nats.PayloadType](task nats.Task, payload T) func()

Variables

var (
	Scheduler = initialize.Scheduler
)

Functions

func MakeJobFunc

func MakeJobFunc(f func() error) func()

func MakeOnceJob

func MakeOnceJob(key lock.Key, f func() error) func()

func PublishTask

func PublishTask(task nats.Task) func()

func PublishTaskWithMakePayload

func PublishTaskWithMakePayload[T nats.PayloadType](task nats.Task, makePayload func() (T, error)) func()

func PublishTaskWithPayload

func PublishTaskWithPayload[T nats.PayloadType](task nats.Task, payload T) func()