inmemory

Documentation

Index

• type CommandBus
  • func NewCommandBus() *CommandBus
  • func (b *CommandBus) Dispatch(ctx context.Context, cmd command.Command) error
  • func (b *CommandBus) Register(cmdType command.Type, handler command.Handler)
• type EventBus
  • func NewEventBus() *EventBus
  • func (b *EventBus) Publish(ctx context.Context, events []event.Event) error
  • func (b *EventBus) Subscribe(evtType event.Type, handler event.Handler)

Types

type CommandBus

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

CommandBus is an in-memory implementation of the command.Bus.

func NewCommandBus

func NewCommandBus() *CommandBus

NewCommandBus initializes a new instance of CommandBus.

func (*CommandBus) Dispatch

func (b *CommandBus) Dispatch(ctx context.Context, cmd command.Command) error

Dispatch implements the command.Bus interface.

func (*CommandBus) Register

func (b *CommandBus) Register(cmdType command.Type, handler command.Handler)

Register implements the command.Bus interface.

type EventBus

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

EventBus is an in-memory implementation of the event.Bus.

func NewEventBus

func NewEventBus() *EventBus

NewEventBus initializes a new EventBus.

func (*EventBus) Publish

func (b *EventBus) Publish(ctx context.Context, events []event.Event) error

Publish implements the event.Bus interface.

func (*EventBus) Subscribe

func (b *EventBus) Subscribe(evtType event.Type, handler event.Handler)

Subscribe implements the event.Bus interface.