history

Documentation

Index

• Constants
• func TimeIntervalDurationSecs(timeInterval TimeInterval) uint64
• type Balance
  • func NewBalance(db *BalanceDB) *Balance
• type BalanceDB
  • func NewBalanceDB(sqlDb *sql.DB) *BalanceDB
• type DataPoint
  • func (d *DataPoint) String() string
• type Exchange
  • func NewExchange(marketManager *market.Manager) *Exchange
  • func (e *Exchange) FetchAndCacheMissingRates(token tokenType, currency currencyType) error
  • func (e *Exchange) GetExchangeRateForDay(token tokenType, currency currencyType, date time.Time) (float32, error)
• type Service
  • func NewService(db *sql.DB, accountsDB *accounts.Database, accountFeed *event.Feed, ...) *Service
  • func (s *Service) GetBalanceHistory(ctx context.Context, chainIDs []uint64, addresses []common.Address, ...) ([]*ValuePoint, error)
  • func (s *Service) Start()
  • func (s *Service) Stop()
• type TimeInterval
• type TransfersLoadedCb
• type ValuePoint
• type Watcher
  • func NewWatcher(feed *event.Feed, callback TransfersLoadedCb) *Watcher
  • func (w *Watcher) Start()
  • func (w *Watcher) Stop()

Constants

const (
	EventBalanceHistoryUpdateStarted           walletevent.EventType = "wallet-balance-history-update-started"
	EventBalanceHistoryUpdateFinished          walletevent.EventType = "wallet-balance-history-update-finished"
	EventBalanceHistoryUpdateFinishedWithError walletevent.EventType = "wallet-balance-history-update-finished-with-error"
)

EventBalanceHistoryUpdateStarted and EventBalanceHistoryUpdateDone are used to notify the UI that balance history is being updated

Functions

func TimeIntervalDurationSecs

func TimeIntervalDurationSecs(timeInterval TimeInterval) uint64

Types

type Balance

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

func NewBalance

func NewBalance(db *BalanceDB) *Balance

type BalanceDB

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

func NewBalanceDB

func NewBalanceDB(sqlDb *sql.DB) *BalanceDB

type DataPoint

type DataPoint struct {
	Balance     *hexutil.Big
	Timestamp   uint64
	BlockNumber *hexutil.Big
}

func (*DataPoint) String

func (d *DataPoint) String() string

String returns a string representation of the data point

type Exchange

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

Exchange caches conversion rates in memory on a daily basis

func NewExchange

func NewExchange(marketManager *market.Manager) *Exchange

func (*Exchange) FetchAndCacheMissingRates

func (e *Exchange) FetchAndCacheMissingRates(token tokenType, currency currencyType) error

fetchAndCacheRates fetches and in memory cache exchange rates for this and last year

func (*Exchange) GetExchangeRateForDay

func (e *Exchange) GetExchangeRateForDay(token tokenType, currency currencyType, date time.Time) (float32, error)

GetExchangeRate returns the exchange rate from token to currency in the day of the given date if none exists returns "missing <element>" error

type Service

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

func NewService

func NewService(db *sql.DB, accountsDB *accounts.Database, accountFeed *event.Feed, eventFeed *event.Feed, rpcClient *statusrpc.Client, tokenManager *token.Manager, marketManager *market.Manager, balanceCache balance.CacheIface) *Service

func (*Service) GetBalanceHistory

func (s *Service) GetBalanceHistory(ctx context.Context, chainIDs []uint64, addresses []common.Address, tokenSymbol string, currencySymbol string, fromTimestamp uint64) ([]*ValuePoint, error)

GetBalanceHistory returns token count balance

func (*Service) Start

func (s *Service) Start()

func (*Service) Stop

func (s *Service) Stop()

type TimeInterval

type TimeInterval int

Specific time intervals for which balance history can be fetched

const (
	BalanceHistory7Days TimeInterval = iota + 1
	BalanceHistory1Month
	BalanceHistory6Months
	BalanceHistory1Year
	BalanceHistoryAllTime
)

type TransfersLoadedCb

type TransfersLoadedCb func(chainID uint64, addresses []common.Address, block *big.Int)

type ValuePoint

type ValuePoint struct {
	Value     float64 `json:"value"`
	Timestamp uint64  `json:"time"`
}

type Watcher

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

Watcher executes a given callback whenever an account gets added/removed

func NewWatcher

func NewWatcher(feed *event.Feed, callback TransfersLoadedCb) *Watcher

func (*Watcher) Start

func (w *Watcher) Start()

func (*Watcher) Stop

func (w *Watcher) Stop()