Documentation ¶
Index ¶
- func GetAssetsJson() (map[string]*OsmosisAsset, error)
- func NewJSONReader(path string, filename string) *jsonReader
- type AcalaAssetSource
- type AnyswapAssetSource
- type AssetSource
- type Assets
- type BalancerV2AssetSource
- type CurvefiAssetSource
- type GRPCClient
- type OrcaAssetSource
- type OsmosisAsset
- type OsmosisAssetResponse
- type OsmosisAssetSource
- type PlatypusAssetSource
- type PlatypusCoin
- type SerumAssetSource
- type SerumPair
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAssetsJson ¶ added in v1.4.242
func GetAssetsJson() (map[string]*OsmosisAsset, error)
func NewJSONReader ¶
Types ¶
type AcalaAssetSource ¶ added in v1.4.289
type AcalaAssetSource struct { RestClient *gsrpc.SubstrateAPI WsClient *gsrpc.SubstrateAPI SpecVersion int Metadata2 *metadata.Instant Metadata *types.Metadata // contains filtered or unexported fields }
func NewAcalaAssetScraper ¶ added in v1.4.289
func NewAcalaAssetScraper(exchange dia.Exchange) *AcalaAssetSource
func (*AcalaAssetSource) Asset ¶ added in v1.4.289
func (pas *AcalaAssetSource) Asset() chan dia.Asset
func (*AcalaAssetSource) Done ¶ added in v1.4.289
func (pas *AcalaAssetSource) Done() chan bool
type AnyswapAssetSource ¶ added in v1.4.0
type AnyswapAssetSource struct { URL string // contains filtered or unexported fields }
func NewAnyswapAssetSource ¶ added in v1.4.0
func NewAnyswapAssetSource(exchange dia.Exchange) *AnyswapAssetSource
func (*AnyswapAssetSource) Asset ¶ added in v1.4.0
func (sas *AnyswapAssetSource) Asset() chan dia.Asset
func (*AnyswapAssetSource) Done ¶ added in v1.4.0
func (sas *AnyswapAssetSource) Done() chan bool
type AssetSource ¶
type BalancerV2AssetSource ¶ added in v1.4.2
type BalancerV2AssetSource struct { RestClient *ethclient.Client // contains filtered or unexported fields }
func NewBalancerV2AssetSource ¶ added in v1.4.2
func NewBalancerV2AssetSource(exchange dia.Exchange) (bas *BalancerV2AssetSource)
func (*BalancerV2AssetSource) Asset ¶ added in v1.4.2
func (bas *BalancerV2AssetSource) Asset() chan dia.Asset
func (*BalancerV2AssetSource) Done ¶ added in v1.4.2
func (bas *BalancerV2AssetSource) Done() chan bool
type CurvefiAssetSource ¶ added in v1.4.2
type CurvefiAssetSource struct { RestClient *ethclient.Client // contains filtered or unexported fields }
CurvefiAssetSource is a curve finance scraper on a specific blockchain.
func NewCurvefiAssetSource ¶ added in v1.4.2
func NewCurvefiAssetSource(exchange dia.Exchange) *CurvefiAssetSource
func (*CurvefiAssetSource) Asset ¶ added in v1.4.2
func (cas *CurvefiAssetSource) Asset() chan dia.Asset
func (*CurvefiAssetSource) Done ¶ added in v1.4.2
func (cas *CurvefiAssetSource) Done() chan bool
type GRPCClient ¶ added in v1.4.242
type GRPCClient struct {
// contains filtered or unexported fields
}
func NewGRPCClient ¶ added in v1.4.242
func NewGRPCClient(conf *scrapers.OsmosisConfig) (*GRPCClient, error)
type OrcaAssetSource ¶ added in v1.4.88
The scraper object for Orca.
func NewOrcaScraper ¶ added in v1.4.88
func NewOrcaScraper(exchange dia.Exchange) *OrcaAssetSource
Returns a new Orca asset scraper.
func (*OrcaAssetSource) Asset ¶ added in v1.4.88
func (pas *OrcaAssetSource) Asset() chan dia.Asset
func (*OrcaAssetSource) Done ¶ added in v1.4.88
func (pas *OrcaAssetSource) Done() chan bool
type OsmosisAsset ¶ added in v1.4.242
type OsmosisAssetResponse ¶ added in v1.4.242
type OsmosisAssetResponse struct {
Assets *[]OsmosisAsset
}
type OsmosisAssetSource ¶ added in v1.4.242
type OsmosisAssetSource struct { GRPCClient *GRPCClient // contains filtered or unexported fields }
The scraper object for Osmosis.
func NewOsmosisScraper ¶ added in v1.4.242
func NewOsmosisScraper(exchange dia.Exchange) *OsmosisAssetSource
Returns a new Osmosis asset scraper.
func (*OsmosisAssetSource) Asset ¶ added in v1.4.242
func (oas *OsmosisAssetSource) Asset() chan dia.Asset
func (*OsmosisAssetSource) Done ¶ added in v1.4.242
func (oas *OsmosisAssetSource) Done() chan bool
type PlatypusAssetSource ¶ added in v1.4.2
type PlatypusAssetSource struct { RestClient *ethclient.Client // contains filtered or unexported fields }
The scraper object for Platypus Finance.
func NewPlatypusScraper ¶ added in v1.4.2
func NewPlatypusScraper(exchange dia.Exchange) *PlatypusAssetSource
Returns a new platypus asset scraper.
func (*PlatypusAssetSource) Asset ¶ added in v1.4.2
func (pas *PlatypusAssetSource) Asset() chan dia.Asset
func (*PlatypusAssetSource) Done ¶ added in v1.4.2
func (pas *PlatypusAssetSource) Done() chan bool
type PlatypusCoin ¶ added in v1.4.2
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 ¶ added in v1.4.0
func (sas *SerumAssetSource) Done() chan bool
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 ¶ added in v1.4.0
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 UniswapV3AssetSource ¶ added in v1.4.2
type UniswapV3AssetSource struct { RestClient *ethclient.Client WsClient *ethclient.Client // contains filtered or unexported fields }
func NewUniswapV3AssetSource ¶ added in v1.4.2
func NewUniswapV3AssetSource(exchange dia.Exchange) *UniswapV3AssetSource
NewUniswapV3AssetSource returns a new UniswapV3AssetSource
func (*UniswapV3AssetSource) Asset ¶ added in v1.4.2
func (uas *UniswapV3AssetSource) Asset() chan dia.Asset
func (*UniswapV3AssetSource) Done ¶ added in v1.4.2
func (uas *UniswapV3AssetSource) Done() chan bool
func (*UniswapV3AssetSource) GetAssetFromAddress ¶ added in v1.4.2
Click to show internal directories.
Click to hide internal directories.