mediator

Documentation

Index

• type Behaviour
• type Builder
• type Mediator
  • func (m *Mediator) Send(ctx context.Context, req Message) (interface{}, error)
• type Message
• type Next
• type Pipeline
• type PipelineBehaviour
• type PipelineContext
  • 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
• type Sender

Types

type Behaviour

type Behaviour func(context.Context, Message, Next) (interface{}, error)

type Builder

type Builder interface {
	RegisterHandler(request Message, handler RequestHandler) Builder
	UseBehaviour(PipelineBehaviour) Builder
	Use(fn func(context.Context, Message, Next) (interface{}, error)) Builder
	Build() (*Mediator, error)
}

type Mediator

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

func (*Mediator) Send

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

type Message

type Message interface {
	Key() string
}

type Next

type Next func(ctx context.Context) (interface{}, error)

type Pipeline

type Pipeline func(context.Context, Message) (interface{}, error)

type PipelineBehaviour

type PipelineBehaviour interface {
	Process(context.Context, Message, Next) (interface{}, error)
}

type PipelineContext

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

func NewContext

func NewContext() *PipelineContext

func (*PipelineContext) Build

func (p *PipelineContext) Build() (*Mediator, error)

func (*PipelineContext) RegisterHandler

func (p *PipelineContext) RegisterHandler(req Message, h RequestHandler) Builder

func (*PipelineContext) Use

func (p *PipelineContext) Use(call func(context.Context, Message, Next) (interface{}, error)) Builder

func (*PipelineContext) UseBehaviour

func (p *PipelineContext) UseBehaviour(behaviour PipelineBehaviour) Builder

type RequestHandler

type RequestHandler interface {
	Handle(context.Context, Message) (interface{}, error)
}

type Sender

type Sender interface {
	Send(context.Context, Message) (interface{}, error)
}