source

Documentation

Index

• func NewJSONReader(path string, filename string) *jsonReader
• type AnyswapAssetSource
  • func NewAnyswapAssetSource(exchange dia.Exchange) *AnyswapAssetSource
  • func (sas *AnyswapAssetSource) Asset() chan dia.Asset
  • func (sas *AnyswapAssetSource) Done() chan bool
• type AssetSource
• type Assets
• type BalancerV2AssetSource
  • func NewBalancerV2AssetSource(exchange dia.Exchange) (bas *BalancerV2AssetSource)
  • func (bas *BalancerV2AssetSource) Asset() chan dia.Asset
  • func (bas *BalancerV2AssetSource) Done() chan bool
• type CurvefiAssetSource
  • func NewCurvefiAssetSource(exchange dia.Exchange) *CurvefiAssetSource
  • func (cas *CurvefiAssetSource) Asset() chan dia.Asset
  • func (cas *CurvefiAssetSource) Done() chan bool
• type SerumAssetSource
  • func NewSerumAssetSource(exchange dia.Exchange) *SerumAssetSource
  • func (sas *SerumAssetSource) Asset() chan dia.Asset
  • func (sas *SerumAssetSource) Done() chan bool
• type SerumPair
• type UniswapAssetSource
  • func NewUniswapAssetSource(exchange dia.Exchange) (uas *UniswapAssetSource)
  • func (uas *UniswapAssetSource) Asset() chan dia.Asset
  • func (uas *UniswapAssetSource) Done() chan bool
  • func (uas *UniswapAssetSource) GetDecimals(tokenAddress common.Address) (decimals uint8, err error)
  • func (uas *UniswapAssetSource) GetName(tokenAddress common.Address) (name string, err error)
  • func (uas *UniswapAssetSource) GetPairByAddress(pairAddress common.Address) (pair UniswapPair, err error)
  • func (uas *UniswapAssetSource) GetPairByID(num int64) (UniswapPair, error)
• type UniswapPair
• type UniswapV3AssetSource
  • func NewUniswapV3AssetSource(exchange dia.Exchange) *UniswapV3AssetSource
  • func (uas *UniswapV3AssetSource) Asset() chan dia.Asset
  • func (uas *UniswapV3AssetSource) Done() chan bool
  • func (uas *UniswapV3AssetSource) GetAssetFromAddress(address common.Address) (asset dia.Asset, err error)

Functions

func NewJSONReader

func NewJSONReader(path string, filename string) *jsonReader

Types

type AnyswapAssetSource

type AnyswapAssetSource struct {
	URL string
	// contains filtered or unexported fields
}

func NewAnyswapAssetSource

func NewAnyswapAssetSource(exchange dia.Exchange) *AnyswapAssetSource

func (*AnyswapAssetSource) Asset

func (sas *AnyswapAssetSource) Asset() chan dia.Asset

func (*AnyswapAssetSource) Done

func (sas *AnyswapAssetSource) Done() chan bool

type AssetSource

type AssetSource interface {
	Asset() chan dia.Asset
	Done() chan bool
}

type Assets

type Assets struct {
	Assets []dia.Asset `json:"Assets"`
}

type BalancerV2AssetSource

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

func NewBalancerV2AssetSource

func NewBalancerV2AssetSource(exchange dia.Exchange) (bas *BalancerV2AssetSource)

func (*BalancerV2AssetSource) Asset

func (bas *BalancerV2AssetSource) Asset() chan dia.Asset

func (*BalancerV2AssetSource) Done

func (bas *BalancerV2AssetSource) Done() chan bool

type CurvefiAssetSource

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

CurvefiAssetSource is a curve finance scraper on a specific blockchain.

func NewCurvefiAssetSource

func NewCurvefiAssetSource(exchange dia.Exchange) *CurvefiAssetSource

func (*CurvefiAssetSource) Asset

func (cas *CurvefiAssetSource) Asset() chan dia.Asset

func (*CurvefiAssetSource) Done

func (cas *CurvefiAssetSource) Done() chan bool

type SerumAssetSource

type SerumAssetSource struct {
	// contains filtered or unexported fields
}

func NewSerumAssetSource

func NewSerumAssetSource(exchange dia.Exchange) *SerumAssetSource

func (*SerumAssetSource) Asset

func (sas *SerumAssetSource) Asset() chan dia.Asset

func (*SerumAssetSource) Done

func (sas *SerumAssetSource) Done() chan bool

type SerumPair

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

type UniswapAssetSource

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

func NewUniswapAssetSource

func NewUniswapAssetSource(exchange dia.Exchange) (uas *UniswapAssetSource)

func (*UniswapAssetSource) Asset

func (uas *UniswapAssetSource) Asset() chan dia.Asset

func (*UniswapAssetSource) Done

func (uas *UniswapAssetSource) Done() chan bool

func (*UniswapAssetSource) GetDecimals

func (uas *UniswapAssetSource) GetDecimals(tokenAddress common.Address) (decimals uint8, err error)

GetDecimals returns the decimals of the token with address @tokenAddress

func (*UniswapAssetSource) GetName

func (uas *UniswapAssetSource) GetName(tokenAddress common.Address) (name string, err error)

func (*UniswapAssetSource) GetPairByAddress

func (uas *UniswapAssetSource) GetPairByAddress(pairAddress common.Address) (pair UniswapPair, err error)

func (*UniswapAssetSource) GetPairByID

func (uas *UniswapAssetSource) GetPairByID(num int64) (UniswapPair, error)

GetPairByID returns the UniswapPair with the integer id @num

type UniswapPair

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

type UniswapV3AssetSource

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

func NewUniswapV3AssetSource

func NewUniswapV3AssetSource(exchange dia.Exchange) *UniswapV3AssetSource

NewUniswapV3AssetSource returns a new UniswapV3AssetSource

func (*UniswapV3AssetSource) Asset

func (uas *UniswapV3AssetSource) Asset() chan dia.Asset

func (*UniswapV3AssetSource) Done

func (uas *UniswapV3AssetSource) Done() chan bool

func (*UniswapV3AssetSource) GetAssetFromAddress

func (uas *UniswapV3AssetSource) GetAssetFromAddress(address common.Address) (asset dia.Asset, err error)