Versions in this module Expand all Collapse all v1 v1.0.1 Nov 17, 2024 v1.0.0 Oct 29, 2024 Changes in this version + var Scheduler = initialize.Scheduler + 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()
Go to main page