local

Documentation

Index

• type CommandBus
  • func NewCommandBus() *CommandBus
  • func (b *CommandBus) HandleCommand(ctx context.Context, cmd eh.Command) error
  • func (b *CommandBus) SetHandler(handler eh.CommandHandler, cmdType eh.CommandType) error

Types

type CommandBus

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

CommandBus is a command bus that handles commands with the registered CommandHandlers

func NewCommandBus

func NewCommandBus() *CommandBus

NewCommandBus creates a CommandBus.

func (*CommandBus) HandleCommand

func (b *CommandBus) HandleCommand(ctx context.Context, cmd eh.Command) error

HandleCommand handles a command with a handler capable of handling it.

func (*CommandBus) SetHandler

func (b *CommandBus) SetHandler(handler eh.CommandHandler, cmdType eh.CommandType) error

SetHandler adds a handler for a specific command.