Versions in this module Expand all Collapse all v0 v0.0.2 May 23, 2021 v0.0.1 May 23, 2021 Changes in this version + type Behaviour func(context.Context, Message, Next) (interface{}, error) + type Builder interface + Build func() (*Mediator, error) + RegisterHandler func(request Message, handler RequestHandler) Builder + Use func(fn func(context.Context, Message, Next) (interface{}, error)) Builder + UseBehaviour func(PipelineBehaviour) Builder + type Mediator struct + func (m *Mediator) Send(ctx context.Context, req Message) (interface{}, error) + type Message interface + Key func() string + type Next func(ctx context.Context) (interface{}, error) + type Pipeline func(context.Context, Message) (interface{}, error) + type PipelineBehaviour interface + Process func(context.Context, Message, Next) (interface{}, error) + type PipelineContext struct + func NewContext() *PipelineContext + func (p *PipelineContext) Build() (*Mediator, error) + func (p *PipelineContext) RegisterHandler(req Message, h RequestHandler) Builder + func (p *PipelineContext) Use(call func(context.Context, Message, Next) (interface{}, error)) Builder + func (p *PipelineContext) UseBehaviour(behaviour PipelineBehaviour) Builder + type RequestHandler interface + Handle func(context.Context, Message) (interface{}, error) + type Sender interface + Send func(context.Context, Message) (interface{}, error)
Go to main page