inmemory

package

v0.0.0-...-ee0c78d Latest Latest Go to latest Published: Jul 29, 2021 License: GPL-3.0 Imports: 3 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

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

func NewCommandBus() *CommandBus

NewCommandBus initializes a new instance of CommandBus.

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

Dispatch implements the command.Bus interface.

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

Register implements the command.Bus interface.

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

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

func NewEventBus() *EventBus

NewEventBus initializes a new EventBus.

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

Publish implements the event.Bus interface.

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

Subscribe implements the event.Bus interface.