stakes

Documentation

Index

• type DB
  • func NewDB(conn *pgxpool.Pool) *DB
  • func (db *DB) GetStakeByLatestStake(ctx context.Context) (*string, error)
  • func (db *DB) GetStakes(ctx context.Context, walletID []byte) ([]*dto.Stake, error)
  • func (db *DB) GetStakesByWalletID(ctx context.Context, walletID string) ([]*entry.Stake, error)
  • func (db *DB) GetStakesByWorldID(ctx context.Context, worldID umid.UMID) ([]*entry.Stake, error)
  • func (db *DB) GetStakesWithCount(ctx context.Context) ([]*entry.Stake, error)
  • func (db *DB) GetWalletsInfo(ctx context.Context, walletIDs [][]byte) ([]*dto.WalletInfo, error)
  • func (db *DB) InsertIntoPendingStakes(ctx context.Context, transactionID []byte, objectID umid.UMID, walletID []byte, ...) error

Types

type DB

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

func NewDB

func NewDB(conn *pgxpool.Pool) *DB

func (*DB) GetStakeByLatestStake

func (db *DB) GetStakeByLatestStake(ctx context.Context) (*string, error)

func (*DB) GetStakes

func (db *DB) GetStakes(ctx context.Context, walletID []byte) ([]*dto.Stake, error)

func (*DB) GetStakesByWalletID

func (db *DB) GetStakesByWalletID(ctx context.Context, walletID string) ([]*entry.Stake, error)

func (*DB) GetStakesByWorldID

func (db *DB) GetStakesByWorldID(ctx context.Context, worldID umid.UMID) ([]*entry.Stake, error)

func (*DB) GetStakesWithCount

func (db *DB) GetStakesWithCount(ctx context.Context) ([]*entry.Stake, error)

func (*DB) GetWalletsInfo

func (db *DB) GetWalletsInfo(ctx context.Context, walletIDs [][]byte) ([]*dto.WalletInfo, error)

func (*DB) InsertIntoPendingStakes

func (db *DB) InsertIntoPendingStakes(ctx context.Context, transactionID []byte,
	objectID umid.UMID,
	walletID []byte,
	blockchainID umid.UMID,
	amount *big.Int,
	comment string,
	kind uint8) error