repositories

Documentation

Index

• func NewAccountCoinBalanceRepository(db *postgres.DB) *accountCoinBalanceRepository
• func NewAddressRepository(db *postgres.DB) *addressRepository
• func NewValueTransferEventRepository(db *postgres.DB) *valueTransferEventRepository
• func NewWatchedContractRepository(db *postgres.DB) *watchedContractRepository
• type AccountCoinBalanceRepository
• type AddressRepository
• type ValueTransferEventRepository
• type WatchedContractRepository

Functions

func NewAccountCoinBalanceRepository

func NewAccountCoinBalanceRepository(db *postgres.DB) *accountCoinBalanceRepository

func NewAddressRepository

func NewAddressRepository(db *postgres.DB) *addressRepository

func NewValueTransferEventRepository

func NewValueTransferEventRepository(db *postgres.DB) *valueTransferEventRepository

func NewWatchedContractRepository

func NewWatchedContractRepository(db *postgres.DB) *watchedContractRepository

Types

type AccountCoinBalanceRepository

type AccountCoinBalanceRepository interface {
	CreateCoinBalanceRecords(balanceRecords []shared.CoinBalanceRecord) error
}

type AddressRepository

type AddressRepository interface {
	GetAddresses() ([]common.Address, error)
	AddAddress(addr common.Address) error
}

type ValueTransferEventRepository

type ValueTransferEventRepository interface {
	CreateTokenValueTransferRecords(models []models.ValueTransferModel) error
	GetTokenValueTransferRecordsForAccount(address common.Address, firstBlock, lastBlock int64) ([]models.ValueTransferModel, error)
	GetTokenValueTransferRecordsForAccounts(addresses []common.Address, lastBlock int64) (map[common.Address][]models.ValueTransferModel, error)
}

type WatchedContractRepository

type WatchedContractRepository interface {
	GetAddresses() ([]common.Address, error)
	AddAddress(addr common.Address) error
}