dispatcher

README

dispatcher

Dispatcher is the Go event dispatcher strategy pattern.

Documentation

Index

• Variables
• func Dispatch(ctx context.Context, d Dispatcher, msg ...Message) error
• func DispatchAfter(ctx context.Context, d Dispatcher, duration time.Duration, ...)
• func DispatchAt(ctx context.Context, d Dispatcher, t time.Time, resultFn func(err error), ...)
• func MessageName(msg Message) string
• func MessageNameFromHandler(h Handler) string
• type Dispatcher
• type HTTPHandlerWrapper
  • func (wrapper HTTPHandlerWrapper) Handler(msg Message) http.Handler
• type Handler
• type Message
• type Mux
  • func NewMux() *Mux
  • func (d *Mux) Dispatch(ctx context.Context, msg Message) error
  • func (d *Mux) Handler(msg Message) Handler
  • func (d *Mux) Register(hs ...Handler)

Variables

var (
	ErrNotFound = errors.New("dispatcher: handler not found")
)

Errors

Functions

func Dispatch

func Dispatch(ctx context.Context, d Dispatcher, msg ...Message) error

Dispatch calls handler for given messages in sequence order, when a handler returns error, dispatch will stop and return that error

func DispatchAfter

func DispatchAfter(ctx context.Context, d Dispatcher, duration time.Duration, resultFn func(err error), msg ...Message)

DispatchAfter calls dispatch after given duration or run immediate if duration is negative, then call resultFn with return error

func DispatchAt

func DispatchAt(ctx context.Context, d Dispatcher, t time.Time, resultFn func(err error), msg ...Message)

DispatchAt calls dispatch at given time, and will run immediate if time already passed

func MessageName

func MessageName(msg Message) string

MessageName gets message name

func MessageNameFromHandler

func MessageNameFromHandler(h Handler) string

MessageNameFromHandler gets message name from handler

Types

type Dispatcher

type Dispatcher interface {
	Dispatch(context.Context, Message) error
}

Dispatcher is the event dispatcher

type HTTPHandlerWrapper

type HTTPHandlerWrapper struct {
	Dispatcher Dispatcher
	Decoder    func(r *http.Request, v interface{}) error
	Encoder    func(w http.ResponseWriter, r *http.Request, v interface{}) error
	Result     string
}

HTTPHandlerWrapper wraps dispatcher message to http handler

func (HTTPHandlerWrapper) Handler

func (wrapper HTTPHandlerWrapper) Handler(msg Message) http.Handler

Handler wraps message to http handler

type Handler

type Handler interface{}

Handler is the event handler

func(context.Context, *Any) error

type Message

type Message interface{}

Message is the event message

type Mux

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

Mux is the dispatch multiplexer

func NewMux

func NewMux() *Mux

NewMux creates new mux

func (*Mux) Dispatch

func (d *Mux) Dispatch(ctx context.Context, msg Message) error

Dispatch calls handler for given messages

func (*Mux) Handler

func (d *Mux) Handler(msg Message) Handler

Handler returns handler for given message

func (*Mux) Register

func (d *Mux) Register(hs ...Handler)

Register registers handlers, and override old handler if exists