repository

Documentation

Index

• type OrderRepository
  • func NewOrderRepository(db Store, ordQuery query.OrderQuery) OrderRepository
• type Store
  • func NewStore(db *pgxpool.Pool) Store
• type StoreImpl
  • func (s *StoreImpl) WithTx(ctx context.Context, fn func(pgx.Tx) error) error
  • func (s *StoreImpl) WithoutTx(ctx context.Context, fn func(*pgxpool.Pool) error) error

Types

type OrderRepository

type OrderRepository interface {
	CreateOrder(context.Context, *pb.Order) (*pb.Order, error)
	GetOrderDetails(context.Context, *pb.GetOrderFilter) (*pb.GetOrderResponse, error)
	GetAllOrders(context.Context, *pb.GetOrdersRequest) (*pb.GetOrderResponse, error)
	SendOrder(context.Context, *pb.SendOrderRequest) (*stripe.PaymentLink, error)
}

func NewOrderRepository

func NewOrderRepository(db Store, ordQuery query.OrderQuery) OrderRepository

type Store

type Store interface {
	WithTx(ctx context.Context, fn func(pgx.Tx) error) error
	WithoutTx(ctx context.Context, fn func(*pgxpool.Pool) error) error
}

func NewStore

func NewStore(db *pgxpool.Pool) Store

type StoreImpl

type StoreImpl struct {
	Db *pgxpool.Pool
	// contains filtered or unexported fields
}

func (*StoreImpl) WithTx

func (s *StoreImpl) WithTx(ctx context.Context, fn func(pgx.Tx) error) error

func (*StoreImpl) WithoutTx

func (s *StoreImpl) WithoutTx(ctx context.Context, fn func(*pgxpool.Pool) error) error