cqs

type AppError ¶

type AppError struct {
	Name   string      `json:"name"`
	Input  interface{} `json:"input"`
	ErrMsg string      `json:"err_msg"`
}

AppError is a query/command hnd error with context

type BasicAggregateRoot ¶

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

func NewBasicAggregateRoot() BasicAggregateRoot

func (b *BasicAggregateRoot) ClearEvents()

func (b BasicAggregateRoot) CreatedAt() vo.Time

func (b *BasicAggregateRoot) Events() []Event

func (b *BasicAggregateRoot) Hydrate(createdAt vo.Time, events []Event)

func (b *BasicAggregateRoot) Record(evs ...Event)

type BasicEvent ¶

type BasicEvent struct {
	IDAttr              uuid.UUID `json:"id"`
	NameAttr            EventName `json:"name"`
	AtAttr              vo.Time   `json:"at"`
	AggregateRootIDAttr string    `json:"aggregate_root_id"`
}

BasicEvent is the minimal domain event struct.

func NewBasicEvent(name EventName, id uuid.UUID, aggRootID string) BasicEvent

func (b BasicEvent) AggregateRootID() string

func (b BasicEvent) EventAt() vo.Time

func (b BasicEvent) EventID() uuid.UUID

func (b BasicEvent) EventName() string

type Command ¶

type Command interface {
	Name() string
}

Command is the interface for identifying commands by name.

type CommandHandler ¶

type CommandHandler interface {
	Handle(ctx context.Context, cmd Command) ([]Event, error)
}

CommandHandler is self-described

type CommandHandlerFunc ¶

type CommandHandlerFunc func(ctx context.Context, cmd Command) ([]Event, error)

CommandHandlerFunc is a function that implements CommandHandler interface.

func (f CommandHandlerFunc) Handle(ctx context.Context, cmd Command) ([]Event, error)

type CommandHandlerMiddleware ¶

type CommandHandlerMiddleware func(h CommandHandler) CommandHandler

func CommandHandlerMultiMiddleware(middlewares ...CommandHandlerMiddleware) CommandHandlerMiddleware

func NewCommandHndErrorMiddleware(logger *zerolog.Logger) CommandHandlerMiddleware

type Event ¶

type Event interface {
	EventID() uuid.UUID
	EventName() string
	EventAt() vo.Time
	AggregateRootID() string
}

Event is self-described

type EventBus ¶

type EventBus map[string][]EventListener

EventBus subscribe events with event listeners, and dispatch them.

func NewEventBus() EventBus

func (e EventBus) Dispatch(ctx context.Context, ev Event) error

func (e EventBus) Subscribe(ev Event, listeners ...EventListener)

type EventFactory ¶

type EventFactory func() Event

EventFactory must return a typed event.

type EventListener ¶

type EventListener interface {
	Listen(ctx context.Context, ev Event) error
}

EventListener is self-described

type EventName ¶

type EventName string

EventName is self-described

func (e EventName) String() string

type EventsRepositoryError ¶

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

EventsRepositoryError is self-described

func NewEventsRepositoryError(operation string, err error) EventsRepositoryError

func (e EventsRepositoryError) Error() string

type InvalidCommandError ¶

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

InvalidCommandError should be returned by the implementations of the interface when the handler does not receive the needed command.

func NewInvalidCommandError(expected string, had string) InvalidCommandError

func (e InvalidCommandError) Error() string

type InvalidQueryError ¶

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

InvalidQueryError is self-described

func NewInvalidQueryError(expected string, had string) InvalidQueryError

func (e InvalidQueryError) Error() string

type Query ¶

type Query interface {
	Name() string
}

Query is the interface to identify the DTO for a given query by name.

type QueryHandler ¶

type QueryHandler interface {
	Handle(ctx context.Context, query Query) (any, error)
}

QueryHandler is the interface for handling queries.

type QueryHandlerMiddleware ¶

type QueryHandlerMiddleware func(h QueryHandler) QueryHandler

QueryHandlerMiddleware is a type for decorating QueryHandlers

func NewQueryHndErrorMiddleware(logger *zerolog.Logger) QueryHandlerMiddleware

type QueryName ¶

type QueryName string

QueryName is string to identify a given query when it has not input parameters.

func (qn QueryName) Name() string

type UnknownEventToDispatchError ¶

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

UnknownEventToDispatchError is self-described

func (u UnknownEventToDispatchError) Error() string