postgres

Documentation

Index

• type Database
  • func New(logger log.Logger, client postgres.Client) *Database
  • func (db *Database) Ping(ctx context.Context) error
  • func (db *Database) Wallets(storeID string) database.Wallets
• type Wallets
  • func NewWallets(storeID string, db postgres.Client, logger log.Logger) *Wallets
  • func (ea *Wallets) Add(ctx context.Context, account *entities.Wallet) (*entities.Wallet, error)
  • func (ea *Wallets) Delete(ctx context.Context, pubkey string) error
  • func (ea *Wallets) Get(ctx context.Context, pubkey string) (*entities.Wallet, error)
  • func (ea *Wallets) GetAll(ctx context.Context) ([]*entities.Wallet, error)
  • func (ea *Wallets) GetAllDeleted(ctx context.Context) ([]*entities.Wallet, error)
  • func (ea *Wallets) GetDeleted(ctx context.Context, pubkey string) (*entities.Wallet, error)
  • func (ea *Wallets) Purge(ctx context.Context, pubkey string) error
  • func (ea *Wallets) Restore(ctx context.Context, pubkey string) error
  • func (ea *Wallets) RunInTransaction(ctx context.Context, persist func(dbTx database.Wallets) error) error
  • func (ea *Wallets) SearchAddresses(ctx context.Context, isDeleted bool, limit, offset uint64) ([]string, error)
  • func (ea *Wallets) Update(ctx context.Context, account *entities.Wallet) (*entities.Wallet, error)

Types

type Database

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

func New

func New(logger log.Logger, client postgres.Client) *Database

func (*Database) Ping

func (db *Database) Ping(ctx context.Context) error

func (*Database) Wallets

func (db *Database) Wallets(storeID string) database.Wallets

type Wallets

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

func NewWallets

func NewWallets(storeID string, db postgres.Client, logger log.Logger) *Wallets

func (*Wallets) Add

func (ea *Wallets) Add(ctx context.Context, account *entities.Wallet) (*entities.Wallet, error)

func (*Wallets) Delete

func (ea *Wallets) Delete(ctx context.Context, pubkey string) error

func (*Wallets) Get

func (ea *Wallets) Get(ctx context.Context, pubkey string) (*entities.Wallet, error)

func (*Wallets) GetAll

func (ea *Wallets) GetAll(ctx context.Context) ([]*entities.Wallet, error)

func (*Wallets) GetAllDeleted

func (ea *Wallets) GetAllDeleted(ctx context.Context) ([]*entities.Wallet, error)

func (*Wallets) GetDeleted

func (ea *Wallets) GetDeleted(ctx context.Context, pubkey string) (*entities.Wallet, error)

func (*Wallets) Purge

func (ea *Wallets) Purge(ctx context.Context, pubkey string) error

func (*Wallets) Restore

func (ea *Wallets) Restore(ctx context.Context, pubkey string) error

func (*Wallets) RunInTransaction

func (ea *Wallets) RunInTransaction(ctx context.Context, persist func(dbTx database.Wallets) error) error

func (*Wallets) SearchAddresses

func (ea *Wallets) SearchAddresses(ctx context.Context, isDeleted bool, limit, offset uint64) ([]string, error)

func (*Wallets) Update

func (ea *Wallets) Update(ctx context.Context, account *entities.Wallet) (*entities.Wallet, error)