cronx

func AddCronTask ¶ added in v0.0.43

func AddCronTask(spec string, f func(ctx context.Context), timeout ...time.Duration)

func AddDelayTask ¶ added in v0.0.47

func AddDelayTask(delay time.Duration, f func(ctx context.Context), timeout ...time.Duration)

AddDelayTask adds a task that runs after a specified delay.

func AddEveryTask ¶ added in v0.0.47

func AddEveryTask(interval time.Duration, f func(ctx context.Context), timeout ...time.Duration)

AddEveryTask is a convenience function to add a task that runs at a regular interval.

func AddOnceTask ¶ added in v0.0.47

func AddOnceTask(runAt time.Time, f func(ctx context.Context), timeout ...time.Duration)

AddOnceTask adds a task that runs only once at the specified time.

func Shutdown ¶

func Shutdown(code string, ctx context.Context) error

func Startup ¶

func Startup(code, port string) error

func WrapCronTask ¶ added in v0.0.43

func WrapCronTask(f func(ctx context.Context), doneCallback func(), timeout ...time.Duration) func()