server

Documentation

Index

• Variables
• type Params
• type Result
  • func New(p Params) Result

Variables

var ErrJobExceededDeadline = errors.New("the job did not complete before its deadline")

Types

type Params

type Params struct {
	fx.In
	Query    lazy.Lazy[*dao.Query]
	PgxPool  lazy.Lazy[*pgxpool.Pool]
	Handlers []lazy.Lazy[handler.Handler] `group:"queue_handlers"`
	Logger   *zap.SugaredLogger
}

type Result

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

func New

func New(p Params) Result