queue

Documentation

Index

• func Dashboard(redisURL string) *asynqmon.HTTPHandler
• func Init(redisURL string, concurrency int)
• type Instance
  • func GetInstance() Instance
  • func (i Instance) RemoveScheduler(id string) error
  • func (i Instance) RunTask(queue string, payload []byte, retryTimes int) (*asynq.TaskInfo, error)
  • func (i Instance) ScheduleTask(typename string, payload []byte, cronSpec string, retryTimes int) (string, error)

Functions

func Dashboard

func Dashboard(redisURL string) *asynqmon.HTTPHandler

func Init

func Init(redisURL string, concurrency int)

Types

type Instance

type Instance struct {
	Client    *asynq.Client
	Server    *asynq.ServeMux
	Scheduler *asynq.Scheduler
	Inspector *asynq.Inspector
}

Instance ...

func GetInstance

func GetInstance() Instance

GetInstance ...

func (Instance) RemoveScheduler

func (i Instance) RemoveScheduler(id string) error

func (Instance) RunTask

func (i Instance) RunTask(queue string, payload []byte, retryTimes int) (*asynq.TaskInfo, error)

RunTask ...

func (Instance) ScheduleTask

func (i Instance) ScheduleTask(typename string, payload []byte, cronSpec string, retryTimes int) (string, error)

ScheduleTask create new task and run at specific time cronSpec follow cron expression https://www.freeformatter.com/cron-expression-generator-quartz.html