db

package
v0.0.0-...-4658266 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 29, 2021 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Account 

type Account struct {
	ID          int64     `json:"id"`
	Owner       string    `json:"owner"`
	Citizenship string    `json:"citizenship"`
	Balance     int64     `json:"balance"`
	Currency    string    `json:"currency"`
	CreatedAt   time.Time `json:"createdAt"`
}

type AddAccountBalanceParams 

type AddAccountBalanceParams struct {
	Amount int64 `json:"amount"`
	ID     int64 `json:"id"`
}

type CreateAccountParams 

type CreateAccountParams struct {
	Owner       string `json:"owner"`
	Balance     int64  `json:"balance"`
	Currency    string `json:"currency"`
	Citizenship string `json:"citizenship"`
}

type CreateEntryParams 

type CreateEntryParams struct {
	AccountID int64 `json:"accountID"`
	Amount    int64 `json:"amount"`
}

type CreateTransferParams 

type CreateTransferParams struct {
	FromAccountID int64 `json:"fromAccountID"`
	ToAccountID   int64 `json:"toAccountID"`
	Amount        int64 `json:"amount"`
}

type CreateTransferPspParams 

type CreateTransferPspParams struct {
	AccountID    int64 `json:"accountID"`
	PspAccountID int64 `json:"pspAccountID"`
	Amount       int64 `json:"amount"`
}

type CreateUserParams 

type CreateUserParams struct {
	Username       string `json:"username"`
	HashedPassword string `json:"hashedPassword"`
	FullName       string `json:"fullName"`
	Email          string `json:"email"`
	Citizenship    string `json:"citizenship"`
}

type DBTX 

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type Entry 

type Entry struct {
	ID        int64 `json:"id"`
	AccountID int64 `json:"accountID"`
	// can be negative or positive
	Amount    int64     `json:"amount"`
	CreatedAt time.Time `json:"createdAt"`
}

type ListAccountsParams 

type ListAccountsParams struct {
	Owner  string `json:"owner"`
	Limit  int32  `json:"limit"`
	Offset int32  `json:"offset"`
}

type ListEntriesParams 

type ListEntriesParams struct {
	AccountID int64 `json:"accountID"`
	Limit     int32 `json:"limit"`
	Offset    int32 `json:"offset"`
}

type ListTransfersParams 

type ListTransfersParams struct {
	FromAccountID int64 `json:"fromAccountID"`
	ToAccountID   int64 `json:"toAccountID"`
	Limit         int32 `json:"limit"`
	Offset        int32 `json:"offset"`
}

type ListTransfersPspParams 

type ListTransfersPspParams struct {
	AccountID    int64 `json:"accountID"`
	PspAccountID int64 `json:"pspAccountID"`
	Limit        int32 `json:"limit"`
	Offset       int32 `json:"offset"`
}

type Querier 

type Querier interface {
	AddAccountBalance(ctx context.Context, arg AddAccountBalanceParams) (Account, error)
	CreateAccount(ctx context.Context, arg CreateAccountParams) (Account, error)
	CreateEntry(ctx context.Context, arg CreateEntryParams) (Entry, error)
	CreateTransfer(ctx context.Context, arg CreateTransferParams) (Transfer, error)
	CreateTransferPsp(ctx context.Context, arg CreateTransferPspParams) (TransfersPsp, error)
	CreateUser(ctx context.Context, arg CreateUserParams) (User, error)
	DeleteAccount(ctx context.Context, id int64) error
	GetAccount(ctx context.Context, id int64) (Account, error)
	GetAccountByC(ctx context.Context, citizenship string) (Account, error)
	GetAccountForUpdate(ctx context.Context, id int64) (Account, error)
	GetEntry(ctx context.Context, id int64) (Entry, error)
	GetTransfer(ctx context.Context, id int64) (Transfer, error)
	GetTransferPsp(ctx context.Context, id int64) (TransfersPsp, error)
	GetUser(ctx context.Context, username string) (User, error)
	ListAccounts(ctx context.Context, arg ListAccountsParams) ([]Account, error)
	ListEntries(ctx context.Context, arg ListEntriesParams) ([]Entry, error)
	ListTransfers(ctx context.Context, arg ListTransfersParams) ([]Transfer, error)
	ListTransfersPsp(ctx context.Context, arg ListTransfersPspParams) ([]TransfersPsp, error)
	UpdateAccount(ctx context.Context, arg UpdateAccountParams) (Account, error)
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) AddAccountBalance 

func (q *Queries) AddAccountBalance(ctx context.Context, arg AddAccountBalanceParams) (Account, error)

func (*Queries) CreateAccount 

func (q *Queries) CreateAccount(ctx context.Context, arg CreateAccountParams) (Account, error)

func (*Queries) CreateEntry 

func (q *Queries) CreateEntry(ctx context.Context, arg CreateEntryParams) (Entry, error)

func (*Queries) CreateTransfer 

func (q *Queries) CreateTransfer(ctx context.Context, arg CreateTransferParams) (Transfer, error)

func (*Queries) CreateTransferPsp 

func (q *Queries) CreateTransferPsp(ctx context.Context, arg CreateTransferPspParams) (TransfersPsp, error)

func (*Queries) CreateUser 

func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error)

func (*Queries) DeleteAccount 

func (q *Queries) DeleteAccount(ctx context.Context, id int64) error

func (*Queries) GetAccount 

func (q *Queries) GetAccount(ctx context.Context, id int64) (Account, error)

func (*Queries) GetAccountByC 

func (q *Queries) GetAccountByC(ctx context.Context, citizenship string) (Account, error)

func (*Queries) GetAccountForUpdate 

func (q *Queries) GetAccountForUpdate(ctx context.Context, id int64) (Account, error)

func (*Queries) GetEntry 

func (q *Queries) GetEntry(ctx context.Context, id int64) (Entry, error)

func (*Queries) GetTransfer 

func (q *Queries) GetTransfer(ctx context.Context, id int64) (Transfer, error)

func (*Queries) GetTransferPsp 

func (q *Queries) GetTransferPsp(ctx context.Context, id int64) (TransfersPsp, error)

func (*Queries) GetUser 

func (q *Queries) GetUser(ctx context.Context, username string) (User, error)

func (*Queries) ListAccounts 

func (q *Queries) ListAccounts(ctx context.Context, arg ListAccountsParams) ([]Account, error)

func (*Queries) ListEntries 

func (q *Queries) ListEntries(ctx context.Context, arg ListEntriesParams) ([]Entry, error)

func (*Queries) ListTransfers 

func (q *Queries) ListTransfers(ctx context.Context, arg ListTransfersParams) ([]Transfer, error)

func (*Queries) ListTransfersPsp 

func (q *Queries) ListTransfersPsp(ctx context.Context, arg ListTransfersPspParams) ([]TransfersPsp, error)

func (*Queries) UpdateAccount 

func (q *Queries) UpdateAccount(ctx context.Context, arg UpdateAccountParams) (Account, error)

func (*Queries) WithTx 

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

type ReceivePspTxParams 

type ReceivePspTxParams struct {
	AccountID    int64 `json:"accountID"`
	PspAccountID int64 `json:"bankAccountID"`
	Amount       int64 `json:"amount"`
}

TransferTxParams contains the input parameters of the transfer transaction

type ReceivePspTxResult 

type ReceivePspTxResult struct {
	Transfer  TransfersPsp `json:"transfer"`
	ToAccount Account      `json:"to_account"`
}

TransferTXResult is the result of the transfer transaction

type SQLStore 

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

SQLStore provides all functions to execute db queries and transactions

func (*SQLStore) ReceivePspTx 

func (store *SQLStore) ReceivePspTx(ctx context.Context, arg ReceivePspTxParams) (ReceivePspTxResult, error)

TransferTx performs a money transfer from one account to the other. It creates a transfer record, add account entries and update account balance within a single database transaction

func (*SQLStore) TransferPspTx 

func (store *SQLStore) TransferPspTx(ctx context.Context, arg TransferPspTxParams) (TransferPspTxResult, error)

TransferTx performs a money transfer from one account to the other. It creates a transfer record, add account entries and update account balance within a single database transaction

func (*SQLStore) TransferTx 

func (store *SQLStore) TransferTx(ctx context.Context, arg TransferTxParams) (TransferTxResult, error)

TransferTx performs a money transfer from one account to the other. It creates a transfer record, add account entries and update account balance within a single database transaction

type Store 

type Store interface {
	Querier
	TransferTx(ctx context.Context, arg TransferTxParams) (TransferTxResult, error)
	TransferPspTx(ctx context.Context, arg TransferPspTxParams) (TransferPspTxResult, error)
	ReceivePspTx(ctx context.Context, arg ReceivePspTxParams) (ReceivePspTxResult, error)
}

func NewStore 

func NewStore(db *sql.DB) Store

NewStore creates a new store

type Transfer 

type Transfer struct {
	ID            int64 `json:"id"`
	FromAccountID int64 `json:"fromAccountID"`
	ToAccountID   int64 `json:"toAccountID"`
	// must be positive
	Amount    int64     `json:"amount"`
	CreatedAt time.Time `json:"createdAt"`
}

type TransferPspTxParams 

type TransferPspTxParams struct {
	AccountID    int64 `json:"account_id"`
	PspAccountID int64 `json:"PspAccount_id"`
	Amount       int64 `json:"amount"`
}

TransferTxParams contains the input parameters of the transfer transaction

type TransferPspTxResult 

type TransferPspTxResult struct {
	Transfer    TransfersPsp `json:"transfer"`
	FromAccount Account      `json:"from_account"`
}

TransferTXResult is the result of the transfer transaction

type TransferTxParams 

type TransferTxParams struct {
	FromAccountID int64 `json:"from_account_id"`
	ToAccountID   int64 `json:"to_account_id"`
	Amount        int64 `json:"amount"`
}

TransferTxParams contains the input parameters of the transfer transaction

type TransferTxResult 

type TransferTxResult struct {
	Transfer    Transfer `json:"transfer"`
	FromAccount Account  `json:"from_account"`
	ToAccount   Account  `json:"to_account"`
	FromEntry   Entry    `json:"from_entry"`
	ToEntry     Entry    `json:"to_entry"`
}

TransferTXResult is the result of the transfer transaction

type TransfersPsp 

type TransfersPsp struct {
	ID           int64     `json:"id"`
	AccountID    int64     `json:"accountID"`
	PspAccountID int64     `json:"pspAccountID"`
	Amount       int64     `json:"amount"`
	CreatedAt    time.Time `json:"createdAt"`
}

type UpdateAccountParams 

type UpdateAccountParams struct {
	ID      int64 `json:"id"`
	Balance int64 `json:"balance"`
}

type User 

type User struct {
	Username          string    `json:"username"`
	HashedPassword    string    `json:"hashedPassword"`
	FullName          string    `json:"fullName"`
	Email             string    `json:"email"`
	Citizenship       string    `json:"citizenship"`
	PasswordChangedAt time.Time `json:"passwordChangedAt"`
	CreatedAt         time.Time `json:"createdAt"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.