queue

Documentation

Index

• Variables
• func CloseClient() error
• func GetClient() (*asynq.Client, error)
• func RegisterJob(name string, config JobConfig)
• func StartQueue() error
• type Executor
• type JobConfig
• type QueueConfig

Variables

var (
	JobMutex     sync.RWMutex
	JobConfigMap = map[string]JobConfig{}
)

Functions

func CloseClient

func CloseClient() error

func GetClient

func GetClient() (*asynq.Client, error)

func RegisterJob

func RegisterJob(name string, config JobConfig)

func StartQueue

func StartQueue() error

Types

type Executor

type Executor interface {
	Execute(ctx context.Context, task *asynq.Task) error
}

type JobConfig

type JobConfig struct {
	Name     string
	Priority int
	Executor Executor
}

type QueueConfig

type QueueConfig struct {
	Enable   bool
	Host     string
	Port     string
	Password string
	DB       int
}

var LightQueueConfig *QueueConfig