sqlc

Documentation

Index

• type DBTX
• type GetBySKURow
• type GetItemsAvailabilityRow
• type Item
• type NullOrderStatus
  • func (ns *NullOrderStatus) Scan(value interface{}) error
  • func (ns NullOrderStatus) Value() (driver.Value, error)
• type Order
• type OrderStatus
  • func (e *OrderStatus) Scan(src interface{}) error
• type OrderStatusChangedEvent
• type OrdersToItem
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) GetBySKU(ctx context.Context, sku int32) (GetBySKURow, error)
  • func (q *Queries) GetItemsAvailability(ctx context.Context, sku []int32) ([]GetItemsAvailabilityRow, error)
  • func (q *Queries) ReserveCancel(ctx context.Context, arg ReserveCancelParams) error
  • func (q *Queries) ReserveRemove(ctx context.Context, arg ReserveRemoveParams) error
  • func (q *Queries) UpdateReservedItems(ctx context.Context, arg UpdateReservedItemsParams) error
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type ReserveCancelParams
• type ReserveRemoveParams
• type UpdateReservedItemsParams

Types

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type GetBySKURow

type GetBySKURow struct {
	Sku        int32
	TotalCount int32
	Reserved   int32
}

type GetItemsAvailabilityRow

type GetItemsAvailabilityRow struct {
	Sku       int32
	Available int32
}

type Item

type Item struct {
	Sku        int32
	TotalCount int32
	Reserved   int32
	CreatedAt  pgtype.Timestamp
	UpdatedAt  pgtype.Timestamp
}

type NullOrderStatus

type NullOrderStatus struct {
	OrderStatus OrderStatus
	Valid       bool // Valid is true if OrderStatus is not NULL
}

func (*NullOrderStatus) Scan

func (ns *NullOrderStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullOrderStatus) Value

func (ns NullOrderStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Order

type Order struct {
	OrderID   int64
	UserID    int32
	Status    OrderStatus
	CreatedAt pgtype.Timestamp
	UpdatedAt pgtype.Timestamp
}

type OrderStatus

type OrderStatus string

const (
	OrderStatusNew             OrderStatus = "new"
	OrderStatusAwaitingpayment OrderStatus = "awaiting payment"
	OrderStatusFailed          OrderStatus = "failed"
	OrderStatusPayed           OrderStatus = "payed"
	OrderStatusCancelled       OrderStatus = "cancelled"
)

func (*OrderStatus) Scan

func (e *OrderStatus) Scan(src interface{}) error

type OrderStatusChangedEvent

type OrderStatusChangedEvent struct {
	ID      int64
	OrderID int64
	Status  OrderStatus
	At      pgtype.Timestamp
	Sent    bool
}

type OrdersToItem

type OrdersToItem struct {
	ID      int32
	OrderID int64
	ItemSku int32
	Count   int32
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) GetBySKU

func (q *Queries) GetBySKU(ctx context.Context, sku int32) (GetBySKURow, error)

func (*Queries) GetItemsAvailability

func (q *Queries) GetItemsAvailability(ctx context.Context, sku []int32) ([]GetItemsAvailabilityRow, error)

func (*Queries) ReserveCancel

func (q *Queries) ReserveCancel(ctx context.Context, arg ReserveCancelParams) error

func (*Queries) ReserveRemove

func (q *Queries) ReserveRemove(ctx context.Context, arg ReserveRemoveParams) error

func (*Queries) UpdateReservedItems

func (q *Queries) UpdateReservedItems(ctx context.Context, arg UpdateReservedItemsParams) error

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type ReserveCancelParams

type ReserveCancelParams struct {
	Sku   []int32
	Count []int32
}

type ReserveRemoveParams

type ReserveRemoveParams struct {
	Sku   []int32
	Count []int32
}

type UpdateReservedItemsParams

type UpdateReservedItemsParams struct {
	Sku   []int32
	Count []int32
}