price

Documentation

Index

• Constants
• type Price
  • func New(repo SrcRepo, priceToken string, logger logging.Logger) (Price, error)
• type SrcRepo
  • func NewRepo(chainId string, dbConfig configs.RdbConfig) SrcRepo

Constants

const BLOCK_INTERVAL_SEC = 5

const NA_VALUE = int64(-1)

Types

type Price

type Price interface {
	CurrHeight() (int64, error)
	NextHeight(minHeight uint64) (int64, error)
	Run(height uint64) error
}

func New

func New(repo SrcRepo, priceToken string, logger logging.Logger) (Price, error)

type SrcRepo

type SrcRepo interface {
	FirstHeight(priceToken string) (int64, error)
	CurrHeight() (int64, error)
	NextHeight(minHeight uint64) (int64, error)
	Txs(height uint64) ([]schemas.ParsedTx, error)
	Decimals(asset string) (int64, error)
	LatestRouteUpdateTimestamp() (float64, error)
	Route(endToken string) (map[string][][]string, error)
	Liquidity(height uint64, token string, priceToken string) (string, string, error)
	UpdateDirectPrice(height uint64, token string, price string, priceToken string, isReverse bool) error
	UpdateRoutePrice(height uint64, token string, price string, priceToken string, route []string) error
}

func NewRepo

func NewRepo(chainId string, dbConfig configs.RdbConfig) SrcRepo