liquidityscrapers

package

v1.4.1-rc-281 Latest Latest Go to latest Published: Jul 29, 2022 License: GPL-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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