mediator

Documentation

Index

• type CommandResponse
• type Handler
• type Mediator
  • func New(options ...Option) (*Mediator, error)
  • func (m *Mediator) Send(ctx context.Context, command Message) (interface{}, error)
• type Message
• type Option
  • func WithHandler(command Message, handler Handler) Option

Types

type CommandResponse

type CommandResponse interface {
}

type Handler

type Handler interface {
	Handle(ctx context.Context, cmd Message) (interface{}, error)
}

type Mediator

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

func New

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

func (*Mediator) Send

func (m *Mediator) Send(ctx context.Context, command Message) (interface{}, error)

type Message

type Message interface {
	Key() string
}

type Option

type Option func(*Mediator) error

func WithHandler

func WithHandler(command Message, handler Handler) Option