Versions in this module Expand all Collapse all v1 v1.0.0 Nov 7, 2021 Changes in this version + type QueueDI interface + NewServ func() (QueueServ, error) + type QueueServ interface + RegisterTasks func(workers ...Worker) error + SendTask func(taskName string, args []tasks.Arg) (*tasks.TaskState, error) + StartWorker func() error + type RabbitMQConf struct + func (conf *RabbitMQConf) NewServ() (QueueServ, error) + type Worker interface + Enable func() bool + Register func(tasks map[string]interface{})
Go to main page