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     lazy.Lazy[*redis.Client]
	Consumers []lazy.Lazy[consumer.Consumer] `group:"queue_consumers"`
	Options   []Option                       `group:"queue_server_options"`
	Logger    *zap.SugaredLogger
}

type Result

type Result struct {
	fx.Out
	Worker worker.Worker `group:"workers"`
}

func New

func New(p Params) (Result, error)