postgres

Documentation

Index

• func NewDB(ctx context.Context, dsn string) (*pgxpool.Pool, error)
• type AccountStorage
  • func NewAccountStorage(db *pgxpool.Pool) *AccountStorage
  • func NewAccountTxStorage(db *pgxpool.Pool) *AccountStorage
  • func (s *AccountStorage) CreateAccount(ctx context.Context, acc account.Account) error
  • func (s *AccountStorage) GetAccount(ctx context.Context, id ulid.ULID) (*account.Account, error)
• type AccountTxStorage
  • func (a *AccountTxStorage) GetAllByDateRange(ctx context.Context, id ulid.ULID, from, to time.Time) ([]transfer.Transaction, error)
  • func (a *AccountTxStorage) GetAllFromAccount(ctx context.Context, id ulid.ULID) ([]transfer.Transaction, error)
• type TxStorage
  • func NewTxStorage(db *pgxpool.Pool) *TxStorage
  • func (s *TxStorage) CreateTx(ctx context.Context, t transfer.Transaction) error
  • func (s *TxStorage) GetTx(ctx context.Context, id ulid.ULID) (*transfer.Transaction, error)

Functions

func NewDB

func NewDB(ctx context.Context, dsn string) (*pgxpool.Pool, error)

Types

type AccountStorage

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

func NewAccountStorage

func NewAccountStorage(db *pgxpool.Pool) *AccountStorage

func NewAccountTxStorage

func NewAccountTxStorage(db *pgxpool.Pool) *AccountStorage

func (*AccountStorage) CreateAccount

func (s *AccountStorage) CreateAccount(ctx context.Context, acc account.Account) error

func (*AccountStorage) GetAccount

func (s *AccountStorage) GetAccount(ctx context.Context, id ulid.ULID) (*account.Account, error)

type AccountTxStorage

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

func (*AccountTxStorage) GetAllByDateRange

func (a *AccountTxStorage) GetAllByDateRange(ctx context.Context, id ulid.ULID, from, to time.Time) ([]transfer.Transaction, error)

func (*AccountTxStorage) GetAllFromAccount

func (a *AccountTxStorage) GetAllFromAccount(ctx context.Context, id ulid.ULID) ([]transfer.Transaction, error)

type TxStorage

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

func NewTxStorage

func NewTxStorage(db *pgxpool.Pool) *TxStorage

func (*TxStorage) CreateTx

func (s *TxStorage) CreateTx(ctx context.Context, t transfer.Transaction) error

func (*TxStorage) GetTx

func (s *TxStorage) GetTx(ctx context.Context, id ulid.ULID) (*transfer.Transaction, error)