mediator

README

mediator

Simple mediator implementation for Go

Example

type MessageHandler struct{}

type Message struct {
    Foo string
}

type Response struct {
    Result string
}

func (h MessageHandler) Handle(ctx context.Context, msg *Message) (Response, error) {
    return Response{ msg.Foo + " bar "}, nil
}


m, err := mediator.New(mediator.WithHandler(&MessageHandler{})) 

r, err := m.Send(context.Background(), &Message{ "foo" })
// ...

Documentation

Index

• Variables
• type Mediator
  • func New(options ...Option) (Mediator, error)
• type Option
  • func WithHandler(h interface{}) Option
  • func WithHandlerFunc(f interface{}) Option

Variables

var (
	ErrHandlerNotFound = errors.New("message handler not found")
)

Errors

Types

type Mediator

type Mediator interface {
	// Send delegates a message to the appropriate handler
	Send(ctx context.Context, msg interface{}) (res interface{}, err error)
}

Mediator is a simple implementation of the mediator pattern

func New

func New(options ...Option) (Mediator, error)

New creates a new mediator with the options set

type Option

type Option func(*mediator) error

Option is a function that modifies the mediator with certain options

func WithHandler

func WithHandler(h interface{}) Option

WithHandler adds a message handler to the mediator a handler must have an Handle method with two arguments and two return values

func WithHandlerFunc

func WithHandlerFunc(f interface{}) Option

WithHandlerFunc adds a handler func which takes two arguments, a context and a message.