application

package

v0.0.0-...-3a9fddd Latest Latest Go to latest Published: Nov 1, 2024 License: MIT Imports: 7 Imported by: 0

Documentation ¶

Index ¶

type App
type Application
- func New(stores domain.StoreRepository, products domain.ProductRepository, ...) *Application
type CatalogHandlers
- func NewCatalogHandlers(catalog domain.CatalogRepository) *CatalogHandlers[ddd.AggregateEvent]
- func (h CatalogHandlers[T]) HandleEvent(ctx context.Context, event T) error
type Commands
type IntegrationEventHandlers
- func NewIntegrationEventHandlers(publisher am.MessagePublisher[ddd.Event]) *IntegrationEventHandlers[ddd.AggregateEvent]
- func (h IntegrationEventHandlers[T]) HandleEvent(ctx context.Context, event T) error
type MallHandlers
- func NewMallHandlers(mall domain.MallRepository) *MallHandlers[ddd.AggregateEvent]
- func (h MallHandlers[T]) HandleEvent(ctx context.Context, event T) error
type Queries

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type App ¶

type App interface {
	Commands
	Queries
}

type Application ¶

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

func New ¶

func New(stores domain.StoreRepository, products domain.ProductRepository,
	catalog domain.CatalogRepository, mall domain.MallRepository,
) *Application

type CatalogHandlers ¶

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

func NewCatalogHandlers ¶

func NewCatalogHandlers(catalog domain.CatalogRepository) *CatalogHandlers[ddd.AggregateEvent]

func (CatalogHandlers[T]) HandleEvent ¶

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

type Commands ¶

type Commands interface {
	CreateStore(ctx context.Context, cmd commands.CreateStore) error
	EnableParticipation(ctx context.Context, cmd commands.EnableParticipation) error
	DisableParticipation(ctx context.Context, cmd commands.DisableParticipation) error
	RebrandStore(ctx context.Context, cmd commands.RebrandStore) error
	AddProduct(ctx context.Context, cmd commands.AddProduct) error
	RebrandProduct(ctx context.Context, cmd commands.RebrandProduct) error
	IncreaseProductPrice(ctx context.Context, cmd commands.IncreaseProductPrice) error
	DecreaseProductPrice(ctx context.Context, cmd commands.DecreaseProductPrice) error
	RemoveProduct(ctx context.Context, cmd commands.RemoveProduct) error
}

type IntegrationEventHandlers ¶

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

func NewIntegrationEventHandlers ¶

func NewIntegrationEventHandlers(publisher am.MessagePublisher[ddd.Event]) *IntegrationEventHandlers[ddd.AggregateEvent]

func (IntegrationEventHandlers[T]) HandleEvent ¶

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

type MallHandlers ¶

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

func NewMallHandlers ¶

func NewMallHandlers(mall domain.MallRepository) *MallHandlers[ddd.AggregateEvent]

func (MallHandlers[T]) HandleEvent ¶

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

type Queries ¶

type Queries interface {
	GetStore(ctx context.Context, query queries.GetStore) (*domain.MallStore, error)
	GetStores(ctx context.Context, query queries.GetStores) ([]*domain.MallStore, error)
	GetParticipatingStores(ctx context.Context, query queries.GetParticipatingStores) ([]*domain.MallStore, error)
	GetCatalog(ctx context.Context, query queries.GetCatalog) ([]*domain.CatalogProduct, error)
	GetProduct(ctx context.Context, query queries.GetProduct) (*domain.CatalogProduct, error)
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
commands
queries

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL