application

Documentation

Index

• func New(orders OrderRepository) *app
• type Application
• type CustomerCacheRepository
• type CustomerHandlers
  • func NewCustomerHandlers(cache CustomerCacheRepository) CustomerHandlers[ddd.Event]
  • func (h CustomerHandlers[T]) HandleEvent(ctx context.Context, event T) error
• type CustomerRepository
• type Filters
• type GetOrder
• type OrderHandlers
  • func NewOrderHandlers(orders OrderRepository, customers CustomerRepository, stores StoreRepository, ...) OrderHandlers[ddd.Event]
  • func (h OrderHandlers[T]) HandleEvent(ctx context.Context, event T) error
• type OrderRepository
• type ProductCacheRepository
• type ProductHandlers
  • func NewProductHandlers(cache ProductCacheRepository) ProductHandlers[ddd.Event]
  • func (h ProductHandlers[T]) HandleEvent(ctx context.Context, event T) error
• type ProductRepository
• type SearchOrders
• type StoreCacheRepository
• type StoreHandlers
  • func NewStoreHandlers(cache StoreCacheRepository) StoreHandlers[ddd.Event]
  • func (h StoreHandlers[T]) HandleEvent(ctx context.Context, event T) error
• type StoreRepository

Functions

func New

func New(orders OrderRepository) *app

Types

type Application

type Application interface {
	SearchOrders(ctx context.Context, search SearchOrders) ([]*models.Order, error)
	GetOrder(ctx context.Context, get GetOrder) (*models.Order, error)
}

type CustomerCacheRepository

type CustomerCacheRepository interface {
	Add(ctx context.Context, customerID, name string) error
	CustomerRepository
}

type CustomerHandlers

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

func NewCustomerHandlers

func NewCustomerHandlers(cache CustomerCacheRepository) CustomerHandlers[ddd.Event]

func (CustomerHandlers[T]) HandleEvent

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

type CustomerRepository

type CustomerRepository interface {
	Find(ctx context.Context, customerID string) (*models.Customer, error)
}

type Filters

type Filters struct {
	CustomerID string
	After      time.Time
	Before     time.Time
	StoreIDs   []string
	ProductIDs []string
	MinTotal   float64
	MaxTotal   float64
	Status     string
}

type GetOrder

type GetOrder struct {
	OrderID string
}

type OrderHandlers

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

func NewOrderHandlers

func NewOrderHandlers(orders OrderRepository, customers CustomerRepository, stores StoreRepository, products ProductRepository) OrderHandlers[ddd.Event]

func (OrderHandlers[T]) HandleEvent

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

type OrderRepository

type OrderRepository interface {
	Add(ctx context.Context, order *models.Order) error
	UpdateStatus(ctx context.Context, orderID, status string) error
	Search(ctx context.Context, search SearchOrders) ([]*models.Order, error)
	Get(ctx context.Context, orderID string) (*models.Order, error)
}

type ProductCacheRepository

type ProductCacheRepository interface {
	Add(ctx context.Context, productID, storeID, name string) error
	Rebrand(ctx context.Context, productID, name string) error
	Remove(ctx context.Context, productID string) error
	ProductRepository
}

type ProductHandlers

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

func NewProductHandlers

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

func (ProductHandlers[T]) HandleEvent

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

type ProductRepository

type ProductRepository interface {
	Find(ctx context.Context, productID string) (*models.Product, error)
}

type SearchOrders

type SearchOrders struct {
	Filters Filters
	Next    string
	Limit   int
}

type StoreCacheRepository

type StoreCacheRepository interface {
	Add(ctx context.Context, storeID, name string) error
	Rename(ctx context.Context, storeID, name string) error
	StoreRepository
}

type StoreHandlers

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

func NewStoreHandlers

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

func (StoreHandlers[T]) HandleEvent

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

type StoreRepository

type StoreRepository interface {
	Find(ctx context.Context, storeID string) (*models.Store, error)
}