asyncQueue

Documentation

Index

• func New(address string, password string) *asyncQueue
• type AsyncQueue

Functions

func New

func New(address string, password string) *asyncQueue

Types

type AsyncQueue

type AsyncQueue interface {
	DistributeTask(taskName string, value []byte) error
	ProcessTask(taskName string, handler asynq.HandlerFunc) error
	Close() error
}