liquidityscrapers

package

v1.4.1-rc-318 Latest Latest Go to latest Published: Aug 18, 2022 License: GPL-2.0 Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type BalancerV2Scraper struct {
	RestClient *ethclient.Client
	// contains filtered or unexported fields
}

func NewBalancerV2Scraper(exchange dia.Exchange) *BalancerV2Scraper

NewBalancerV2Scraper returns a Balancer V2 scraper

func (scraper *BalancerV2Scraper) Done() chan bool

func (scraper *BalancerV2Scraper) Pool() chan dia.Pool

type CurveFIScraper struct {
	RestClient *ethclient.Client
	// contains filtered or unexported fields
}

func NewCurveFIScraper(exchange dia.Exchange) *CurveFIScraper

func (scraper *CurveFIScraper) Done() chan bool

func (scraper *CurveFIScraper) Pool() chan dia.Pool

type LiquidityScraper interface {
	Pool() chan dia.Pool
	Done() chan bool
}

func NewLiquidityScraper(source string) LiquidityScraper

NewLiquidityScraper returns a liquidity scraper for @source.

type UniswapPair struct {
	Token0      dia.Asset
	Token1      dia.Asset
	ForeignName string
	Address     common.Address
}

type UniswapScraper struct {
	RestClient *ethclient.Client
	// contains filtered or unexported fields
}

func NewUniswapScraper(exchange dia.Exchange) (us *UniswapScraper)

func (us *UniswapScraper) Done() chan bool

func (us *UniswapScraper) GetDecimals(tokenAddress common.Address) (decimals uint8, err error)

GetDecimals returns the decimals of the token with address @tokenAddress

func (us *UniswapScraper) GetName(tokenAddress common.Address) (name string, err error)

func (us *UniswapScraper) GetPoolByAddress(pairAddress common.Address) (pool dia.Pool, err error)

func (us *UniswapScraper) GetPoolByID(num int64) (dia.Pool, error)

GetPoolByID returns the Uniswap Pool with the integer id @num.

func (us *UniswapScraper) Pool() chan dia.Pool

type UniswapV3Scraper struct {
	RestClient *ethclient.Client
	WsClient   *ethclient.Client
	// contains filtered or unexported fields
}

func NewUniswapV3Scraper(exchange dia.Exchange) *UniswapV3Scraper

NewUniswapV3Scraper returns a new UniswapV3Scraper.

func (uas *UniswapV3Scraper) Done() chan bool

func (uls *UniswapV3Scraper) GetAssetFromAddress(address common.Address) (asset dia.Asset, err error)

func (uas *UniswapV3Scraper) Pool() chan dia.Pool