liquidityscrapers

Documentation

Index

• type BalancerV2Scraper
  • func NewBalancerV2Scraper(exchange dia.Exchange) *BalancerV2Scraper
  • func (scraper *BalancerV2Scraper) Done() chan bool
  • func (scraper *BalancerV2Scraper) Pool() chan dia.Pool
• type CurveFIScraper
  • func NewCurveFIScraper(exchange dia.Exchange) *CurveFIScraper
  • func (scraper *CurveFIScraper) Done() chan bool
  • func (scraper *CurveFIScraper) Pool() chan dia.Pool
• type LiquidityScraper
  • func NewLiquidityScraper(source string) LiquidityScraper
• type UniswapPair
• type UniswapScraper
  • func NewUniswapScraper(exchange dia.Exchange) (us *UniswapScraper)
  • func (us *UniswapScraper) Done() chan bool
  • func (us *UniswapScraper) GetDecimals(tokenAddress common.Address) (decimals uint8, err error)
  • 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)
  • func (us *UniswapScraper) Pool() chan dia.Pool
• type UniswapV3Scraper
  • func NewUniswapV3Scraper(exchange dia.Exchange) *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

Types

type BalancerV2Scraper

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

func NewBalancerV2Scraper

func NewBalancerV2Scraper(exchange dia.Exchange) *BalancerV2Scraper

NewBalancerV2Scraper returns a Balancer V2 scraper

func (*BalancerV2Scraper) Done

func (scraper *BalancerV2Scraper) Done() chan bool

func (*BalancerV2Scraper) Pool

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

type CurveFIScraper

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

func NewCurveFIScraper

func NewCurveFIScraper(exchange dia.Exchange) *CurveFIScraper

func (*CurveFIScraper) Done

func (scraper *CurveFIScraper) Done() chan bool

func (*CurveFIScraper) Pool

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

type LiquidityScraper

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

func NewLiquidityScraper

func NewLiquidityScraper(source string) LiquidityScraper

NewLiquidityScraper returns a liquidity scraper for @source.

type UniswapPair

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

type UniswapScraper

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

func NewUniswapScraper

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

func (*UniswapScraper) Done

func (us *UniswapScraper) Done() chan bool

func (*UniswapScraper) GetDecimals

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

GetDecimals returns the decimals of the token with address @tokenAddress

func (*UniswapScraper) GetName

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

func (*UniswapScraper) GetPoolByAddress

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

func (*UniswapScraper) GetPoolByID

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

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

func (*UniswapScraper) Pool

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

type UniswapV3Scraper

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

func NewUniswapV3Scraper

func NewUniswapV3Scraper(exchange dia.Exchange) *UniswapV3Scraper

NewUniswapV3Scraper returns a new UniswapV3Scraper.

func (*UniswapV3Scraper) Done

func (uas *UniswapV3Scraper) Done() chan bool

func (*UniswapV3Scraper) GetAssetFromAddress

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

func (*UniswapV3Scraper) Pool

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