Documentation ¶
Index ¶
- func Dispatch(name string, args ...any) error
- func DispatchSync(name string, args ...any) error
- func Job[T queue.Argument | any](job queue.IJob, args ...T) queue.IProducer
- func JobByName[T queue.Argument | any](name string, args ...T) queue.IProducer
- func Register(jobs ...queue.IJob) queue.IJobMap
- func RegisterWithName(name string, jobFunc queue.JobFunc) queue.IJobMap
- func Registers(jobMap map[string]queue.JobFunc) queue.IJobMap
- func RunServe(connectionName string, queueName string, concurrentCount int) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DispatchSync ¶
DispatchSync invoke a job synchronous
func RegisterWithName ¶
RegisterWithName job-func map
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.