mediator

Documentation

Index

• Variables
• type Behavior
• type Behaviors
• type Mediator
  • func New(opts ...Option) (*Mediator, error)
  • func (m *Mediator) Send(ctx context.Context, req Message) (interface{}, error)
• type Message
• type Next
• type Option
  • func WithBehaviour(behavior PipelineBehaviour) Option
  • func WithBehaviourFunc(fn func(context.Context, Message, Next) (interface{}, error)) Option
  • func WithHandler(req Message, rh RequestHandler) Option
• type Pipeline
• type PipelineBehaviour
• type PipelineContext
• type RequestHandler
• type Sender

Variables

var (
	ErrHandlerNotFound = errors.New("handler could not be found")
	ErrInvalidArg      = errors.New("invalid arg")
)

Types

type Behavior

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

type Behaviors

type Behaviors []Behavior

type Mediator

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

func New

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

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 Option

type Option func(pCtx *PipelineContext) error

func WithBehaviour

func WithBehaviour(behavior PipelineBehaviour) Option

func WithBehaviourFunc

func WithBehaviourFunc(fn func(context.Context, Message, Next) (interface{}, error)) Option

func WithHandler

func WithHandler(req Message, rh RequestHandler) Option

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
}

type RequestHandler

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

type Sender

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