repository

Documentation

Index

• func Connect(cfg *config.PG) (*pgxpool.Pool, error)
• func GenerateOrder() *models.Order
• type Cache
• type Order
• type OrderCache
  • func NewOrderCache(cache *cache.OrderCache) *OrderCache
  • func (oc *OrderCache) CreateCache(or models.Order)
  • func (oc *OrderCache) GetOrderByIdCache(id string) *models.Order
  • func (oc *OrderCache) GetOrdersCache(limit int, offset int) []*models.Order
  • func (oc *OrderCache) GetOrdersCount() int
  • func (oc *OrderCache) PreloadCache(orders []models.Order)
• type Repo
  • func NewOrderPostgres(pool *pgxpool.Pool) *Repo
  • func (r *Repo) CreateTable() error
  • func (r *Repo) GetOrder(uid string) (models.Order, error)
  • func (r *Repo) GetOrders() ([]models.Order, error)
  • func (r *Repo) SaveOrder(order models.Order) error
• type Repository
  • func NewRepository(db *pgxpool.Pool, cache *cache.OrderCache) *Repository

Functions

func Connect

func Connect(cfg *config.PG) (*pgxpool.Pool, error)

func GenerateOrder

func GenerateOrder() *models.Order

Types

type Cache

type Cache interface {
	CreateCache(or models.Order)
	PreloadCache(orders []models.Order)
	GetOrderByIdCache(id string) *models.Order
	GetOrdersCache(limit int, offset int) []*models.Order
	GetOrdersCount() int
}

type Order

type Order interface {
	CreateTable() error
	SaveOrder(order models.Order) error
	GetOrders() ([]models.Order, error)
}

type OrderCache

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

func NewOrderCache

func NewOrderCache(cache *cache.OrderCache) *OrderCache

func (*OrderCache) CreateCache

func (oc *OrderCache) CreateCache(or models.Order)

func (*OrderCache) GetOrderByIdCache

func (oc *OrderCache) GetOrderByIdCache(id string) *models.Order

func (*OrderCache) GetOrdersCache

func (oc *OrderCache) GetOrdersCache(limit int, offset int) []*models.Order

func (*OrderCache) GetOrdersCount

func (oc *OrderCache) GetOrdersCount() int

func (*OrderCache) PreloadCache

func (oc *OrderCache) PreloadCache(orders []models.Order)

type Repo

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

func NewOrderPostgres

func NewOrderPostgres(pool *pgxpool.Pool) *Repo

func (*Repo) CreateTable

func (r *Repo) CreateTable() error

func (*Repo) GetOrder

func (r *Repo) GetOrder(uid string) (models.Order, error)

useless, т.к. все заказы разом подгружаются в кэш и данные http запросов читаются из кэша

func (*Repo) GetOrders

func (r *Repo) GetOrders() ([]models.Order, error)

func (*Repo) SaveOrder

func (r *Repo) SaveOrder(order models.Order) error

type Repository

type Repository struct {
	Order
	Cache
}

func NewRepository

func NewRepository(db *pgxpool.Pool, cache *cache.OrderCache) *Repository