registry

Documentation

Index

• type Handler
  • func NewHandler(fn HandlerFunc, payloadType interface{}, opts ...HandlerOption) *Handler
  • func (h *Handler) Execute(payload json.RawMessage) error
  • func (h *Handler) MaxRetries() int
• type HandlerFunc
• type HandlerOption
  • func WithMaxRetries(retries int) HandlerOption
  • func WithMiddleware(middleware ...MiddlewareFunc) HandlerOption
  • func WithTimeout(timeout time.Duration) HandlerOption
• type MiddlewareFunc
• type Registry
  • func New() *Registry
  • func (r *Registry) Execute(topic string, payload json.RawMessage) error
  • func (r *Registry) Get(topic string) (*Handler, bool)
  • func (r *Registry) Has(topic string) bool
  • func (r *Registry) Register(topic string, fn HandlerFunc, payloadType interface{}) error
  • func (r *Registry) Remove(topic string)
  • func (r *Registry) Topics() []string

Types

type Handler

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

func NewHandler

func NewHandler(fn HandlerFunc, payloadType interface{}, opts ...HandlerOption) *Handler

func (*Handler) Execute

func (h *Handler) Execute(payload json.RawMessage) error

func (*Handler) MaxRetries

func (h *Handler) MaxRetries() int

type HandlerFunc

type HandlerFunc func(payload interface{}) error

HandlerFunc is the function signature for task handlers

type HandlerOption

type HandlerOption func(*Handler)

func WithMaxRetries

func WithMaxRetries(retries int) HandlerOption

func WithMiddleware

func WithMiddleware(middleware ...MiddlewareFunc) HandlerOption

func WithTimeout

func WithTimeout(timeout time.Duration) HandlerOption

type MiddlewareFunc

type MiddlewareFunc func(next HandlerFunc) HandlerFunc

type Registry

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

func New

func New() *Registry

func (*Registry) Execute

func (r *Registry) Execute(topic string, payload json.RawMessage) error

func (*Registry) Get

func (r *Registry) Get(topic string) (*Handler, bool)

func (*Registry) Has

func (r *Registry) Has(topic string) bool

func (*Registry) Register

func (r *Registry) Register(topic string, fn HandlerFunc, payloadType interface{}) error

func (*Registry) Remove

func (r *Registry) Remove(topic string)

func (*Registry) Topics

func (r *Registry) Topics() []string