domain

package
v0.0.0-...-0ebfa01 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 20, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BasketStartedEvent     = "baskets.BasketStarted"
	BasketItemAddedEvent   = "baskets.BasketItemAdded"
	BasketItemRemovedEvent = "baskets.BasketItemRemoved"
	BasketCanceledEvent    = "baskets.BasketCanceled"
	BasketCheckedOutEvent  = "baskets.BasketCheckedOut"
)
View Source 
const BasketAggregate = "baskets.Basket"

Variables

View Source 
var (
	ErrBasketHasNoItems         = errors.Wrap(errors.ErrBadRequest, "the basket has no items")
	ErrBasketCannotBeModified   = errors.Wrap(errors.ErrBadRequest, "the basket cannot be modified")
	ErrBasketCannotBeCancelled  = errors.Wrap(errors.ErrBadRequest, "the basket cannot be cancelled")
	ErrQuantityCannotBeNegative = errors.Wrap(errors.ErrBadRequest, "the item quantity cannot be negative")
	ErrBasketIDCannotBeBlank    = errors.Wrap(errors.ErrBadRequest, "the basket id cannot be blank")
	ErrPaymentIDCannotBeBlank   = errors.Wrap(errors.ErrBadRequest, "the payment id cannot be blank")
	ErrCustomerIDCannotBeBlank  = errors.Wrap(errors.ErrBadRequest, "the customer id cannot be blank")
)

Functions

func Registrations 

func Registrations(reg registry.Registry) error

Types

type Basket 

type Basket struct {
	es.Aggregate
	CustomerID string
	PaymentID  string
	Items      map[string]Item
	Status     BasketStatus
}

func NewBasket 

func NewBasket(id string) *Basket

func (*Basket) AddItem 

func (b *Basket) AddItem(store *Store, product *Product, quantity int) error

func (*Basket) ApplyEvent 

func (b *Basket) ApplyEvent(event ddd.Event) error

func (*Basket) ApplySnapshot 

func (b *Basket) ApplySnapshot(snapshot es.Snapshot) error

func (*Basket) Cancel 

func (b *Basket) Cancel() (ddd.Event, error)

func (*Basket) Checkout 

func (b *Basket) Checkout(paymentID string) (ddd.Event, error)

func (Basket) IsCancellable 

func (b Basket) IsCancellable() bool

func (Basket) IsOpen 

func (b Basket) IsOpen() bool

func (Basket) Key 

func (Basket) Key() string

func (*Basket) RemoveItem 

func (b *Basket) RemoveItem(product *Product, quantity int) error

func (*Basket) Start 

func (b *Basket) Start(customerID string) (ddd.Event, error)

func (*Basket) ToSnapshot 

func (b *Basket) ToSnapshot() es.Snapshot

type BasketCanceled 

type BasketCanceled struct{}

func (BasketCanceled) Key 

func (BasketCanceled) Key() string

type BasketCheckedOut 

type BasketCheckedOut struct {
	PaymentID string
}

func (BasketCheckedOut) Key 

func (BasketCheckedOut) Key() string

type BasketItemAdded 

type BasketItemAdded struct {
	Item Item
}

func (BasketItemAdded) Key 

func (BasketItemAdded) Key() string

type BasketItemRemoved 

type BasketItemRemoved struct {
	ProductID string
	Quantity  int
}

func (BasketItemRemoved) Key 

func (BasketItemRemoved) Key() string

type BasketRepository 

type BasketRepository interface {
	Load(ctx context.Context, basketID string) (*Basket, error)
	Save(ctx context.Context, basket *Basket) error
}

type BasketStarted 

type BasketStarted struct {
	CustomerID string
}

func (BasketStarted) Key 

func (BasketStarted) Key() string

type BasketStatus 

type BasketStatus string
const (
	BasketUnknown      BasketStatus = ""
	BasketIsOpen       BasketStatus = "open"
	BasketIsCanceled   BasketStatus = "canceled"
	BasketIsCheckedOut BasketStatus = "checked_out"
)

func ToBasketStatus 

func ToBasketStatus(status string) BasketStatus

func (BasketStatus) String 

func (s BasketStatus) String() string

type BasketV1 

type BasketV1 struct {
	CustomerID string
	PaymentID  string
	Items      map[string]Item
	Status     BasketStatus
}

func (BasketV1) SnapshotName 

func (BasketV1) SnapshotName() string

type FakeBasketRepository 

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

func NewFakeBasketRepository 

func NewFakeBasketRepository() *FakeBasketRepository

func (*FakeBasketRepository) Load 

func (r *FakeBasketRepository) Load(ctx context.Context, basketID string) (*Basket, error)

func (*FakeBasketRepository) Reset 

func (r *FakeBasketRepository) Reset(baskets ...*Basket)

func (*FakeBasketRepository) Save 

func (r *FakeBasketRepository) Save(ctx context.Context, basket *Basket) error

type FakeProductCacheRepository 

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

func NewFakeProductCacheRepository 

func NewFakeProductCacheRepository() *FakeProductCacheRepository

func (*FakeProductCacheRepository) Add 

func (r *FakeProductCacheRepository) Add(ctx context.Context, productID, storeID, name string, price float64) error

func (*FakeProductCacheRepository) Find 

func (r *FakeProductCacheRepository) Find(ctx context.Context, productID string) (*Product, error)

func (*FakeProductCacheRepository) Rebrand 

func (r *FakeProductCacheRepository) Rebrand(ctx context.Context, productID, name string) error

func (*FakeProductCacheRepository) Remove 

func (r *FakeProductCacheRepository) Remove(ctx context.Context, productID string) error

func (*FakeProductCacheRepository) Reset 

func (r *FakeProductCacheRepository) Reset(products ...*Product)

func (*FakeProductCacheRepository) UpdatePrice 

func (r *FakeProductCacheRepository) UpdatePrice(ctx context.Context, productID string, delta float64) error

type FakeStoreCacheRepository 

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

func NewFakeStoreCacheRepository 

func NewFakeStoreCacheRepository() *FakeStoreCacheRepository

func (*FakeStoreCacheRepository) Add 

func (r *FakeStoreCacheRepository) Add(ctx context.Context, storeID, name string) error

func (*FakeStoreCacheRepository) Find 

func (r *FakeStoreCacheRepository) Find(ctx context.Context, storeID string) (*Store, error)

func (*FakeStoreCacheRepository) Rename 

func (r *FakeStoreCacheRepository) Rename(ctx context.Context, storeID, name string) error

func (*FakeStoreCacheRepository) Reset 

func (r *FakeStoreCacheRepository) Reset(stores ...*Store)

type Item 

type Item struct {
	StoreID      string
	ProductID    string
	StoreName    string
	ProductName  string
	ProductPrice float64
	Quantity     int
}

type MockBasketRepository 

type MockBasketRepository struct {
	mock.Mock
}

MockBasketRepository is an autogenerated mock type for the BasketRepository type

func NewMockBasketRepository 

func NewMockBasketRepository(t mockConstructorTestingTNewMockBasketRepository) *MockBasketRepository

NewMockBasketRepository creates a new instance of MockBasketRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockBasketRepository) Load 

func (_m *MockBasketRepository) Load(ctx context.Context, basketID string) (*Basket, error)

Load provides a mock function with given fields: ctx, basketID

func (*MockBasketRepository) Save 

func (_m *MockBasketRepository) Save(ctx context.Context, basket *Basket) error

Save provides a mock function with given fields: ctx, basket

type MockProductCacheRepository 

type MockProductCacheRepository struct {
	mock.Mock
}

MockProductCacheRepository is an autogenerated mock type for the ProductCacheRepository type

func NewMockProductCacheRepository 

func NewMockProductCacheRepository(t mockConstructorTestingTNewMockProductCacheRepository) *MockProductCacheRepository

NewMockProductCacheRepository creates a new instance of MockProductCacheRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockProductCacheRepository) Add 

func (_m *MockProductCacheRepository) Add(ctx context.Context, productID string, storeID string, name string, price float64) error

Add provides a mock function with given fields: ctx, productID, storeID, name, price

func (*MockProductCacheRepository) Find 

func (_m *MockProductCacheRepository) Find(ctx context.Context, productID string) (*Product, error)

Find provides a mock function with given fields: ctx, productID

func (*MockProductCacheRepository) Rebrand 

func (_m *MockProductCacheRepository) Rebrand(ctx context.Context, productID string, name string) error

Rebrand provides a mock function with given fields: ctx, productID, name

func (*MockProductCacheRepository) Remove 

func (_m *MockProductCacheRepository) Remove(ctx context.Context, productID string) error

Remove provides a mock function with given fields: ctx, productID

func (*MockProductCacheRepository) UpdatePrice 

func (_m *MockProductCacheRepository) UpdatePrice(ctx context.Context, productID string, delta float64) error

UpdatePrice provides a mock function with given fields: ctx, productID, delta

type MockProductRepository 

type MockProductRepository struct {
	mock.Mock
}

MockProductRepository is an autogenerated mock type for the ProductRepository type

func NewMockProductRepository 

func NewMockProductRepository(t mockConstructorTestingTNewMockProductRepository) *MockProductRepository

NewMockProductRepository creates a new instance of MockProductRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockProductRepository) Find 

func (_m *MockProductRepository) Find(ctx context.Context, productID string) (*Product, error)

Find provides a mock function with given fields: ctx, productID

type MockStoreCacheRepository 

type MockStoreCacheRepository struct {
	mock.Mock
}

MockStoreCacheRepository is an autogenerated mock type for the StoreCacheRepository type

func NewMockStoreCacheRepository 

func NewMockStoreCacheRepository(t mockConstructorTestingTNewMockStoreCacheRepository) *MockStoreCacheRepository

NewMockStoreCacheRepository creates a new instance of MockStoreCacheRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockStoreCacheRepository) Add 

func (_m *MockStoreCacheRepository) Add(ctx context.Context, storeID string, name string) error

Add provides a mock function with given fields: ctx, storeID, name

func (*MockStoreCacheRepository) Find 

func (_m *MockStoreCacheRepository) Find(ctx context.Context, storeID string) (*Store, error)

Find provides a mock function with given fields: ctx, storeID

func (*MockStoreCacheRepository) Rename 

func (_m *MockStoreCacheRepository) Rename(ctx context.Context, storeID string, name string) error

Rename provides a mock function with given fields: ctx, storeID, name

type MockStoreRepository 

type MockStoreRepository struct {
	mock.Mock
}

MockStoreRepository is an autogenerated mock type for the StoreRepository type

func NewMockStoreRepository 

func NewMockStoreRepository(t mockConstructorTestingTNewMockStoreRepository) *MockStoreRepository

NewMockStoreRepository creates a new instance of MockStoreRepository. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockStoreRepository) Find 

func (_m *MockStoreRepository) Find(ctx context.Context, storeID string) (*Store, error)

Find provides a mock function with given fields: ctx, storeID

type Product 

type Product struct {
	ID      string
	StoreID string
	Name    string
	Price   float64
}

type ProductCacheRepository 

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

type ProductRepository 

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

type Store 

type Store struct {
	ID   string
	Name string
}

type StoreCacheRepository 

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

type StoreRepository 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.