Versions in this module Expand all Collapse all v0 v0.0.1 Nov 1, 2023 Changes in this version + const BLOCK_INTERVAL_SEC + const NA_VALUE + type Price interface + CurrHeight func() (int64, error) + NextHeight func(minHeight uint64) (int64, error) + Run func(height uint64) error + func New(repo SrcRepo, priceToken string, logger logging.Logger) (Price, error) + type SrcRepo interface + CurrHeight func() (int64, error) + Decimals func(asset string) (int64, error) + FirstHeight func(priceToken string) (int64, error) + LatestRouteUpdateTimestamp func() (float64, error) + Liquidity func(height uint64, token string, priceToken string) (string, string, error) + NextHeight func(minHeight uint64) (int64, error) + Route func(endToken string) (map[string][][]string, error) + Txs func(height uint64) ([]schemas.ParsedTx, error) + UpdateDirectPrice func(height uint64, token string, price string, priceToken string, isReverse bool) error + UpdateRoutePrice func(height uint64, token string, price string, priceToken string, route []string) error + func NewRepo(chainId string, dbConfig configs.RdbConfig) SrcRepo
Go to main page