postgres

Documentation

Index

• type ProductCacheRepository
  • func NewProductCacheRepository(tableName string, db postgres.DB, fallback domain.ProductRepository) ProductCacheRepository
  • func (r ProductCacheRepository) Add(ctx context.Context, productID, storeID, name string, price float64) error
  • func (r ProductCacheRepository) Find(ctx context.Context, productID string) (*domain.Product, error)
  • func (r ProductCacheRepository) Rebrand(ctx context.Context, productID, name string) error
  • func (r ProductCacheRepository) Remove(ctx context.Context, productID string) error
  • func (r ProductCacheRepository) UpdatePrice(ctx context.Context, productID string, delta float64) error
• type StoreCacheRepository
  • func NewStoreCacheRepository(tableName string, db postgres.DB, fallback domain.StoreRepository) StoreCacheRepository
  • func (r StoreCacheRepository) Add(ctx context.Context, storeID, name string) error
  • func (r StoreCacheRepository) Find(ctx context.Context, storeID string) (*domain.Store, error)
  • func (r StoreCacheRepository) Rename(ctx context.Context, storeID, name string) error

Types

type ProductCacheRepository

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

func NewProductCacheRepository

func NewProductCacheRepository(tableName string, db postgres.DB, fallback domain.ProductRepository) ProductCacheRepository

func (ProductCacheRepository) Add

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

func (ProductCacheRepository) Find

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

func (ProductCacheRepository) Rebrand

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

func (ProductCacheRepository) Remove

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

func (ProductCacheRepository) UpdatePrice

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

type StoreCacheRepository

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

func NewStoreCacheRepository

func NewStoreCacheRepository(tableName string, db postgres.DB, fallback domain.StoreRepository) StoreCacheRepository

func (StoreCacheRepository) Add

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

func (StoreCacheRepository) Find

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

func (StoreCacheRepository) Rename

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