queue

Documentation

Index

• type Client
  • func (q *Client) Enqueue(taskType string, payload []byte, opts ...asynq.Option) (*asynq.TaskInfo, error)
  • func (q *Client) RegisterHandler(taskType string, handler asynq.Handler) error
• type Queue
  • func New(opt redis.Options) *Queue
  • func (q *Queue) Client() *Client
  • func (q *Queue) Run()

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client queue client.

func (*Client) Enqueue

func (q *Client) Enqueue(taskType string, payload []byte, opts ...asynq.Option) (*asynq.TaskInfo, error)

Enqueue enqueues the given task and payload to a queue.

func (*Client) RegisterHandler

func (q *Client) RegisterHandler(taskType string, handler asynq.Handler) error

RegisterHandler register handler for the task type.

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

Queue is Queue instance.

func New

func New(opt redis.Options) *Queue

New returns a Queue instance.

func (*Queue) Client

func (q *Queue) Client() *Client

Client returns the queue client.

func (*Queue) Run

func (q *Queue) Run()

Run tasks with handlers. Special attention, please run after registration is completed.