handle

Documentation

Index

• type Handler
  • func NewHandler(db *pgxpool.Pool, src *source.Store, lg *slog.Logger, jbt time.Duration, ...) *Handler
  • func (h *Handler) Handle() error

Types

type Handler

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

Handler contains all it needs to handle jobs.

func NewHandler

func NewHandler(db *pgxpool.Pool, src *source.Store, lg *slog.Logger, jbt time.Duration, lt heavy.Lifter, msg message.Messenger) *Handler

NewHandler returns a new *Handler.

func (*Handler) Handle

func (h *Handler) Handle() error

Handle is the main process for handling all jobs.