wrapchinery

May 23, 2024

Changes in this version

+ func InitTaskServer() error

+ func InitTestTaskServer() error

+ func NewWorker(concurrency int) *machinery.Worker

+ func RegisterTasks(taskList map[string]interface{}) error

+ func SendTask(ctx context.Context, task *TaskConfig, args ...interface{}) (*result.AsyncResult, error)

+ func SendTaskWaitResult(ctx context.Context, task *TaskConfig, args ...interface{}) error

+ type TaskServer struct

+ func (m *TaskServer) WrapNewWorker(concurrency int) *machinery.Worker

+ func (m *TaskServer) WrapSendTask(cfg *TaskConfig, args ...interface{}) (*result.AsyncResult, error)

+ func (m *TaskServer) WrapSendTaskWithContext(ctx context.Context, cfg *TaskConfig, args ...interface{}) (*result.AsyncResult, error)

May 23, 2024

Changes in this version

+ const ShopIDHeader

type TaskConfig

+ ShopID uint64

Feb 24, 2023

Changes in this version

+ type TaskConfig struct

+ Delay time.Duration

+ Name string

+ OnError *TaskConfig

+ OnSuccess *TaskConfig

+ RetryCount int

Oct 7, 2022

Changes in this version

+ func GetTaskSignature(taskName string, delay time.Duration, retry int, args ...interface{}) *tasks.Signature

+ func SetupLoggers()

+ type Server struct

+ func NewServer(cnf *config.Config, brokerServer brokersiface.Broker, ...) *Server

+ func (m *Server) WrapNewWorker() *machinery.Worker

+ func (m *Server) WrapSendTask(taskName string, delay time.Duration, retry int, args ...interface{}) (*result.AsyncResult, error)

+ func (m *Server) WrapSendTaskWithContext(taskName string, ctx context.Context, delay time.Duration, retry int, ...) (*result.AsyncResult, error)