worker

Documentation

Index

• type EngineClient
  • func InitEngine(rds *asynq.RedisClientOpt, config asynq.Config) *EngineClient
  • func (e *EngineClient) Add(task *asynq.Task) error
  • func (e *EngineClient) Register(t Task)
  • func (e *EngineClient) Run()
• type Task

Types

type EngineClient

type EngineClient struct {
	Running bool
	Router  map[string]Task

	Opt    *asynq.RedisClientOpt
	Server *asynq.Server
}

var Engine *EngineClient

func InitEngine

func InitEngine(rds *asynq.RedisClientOpt, config asynq.Config) *EngineClient

func (*EngineClient) Add

func (e *EngineClient) Add(task *asynq.Task) error

func (*EngineClient) Register

func (e *EngineClient) Register(t Task)

func (*EngineClient) Run

func (e *EngineClient) Run()

type Task

type Task interface {
	GetName() string
	ProcessTask(ctx context.Context, task *asynq.Task) error
}