store

Documentation

Index

• type BuyTokenTxParams
• type CancelWithdrawTxParams
• type IStore
• type Store
  • func NewStore(pgdb *pgxpool.Pool) *Store
  • func (s *Store) BuyTokenTx(ctx context.Context, qtx *db.Queries, arg *BuyTokenTxParams) (*db.Account, error)
  • func (s *Store) CancelWithdrawTx(ctx context.Context, arg CancelWithdrawTxParams) error
  • func (s *Store) DoUpsertAccountWithTx(ctx context.Context, qtx *db.Queries, arg *UpsertAccountTxParams) (*db.Account, error)
  • func (s *Store) GetConn() *pgxpool.Pool
  • func (s *Store) UpsertAccountTx(ctx context.Context, arg *UpsertAccountTxParams) (*db.Account, error)
  • func (s *Store) WithdrawTx(ctx context.Context, arg WithdrawTxParams) (*db.Withdrawal, error)
• type UpsertAccountTxParams
• type WithdrawTxParams

Types

type BuyTokenTxParams

type BuyTokenTxParams struct {
	Req     *pb.BuyTokenRequest
	BuyerID int64
}

type CancelWithdrawTxParams

type CancelWithdrawTxParams struct {
	WithdrawalId int64
}

type IStore

type IStore interface {
	db.Querier
	UpsertAccountTx(ctx context.Context, arg UpsertAccountTxParams) (*int64, error)
	WithdrawTx(ctx context.Context, arg WithdrawTxParams) (*int64, error)
	CancelWithdrawTx(ctx context.Context, arg CancelWithdrawTxParams) error
}

type Store

type Store struct {
	*db.Queries
	// contains filtered or unexported fields
}

func NewStore

func NewStore(pgdb *pgxpool.Pool) *Store

func (*Store) BuyTokenTx

func (s *Store) BuyTokenTx(
	ctx context.Context,
	qtx *db.Queries,
	arg *BuyTokenTxParams,
) (*db.Account, error)

func (*Store) CancelWithdrawTx

func (s *Store) CancelWithdrawTx(ctx context.Context, arg CancelWithdrawTxParams) error

func (*Store) DoUpsertAccountWithTx

func (s *Store) DoUpsertAccountWithTx(
	ctx context.Context,
	qtx *db.Queries,
	arg *UpsertAccountTxParams,
) (*db.Account, error)

func (*Store) GetConn

func (s *Store) GetConn() *pgxpool.Pool

func (*Store) UpsertAccountTx

func (s *Store) UpsertAccountTx(ctx context.Context, arg *UpsertAccountTxParams) (*db.Account, error)

func (*Store) WithdrawTx

func (s *Store) WithdrawTx(ctx context.Context, arg WithdrawTxParams) (*db.Withdrawal, error)

Account is not deleted even if all balance is withdrawn. Account is only deleted when expire_time is reached

type UpsertAccountTxParams

type UpsertAccountTxParams struct {
	db.UpsertAccountParams
	Digest string
	Epoch  int64
}

type WithdrawTxParams

type WithdrawTxParams struct {
	db.StartWithdrawalParams
	WithdrawAll bool
}