server

Documentation

Index

• func NewFromZap(l *zap.SugaredLogger) asynq.Logger
• type Option
• type Params
• type Result
  • func New(p Params) (Result, error)

Functions

func NewFromZap

func NewFromZap(l *zap.SugaredLogger) asynq.Logger

Types

type Option

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

type Params

type Params struct {
	fx.In
	Config    queue.Config
	Redis     *redis.Client
	Consumers []consumer.Consumer `group:"queue_consumers"`
	Options   []Option            `group:"queue_server_options"`
	Logger    *zap.SugaredLogger
}

type Result

type Result struct {
	fx.Out
	Server   *asynq.Server
	ServeMux *asynq.ServeMux
	Worker   worker.Worker `group:"workers"`
}

func New

func New(p Params) (Result, error)