queue

Documentation

Index

• type Client
  • func NewClient(redisAddress string) *Client
  • func (c *Client) Add(task *asynq.Task, opts ...asynq.Option) *Client
• type Handler
• type HandlerFunc
• type Queue
  • func CreateServer(redisAddress string, concurrency int, qs Queues) *Queue
  • func (q *Queue) AddHandler(pattern string, handler asynq.Handler) *Queue
  • func (q *Queue) AddHandlerFunc(pattern string, handler func(context.Context, *asynq.Task) error) *Queue
  • func (q *Queue) MountMonitor(redisAddress, redisPw string) (*Queue, *asynqmon.HTTPHandler)
  • func (q *Queue) Run()
• type Queues

Types

type Client

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

Client ...

func NewClient

func NewClient(redisAddress string) *Client

NewClient ...

func (*Client) Add

func (c *Client) Add(task *asynq.Task, opts ...asynq.Option) *Client

Add a new task to queue

type Handler

type Handler struct {
	Pattern string
	FN      asynq.Handler
}

Handler ...

type HandlerFunc

type HandlerFunc struct {
	Pattern string
	FN      func(context.Context, *asynq.Task) error
}

HandlerFunc ...

type Queue

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

Queue holds Asynq server things

func CreateServer

func CreateServer(redisAddress string, concurrency int, qs Queues) *Queue

CreateServer creates a new Asynq server

func (*Queue) AddHandler

func (q *Queue) AddHandler(pattern string, handler asynq.Handler) *Queue

AddHandler adds a handler to mux

func (*Queue) AddHandlerFunc

func (q *Queue) AddHandlerFunc(pattern string, handler func(context.Context, *asynq.Task) error) *Queue

AddHandlerFunc adds a handler func to mux

func (*Queue) MountMonitor

func (q *Queue) MountMonitor(redisAddress, redisPw string) (*Queue, *asynqmon.HTTPHandler)

MountMonitor mounts asynqmon

func (*Queue) Run

func (q *Queue) Run()

type Queues

type Queues map[string]int

Queues represents queues config for Asynq