application

Documentation

Index

• type App
• type Application
  • func New(shoppingLists domain.ShoppingListRepository, stores domain.StoreRepository, ...) *Application
• type Commands
• type OrderHandlers
  • func NewOrderHandlers(orders domain.OrderRepository) OrderHandlers[ddd.AggregateEvent]
  • func (h OrderHandlers[T]) HandleEvent(ctx context.Context, event T) error
• type ProductHandlers
  • func NewProductHandlers(cache domain.ProductCacheRepository) ProductHandlers[ddd.Event]
  • func (h ProductHandlers[T]) HandleEvent(ctx context.Context, event T) error
• type Queries
• type StoreHandlers
  • func NewStoreHandlers(cache domain.StoreCacheRepository) StoreHandlers[ddd.Event]
  • func (h StoreHandlers[T]) HandleEvent(ctx context.Context, event T) error

Types

type App

type App interface {
	Commands
	Queries
}

type Application

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

func New

func New(shoppingLists domain.ShoppingListRepository, stores domain.StoreRepository, products domain.ProductRepository,
	domainPublisher ddd.EventPublisher[ddd.AggregateEvent],
) *Application

type Commands

type Commands interface {
	CreateShoppingList(ctx context.Context, cmd commands.CreateShoppingList) error
	CancelShoppingList(ctx context.Context, cmd commands.CancelShoppingList) error
	AssignShoppingList(ctx context.Context, cmd commands.AssignShoppingList) error
	CompleteShoppingList(ctx context.Context, cmd commands.CompleteShoppingList) error
}

type OrderHandlers

type OrderHandlers[T ddd.AggregateEvent] struct {
	// contains filtered or unexported fields
}

func NewOrderHandlers

func NewOrderHandlers(orders domain.OrderRepository) OrderHandlers[ddd.AggregateEvent]

func (OrderHandlers[T]) HandleEvent

func (h OrderHandlers[T]) HandleEvent(ctx context.Context, event T) error

type ProductHandlers

type ProductHandlers[T ddd.Event] struct {
	// contains filtered or unexported fields
}

func NewProductHandlers

func NewProductHandlers(cache domain.ProductCacheRepository) ProductHandlers[ddd.Event]

func (ProductHandlers[T]) HandleEvent

func (h ProductHandlers[T]) HandleEvent(ctx context.Context, event T) error

type Queries

type Queries interface {
	GetShoppingList(ctx context.Context, query queries.GetShoppingList) (*domain.ShoppingList, error)
}

type StoreHandlers

type StoreHandlers[T ddd.Event] struct {
	// contains filtered or unexported fields
}

func NewStoreHandlers

func NewStoreHandlers(cache domain.StoreCacheRepository) StoreHandlers[ddd.Event]

func (StoreHandlers[T]) HandleEvent

func (h StoreHandlers[T]) HandleEvent(ctx context.Context, event T) error