consumer

Documentation

Index

• type Consumer
  • func New[T interface{}](pattern string, handler Handler[T]) Consumer
• type Handler
• type HandlerFunc
  • func (f HandlerFunc[T]) Handle(ctx context.Context, payload T) error
• type Unmarshaler
  • func NewJsonUnmarshaler[T interface{}]() Unmarshaler[T]

Types

type Consumer

type Consumer interface {
	Pattern() string
	ProcessTask(ctx context.Context, t *asynq.Task) error
}

func New

func New[T interface{}](pattern string, handler Handler[T]) Consumer

type Handler

type Handler[T interface{}] interface {
	Handle(ctx context.Context, payload T) error
}

type HandlerFunc

type HandlerFunc[T interface{}] func(ctx context.Context, payload T) error

func (HandlerFunc[T]) Handle

func (f HandlerFunc[T]) Handle(ctx context.Context, payload T) error

type Unmarshaler

type Unmarshaler[T interface{}] interface {
	Unmarshal(t *asynq.Task) (T, error)
}

func NewJsonUnmarshaler

func NewJsonUnmarshaler[T interface{}]() Unmarshaler[T]