scrapers

package
v1.4.533 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 20, 2024 License: GPL-2.0 Imports: 113 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ChannelHeartbeat = "heartbeat"
	ChannelTicker    = "ticker"
	ChannelLevel2    = "level2"
	ChannelUser      = "user"
	ChannelMatches   = "matches"
	ChannelFull      = "full"
)
View Source 
const (
	OrcaProgWhirlpoolConfigAddr      = "2LecshUwdy9xi7meFgHtFJQNSKk4KdTrcpvaB56dP2NQ"
	OrcaProgWhirlpoolAddr            = "whirLbMiicVdio4qvUfM5KAg6Ct8VwpYzGff3uctyCc"
	OrcaProgWhirlpoolAccountDataSize = 653
	OrcaMaxRetries                   = 5
	OrcaRetryDelay                   = 3 * time.Second
)
View Source 
const (
	BinanceUSWsURL = "wss://stream.binance.us:9443/ws"
)

Variables

View Source 
var (
	Exchanges          = make(map[string]dia.Exchange)
	ExchangeDuplicates = make(map[string]dia.Exchange)
	Blockchains        map[string]dia.BlockChain
)
View Source 
var (
	TraderJoeExchangeFactoryContractAddress = "0x5C69bEe701ef814a2B6a3EDD4B1652CB9cc5aA6f"

	MapOfPools = make(map[string]TraderJoePair)
)
View Source 
var (
	NodeScriptPathBifrostKusama   = utils.Getenv("PATH_TO_NODE_SCRIPT", "scripts/bifrost/main.js")
	NodeScriptPathBifrostPolkadot = utils.Getenv("PATH_TO_NODE_SCRIPT", "scripts/bifrost/zenlink-bifrost-polkadot.js")
)
View Source 
var ByBitSocketURL string = "wss://stream.bybit.com/spot/public/v3"

Functions

func DecodeTx added in v1.4.242 

func DecodeTx(encoding OsmosisEncodingConfig, rawTx interface{}) (sdk.Tx, error)

DecodeTx will attempt to decode a raw transaction in the form of a base64 encoded string or a protobuf encoded byte slice

func FloatToString 

func FloatToString(input_num float64) string

func FormatUint64Decimals added in v1.4.81 

func FormatUint64Decimals(value uint64, decimals int) (valueFormatted float64)

Format a uint64 to a float64 with the given number of decimals

func GetDecimals added in v1.4.2 

func GetDecimals(tokenAddress common.Address, chainid string) (decimals uint8, err error)

func GetName added in v1.4.2 

func GetName(tokenAddress common.Address, chainid string) (name string, err error)

func GetOrcaTokensMetadata added in v1.4.88 

func GetOrcaTokensMetadata() map[string]interface{}

func GetSymbol added in v1.4.2 

func GetSymbol(tokenAddress common.Address, chainid string) (name string, err error)

func GzipDecode 

func GzipDecode(in []byte) (content []byte, err error)

func InitialiseRestClientsMap added in v1.4.2 

func InitialiseRestClientsMap()

func InitialiseWsClientsMap added in v1.4.2 

func InitialiseWsClientsMap()

func NewRpcClient added in v1.4.242 

func NewRpcClient(conf OsmosisConfig) (*resty.Client, error)

func NewTrade 

func NewTrade(pair dia.ExchangePair, info krakenapi.TradeInfo, foreignTradeID string, relDB *models.RelDB) *dia.Trade

func NewWsClient added in v1.4.242 

func NewWsClient(conf OsmosisConfig) (*tendermint.WSClient, error)

func Populate 

func Populate(datastore *models.DB, rdb *models.RelDB, pairs []string)

Populate fetches historical daily datas from 1999 until today and saves them on the database

func Round 

func Round(x, unit float64) float64

Types

type APIScraper 

type APIScraper interface {
	io.Closer
	// ScrapePair returns a PairScraper that continuously scrapes trades for a
	// single pair from this APIScraper
	ScrapePair(pair dia.ExchangePair) (PairScraper, error)
	// FetchAvailablePairs returns a list with all trading pairs available on
	// the exchange associated to the APIScraper. The format is such that it can
	// be used by the corr. pairScraper in order to fetch trades.
	FetchAvailablePairs() ([]dia.ExchangePair, error)

	// FillSymbolData collects information associated to the symbol ticker of an
	// asset traded on the exchange associated to the APIScraper.
	// Ideally, data is returned as close to original (blockchain) notation as possible.
	// This is only needed for CEX. For DEX the trade can be filled.
	FillSymbolData(symbol string) (dia.Asset, error)

	NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)
	// Channel returns a channel that can be used to receive trades
	Channel() chan *dia.Trade
}

APIScraper provides common methods needed to get Trade information from exchange APIs.

func NewAPIScraper 

func NewAPIScraper(exchange string, scrape bool, key string, secret string, relDB *models.RelDB) APIScraper

NewAPIScraper returns an API scraper for @exchange. If scrape==true it actually does scraping. Otherwise can be used for pairdiscovery.

type AllOKEXMarketResponse 

type AllOKEXMarketResponse struct {
	Code string       `json:"code"`
	Data []OKEXMarket `json:"data"`
	Msg  string       `json:"msg"`
}

type AnyswapPair added in v1.4.0 

type AnyswapPair struct {
	Token0      UniswapToken
	Token1      UniswapToken
	ForeignName string
	Address     common.Address
}

type AnyswapPairScraper added in v1.4.0 

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

UniswapPairScraper implements PairScraper for Uniswap

func (*AnyswapPairScraper) Close added in v1.4.0 

func (ps *AnyswapPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*AnyswapPairScraper) Error added in v1.4.0 

func (ps *AnyswapPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*AnyswapPairScraper) Pair added in v1.4.0 

func (ps *AnyswapPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type AnyswapScraper added in v1.4.0 

type AnyswapScraper struct {
	WsClientMap   map[string]*ethclient.Client
	RestClientMap map[string]*ethclient.Client
	// contains filtered or unexported fields
}

func NewAnyswapScraper added in v1.4.0 

func NewAnyswapScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *AnyswapScraper

NewUniswapScraper returns a new UniswapScraper for the given pair

func (*AnyswapScraper) Channel added in v1.4.0 

func (ps *AnyswapScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*AnyswapScraper) Close added in v1.4.0 

func (s *AnyswapScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*AnyswapScraper) FetchAvailablePairs added in v1.4.0 

func (s *AnyswapScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs as dia.ExchangePair for the pairDiscorvery service

func (*AnyswapScraper) FillSymbolData added in v1.4.0 

func (s *AnyswapScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData is not used by DEX scrapers.

func (*AnyswapScraper) GetSwapOutChannel added in v1.4.0 

func (s *AnyswapScraper) GetSwapOutChannel(tokens []common.Address, chainID string) (chan *anyswap.AnyswapV4RouterLogAnySwapOut, error)

GetSwapOutChannel returns the channel @sink delivering the events LogAnySwapOut.

func (*AnyswapScraper) ListenToChainOut added in v1.4.0 

func (s *AnyswapScraper) ListenToChainOut(chainID string)

ListenToChainOut screens swaps out of the chain with @chainID to any other chain offered by Anyswap.

func (*AnyswapScraper) NormalizePair added in v1.4.0 

func (up *AnyswapScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*AnyswapScraper) ScrapePair added in v1.4.0 

func (s *AnyswapScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type AnyswapSwap added in v1.4.0 

type AnyswapSwap struct {
	ID         string
	Timestamp  int64
	Pair       UniswapPair
	Amount0In  float64
	Amount0Out float64
	Amount1In  float64
	Amount1Out float64
}

type AnyswapToken added in v1.4.0 

type AnyswapToken struct {
	Address  common.Address
	Symbol   string
	Decimals uint8
	Name     string
}

type Attribute added in v1.4.242 

type Attribute struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

Contains info about a transaction log event key/val attribute

type AttributesByEvent added in v1.4.242 

type AttributesByEvent map[string]ValueByAttribute

Contains info about event attributes keyed by event type

type AyinPairScraper added in v1.4.504 

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

func (*AyinPairScraper) Close added in v1.4.504 

func (ps *AyinPairScraper) Close() error

func (*AyinPairScraper) Error added in v1.4.504 

func (ps *AyinPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*AyinPairScraper) Pair added in v1.4.504 

func (ps *AyinPairScraper) Pair() dia.ExchangePair

type AyinScraper added in v1.4.504 

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

func NewAyinScraper added in v1.4.504 

func NewAyinScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *AyinScraper

NewAyinScraper returns a new AyinScraper initialized with default values. The instance is asynchronously scraping as soon as it is created. ENV values: 

	AYIN_REFRESH_DELAY - (optional,millisecond) refresh data after each poll, default "alephiumhelper.DefaultRefreshDelay" value
 	AYIN_SLEEP_TIMEOUT - (optional,millisecond), make timeout between API calls, default "alephiumhelper.DefaultSleepBetweenContractCalls" value
	AYIN_SWAP_CONTRACTS_LIMIT - (optional, int), limit to get swap contact addresses, default "alephiumhelper.DefaultSwapContractsLimit" value
	AYIN_TARGET_SWAP_CONTRACT - (optional, string), useful for debug, default = ""
	AYIN_DEBUG - (optional, bool), make stdout output with alephium client http call, default = false

func (*AyinScraper) Channel added in v1.4.504 

func (s *AyinScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades/pricing information

func (*AyinScraper) Close added in v1.4.504 

func (s *AyinScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*AyinScraper) FetchAvailablePairs added in v1.4.504 

func (s *AyinScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs as dia.ExchangePair for the pairDiscorvery service

func (*AyinScraper) FillSymbolData added in v1.4.504 

func (s *AyinScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*AyinScraper) NormalizePair added in v1.4.504 

func (s *AyinScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*AyinScraper) ScrapePair added in v1.4.504 

func (s *AyinScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

func (*AyinScraper) Update added in v1.4.504 

func (s *AyinScraper) Update() error

type BKEXExchangeInfo added in v1.4.6 

type BKEXExchangeInfo struct {
	Code string               `json:"code"`
	Data []BKEXExchangeSymbol `json:"data"`
}

type BKEXExchangeSymbol added in v1.4.6 

type BKEXExchangeSymbol struct {
	MinimumOrderSize   float64 `json:"minimumOrderSize"`
	MinimumTradeVolume float64 `json:"minimumTradeVolume"`
	PricePrecision     int     `json:"pricePrecision"`
	SupportTrade       bool    `json:"supportTrade"`
	Symbol             string  `json:"symbol"`
	VolumePrecision    int     `json:"volumePrecision"`
}

type BKEXPairScraper added in v1.4.6 

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

BKEXPairScraper implements PairScraper for BKEX

func (*BKEXPairScraper) Close added in v1.4.6 

func (ps *BKEXPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*BKEXPairScraper) Error added in v1.4.6 

func (ps *BKEXPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BKEXPairScraper) Pair added in v1.4.6 

func (ps *BKEXPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BKEXScraper added in v1.4.6 

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

func NewBKEXScraper added in v1.4.6 

func NewBKEXScraper(exchange dia.Exchange, scraperName string, scrape bool, relDB *models.RelDB) *BKEXScraper

func (*BKEXScraper) Channel added in v1.4.6 

func (s *BKEXScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*BKEXScraper) Close added in v1.4.6 

func (s *BKEXScraper) Close() error

func (*BKEXScraper) FetchAvailablePairs added in v1.4.6 

func (s *BKEXScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*BKEXScraper) FillSymbolData added in v1.4.6 

func (s *BKEXScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

FillSymbolData from MEXCScraper @todo more update

func (*BKEXScraper) NormalizePair added in v1.4.6 

func (s *BKEXScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BKEXScraper) ScrapePair added in v1.4.6 

func (s *BKEXScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

type BKEXTradeRecord added in v1.4.6 

type BKEXTradeRecord struct {
	Symbol    string  `json:"symbol"`
	Price     string  `json:"price"`
	Volume    float64 `json:"volume"`
	Direction string  `json:"direction"`
	Ts        int64   `json:"ts"`
}

type BKEXTradeResponse added in v1.4.6 

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

type BalancerV2PairScraper added in v1.4.0 

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

BalancerV2PairScraper implements PairScraper for BalancerV2

func (*BalancerV2PairScraper) Close added in v1.4.0 

func (p *BalancerV2PairScraper) Close() error

Close stops listening for trades of the pair associated with the BalancerV2Scraper

func (*BalancerV2PairScraper) Error added in v1.4.0 

func (p *BalancerV2PairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BalancerV2PairScraper) Pair added in v1.4.0 

func (p *BalancerV2PairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BalancerV2Scraper added in v1.4.0 

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

BalancerV2Scraper is a scraper for Balancer V2

func NewBalancerV2Scraper added in v1.4.0 

func NewBalancerV2Scraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BalancerV2Scraper

NewBalancerV2Scraper returns a Balancer V2 scraper

func (*BalancerV2Scraper) Channel added in v1.4.0 

func (s *BalancerV2Scraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*BalancerV2Scraper) Close added in v1.4.0 

func (s *BalancerV2Scraper) Close() error

Close unsubscribes data and closes any existing WebSocket connections, as well as channels of BalancerV2Scraper

func (*BalancerV2Scraper) FetchAvailablePairs added in v1.4.0 

func (s *BalancerV2Scraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*BalancerV2Scraper) FillSymbolData added in v1.4.0 

func (s *BalancerV2Scraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData adds the name to the asset underlying @symbol on BalancerV2

func (*BalancerV2Scraper) NormalizePair added in v1.4.0 

func (s *BalancerV2Scraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BalancerV2Scraper) ScrapePair added in v1.4.0 

func (s *BalancerV2Scraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from the BalancerV2 scraper

type BalancerV2Swap added in v1.4.0 

type BalancerV2Swap struct {
	SellToken  string
	BuyToken   string
	SellVolume float64
	BuyVolume  float64
	ID         string
	Timestamp  int64
}

BalancerV2Swap is a swap information

type BancorPairScraper 

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

func (*BancorPairScraper) Close 

func (pairScraper *BancorPairScraper) Close() error

func (*BancorPairScraper) Error 

func (pairScraper *BancorPairScraper) Error() error

func (*BancorPairScraper) Pair 

func (pairScraper *BancorPairScraper) Pair() dia.ExchangePair

type BancorPool 

type BancorPool struct {
	Reserves []struct {
		DltID   string `json:"dlt_id"`
		Symbol  string `json:"symbol"`
		Name    string `json:"name"`
		Balance struct {
			Usd string `json:"usd"`
		} `json:"balance"`
		Weight int `json:"weight"`
		Price  struct {
			Usd string `json:"usd"`
		} `json:"price"`
		Price24HAgo struct {
			Usd string `json:"usd"`
		} `json:"price_24h_ago"`
		Volume24H struct {
			Usd  string `json:"usd"`
			Base string `json:"base"`
		} `json:"volume_24h"`
	} `json:"reserves"`
	DltType        string `json:"dlt_type"`
	DltID          string `json:"dlt_id"`
	Type           int    `json:"type"`
	Version        int    `json:"version"`
	Symbol         string `json:"symbol"`
	Name           string `json:"name"`
	Supply         string `json:"supply"`
	ConverterDltID string `json:"converter_dlt_id"`
	ConversionFee  string `json:"conversion_fee"`
	Liquidity      struct {
		Usd string `json:"usd"`
	} `json:"liquidity"`
	Volume24H struct {
		Usd string `json:"usd"`
	} `json:"volume_24h"`
	Fees24H struct {
		Usd string `json:"usd"`
	} `json:"fees_24h"`
}

type BancorPools 

type BancorPools struct {
	Data      []BancorPool `json:"data"`
	Timestamp struct {
		Ethereum struct {
			Block     int   `json:"block"`
			Timestamp int64 `json:"timestamp"`
		} `json:"ethereum"`
	} `json:"timestamp"`
}

type BancorScraper 

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

func NewBancorScraper 

func NewBancorScraper(exchange dia.Exchange, scrape bool) *BancorScraper

func (*BancorScraper) Channel 

func (scraper *BancorScraper) Channel() chan *dia.Trade

func (*BancorScraper) Close 

func (scraper *BancorScraper) Close() error

func (*BancorScraper) ConverterTypeFour 

func (scraper *BancorScraper) ConverterTypeFour(address common.Address) (tokenAddress []common.Address, err error)

func (*BancorScraper) ConverterTypeOne 

func (scraper *BancorScraper) ConverterTypeOne(address common.Address) (tokenAddress []common.Address, err error)

func (*BancorScraper) ConverterTypeThree 

func (scraper *BancorScraper) ConverterTypeThree(address common.Address) (tokenAddress []common.Address, err error)

func (*BancorScraper) ConverterTypeZero 

func (scraper *BancorScraper) ConverterTypeZero(address common.Address) (tokenAddress []common.Address, err error)

func (*BancorScraper) FetchAvailablePairs 

func (scraper *BancorScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*BancorScraper) FillSymbolData 

func (scraper *BancorScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*BancorScraper) GetConversion 

func (scraper *BancorScraper) GetConversion() (chan *BancorNetwork.BancorNetworkConversion, error)

func (*BancorScraper) GetPair 

func (scraper *BancorScraper) GetPair(address []common.Address) dia.ExchangePair

func (*BancorScraper) GetpoolAddress 

func (scraper *BancorScraper) GetpoolAddress()

func (*BancorScraper) NormalizePair 

func (scraper *BancorScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BancorScraper) ScrapePair 

func (scraper *BancorScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

type BancorSwap 

type BancorSwap struct {
	Pair       dia.ExchangePair
	FromAmount float64
	ToAmount   float64
	ID         string
	Timestamp  int64
}

type BinancePairScraper 

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

BinancePairScraper implements PairScraper for Binance

func (*BinancePairScraper) Close 

func (ps *BinancePairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*BinancePairScraper) Error 

func (ps *BinancePairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BinancePairScraper) Pair 

func (ps *BinancePairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BinanceScraper 

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

BinanceScraper is a Scraper for collecting trades from the Binance websocket API

func NewBinanceScraper 

func NewBinanceScraper(apiKey string, secretKey string, exchange dia.Exchange, scraperName string, scrape bool, relDB *models.RelDB) *BinanceScraper

NewBinanceScraper returns a new BinanceScraper for the given pair

func (*BinanceScraper) Channel 

func (ps *BinanceScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*BinanceScraper) Close 

func (s *BinanceScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*BinanceScraper) FetchAvailablePairs 

func (s *BinanceScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*BinanceScraper) FillSymbolData 

func (s *BinanceScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*BinanceScraper) NormalizePair 

func (up *BinanceScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BinanceScraper) ScrapePair 

func (s *BinanceScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type BinanceScraperUS added in v1.4.2 

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

BinanceScraperUS is a Scraper for collecting trades from the Binance websocket API

func NewBinanceScraperUS added in v1.4.2 

func NewBinanceScraperUS(apiKey string, secretKey string, exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BinanceScraperUS

NewBinanceScraperUS returns a new BinanceScraperUS for the given pair

func (*BinanceScraperUS) Channel added in v1.4.2 

func (ps *BinanceScraperUS) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*BinanceScraperUS) Close added in v1.4.2 

func (s *BinanceScraperUS) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*BinanceScraperUS) FetchAvailablePairs added in v1.4.2 

func (s *BinanceScraperUS) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*BinanceScraperUS) FillSymbolData added in v1.4.2 

func (s *BinanceScraperUS) FillSymbolData(symbol string) (dia.Asset, error)

func (*BinanceScraperUS) NormalizePair added in v1.4.2 

func (up *BinanceScraperUS) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BinanceScraperUS) ScrapePair added in v1.4.2 

func (s *BinanceScraperUS) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type BinanceUSPairScraper added in v1.4.2 

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

BinanceUSPairScraper implements PairScraper for Binance

func (*BinanceUSPairScraper) Close added in v1.4.2 

func (ps *BinanceUSPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*BinanceUSPairScraper) Error added in v1.4.2 

func (ps *BinanceUSPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BinanceUSPairScraper) Pair added in v1.4.2 

func (ps *BinanceUSPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BinanceUSPairScraperSet added in v1.4.2 

type BinanceUSPairScraperSet map[*BinanceUSPairScraper]nothing

type BitMartPairScraper added in v1.4.2 

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

BitMartPairScraper implements PairScraper for BitMart

func (*BitMartPairScraper) Close added in v1.4.2 

func (ps *BitMartPairScraper) Close() error

Close stops listening for trades of the pair associated with the BitMart scraper

func (*BitMartPairScraper) Error added in v1.4.2 

func (ps *BitMartPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BitMartPairScraper) Pair added in v1.4.2 

func (ps *BitMartPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BitMartScraper added in v1.4.2 

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

BitMartScraper is a scraper for BitMart

func NewBitMartScraper added in v1.4.2 

func NewBitMartScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BitMartScraper

NewBitMartScraper returns a new BitMart scraper

func (*BitMartScraper) Channel added in v1.4.2 

func (s *BitMartScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*BitMartScraper) Close added in v1.4.2 

func (s *BitMartScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*BitMartScraper) FetchAvailablePairs added in v1.4.2 

func (s *BitMartScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*BitMartScraper) FillSymbolData added in v1.4.2 

func (s *BitMartScraper) FillSymbolData(symbol string) (dia.Asset, error)

TODO: FillSymbolData adds the name to the asset underlying @symbol on BitMart

func (*BitMartScraper) NormalizePair added in v1.4.2 

func (s *BitMartScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

TODO: NormalizePair accounts for the par

func (*BitMartScraper) ScrapePair added in v1.4.2 

func (s *BitMartScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from the BitMart scraper

type BitMaxAsset 

type BitMaxAsset struct {
	AssetCode        string `json:"assetCode"`
	AssetName        string `json:"assetName"`
	PrecisionScale   int    `json:"precisionScale"`
	NativeScale      int    `json:"nativeScale"`
	WithdrawalFee    string `json:"withdrawalFee"`
	MinWithdrawalAmt string `json:"minWithdrawalAmt"`
	Status           string `json:"status"`
}

type BitMaxAssets 

type BitMaxAssets struct {
	Code int           `json:"code"`
	Data []BitMaxAsset `json:"data"`
}

type BitMaxPair 

type BitMaxPair struct {
	Symbol                string `json:"symbol"`
	DisplayName           string `json:"displayName"`
	BaseAsset             string `json:"baseAsset"`
	QuoteAsset            string `json:"quoteAsset"`
	Status                string `json:"status"`
	MinNotional           string `json:"minNotional"`
	MaxNotional           string `json:"maxNotional"`
	MarginTradable        bool   `json:"marginTradable"`
	CommissionType        string `json:"commissionType"`
	CommissionReserveRate string `json:"commissionReserveRate"`
	TickSize              string `json:"tickSize"`
	LotSize               string `json:"lotSize"`
}

type BitMaxPairResponse 

type BitMaxPairResponse struct {
	Code int          `json:"code"`
	Data []BitMaxPair `json:"data"`
}

type BitMaxPairScraper 

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

BitMax implements PairScraper for BitMax

func (*BitMaxPairScraper) Close 

func (ps *BitMaxPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*BitMaxPairScraper) Error 

func (ps *BitMaxPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BitMaxPairScraper) Pair 

func (ps *BitMaxPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BitMaxRequest 

type BitMaxRequest struct {
	Op string `json:"op"`
	ID string `json:"id"`
	Ch string `json:"ch"`
}

type BitMaxScraper 

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

func NewBitMaxScraper 

func NewBitMaxScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BitMaxScraper

func (*BitMaxScraper) Channel 

func (ps *BitMaxScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*BitMaxScraper) Close 

func (s *BitMaxScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*BitMaxScraper) FetchAvailablePairs 

func (s *BitMaxScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*BitMaxScraper) FillSymbolData 

func (s *BitMaxScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

FillSymbolData collects all available information on an asset traded on Bitmax

func (*BitMaxScraper) NormalizePair 

func (s *BitMaxScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BitMaxScraper) ScrapePair 

func (s *BitMaxScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type BitMaxTradeResponse 

type BitMaxTradeResponse struct {
	M      string `json:"m"`
	Symbol string `json:"symbol"`
	Data   []struct {
		P      string `json:"p"`
		Q      string `json:"q"`
		Ts     int64  `json:"ts"`
		Bm     bool   `json:"bm"`
		Seqnum int64  `json:"seqnum"`
	} `json:"data"`
}

type BitMexPairScraper added in v1.4.0 

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

BitMexPairScraper implements PairScraper for BitMex

func (*BitMexPairScraper) Close added in v1.4.0 

func (p *BitMexPairScraper) Close() error

Close stops listening for trades of the pair associated with the BitMex scraper

func (*BitMexPairScraper) Error added in v1.4.0 

func (p *BitMexPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BitMexPairScraper) Pair added in v1.4.0 

func (p *BitMexPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BitMexScraper added in v1.4.0 

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

BitMexScraper is a scraper for bitmex.com

func NewBitMexScraper added in v1.4.0 

func NewBitMexScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BitMexScraper

NewBitMexScraper returns a new BitMex scraper

func (*BitMexScraper) Channel added in v1.4.0 

func (s *BitMexScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*BitMexScraper) Close added in v1.4.0 

func (s *BitMexScraper) Close() error

Close unsubscribes data and closes any existing WebSocket connections, as well as channels of BitMexScraper

func (*BitMexScraper) FetchAvailablePairs added in v1.4.0 

func (s *BitMexScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns all traded pairs on BitMex

func (*BitMexScraper) FillSymbolData added in v1.4.0 

func (s *BitMexScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData adds the name to the asset underlying @symbol on BitMex

func (*BitMexScraper) NormalizePair added in v1.4.0 

func (s *BitMexScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BitMexScraper) ScrapePair added in v1.4.0 

func (s *BitMexScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from the BitMex scraper

type BitfinexPairScraper 

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

BitfinexPairScraper implements PairScraper for Bitfinex

func (*BitfinexPairScraper) Close 

func (ps *BitfinexPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*BitfinexPairScraper) Error 

func (ps *BitfinexPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BitfinexPairScraper) Pair 

func (ps *BitfinexPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BitfinexScraper 

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

BitfinexScraper is a Scraper for collecting trades from the Bitfinex websocket API

func NewBitfinexScraper 

func NewBitfinexScraper(key string, secret string, exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BitfinexScraper

NewBitfinexScraper returns a new BitfinexScraper for the given pair

func (*BitfinexScraper) Channel 

func (ps *BitfinexScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*BitfinexScraper) Close 

func (s *BitfinexScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*BitfinexScraper) FetchAvailablePairs 

func (s *BitfinexScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*BitfinexScraper) FillSymbolData 

func (s *BitfinexScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

func (*BitfinexScraper) NormalizePair 

func (s *BitfinexScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BitfinexScraper) ScrapePair 

func (s *BitfinexScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type BitgetPairScraper added in v1.4.529 

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

BitgetPairScraper implements PairScraper

func (*BitgetPairScraper) Close added in v1.4.529 

func (ps *BitgetPairScraper) Close() error

func (*BitgetPairScraper) Error added in v1.4.529 

func (ps *BitgetPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BitgetPairScraper) Pair added in v1.4.529 

func (ps *BitgetPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BitgetScraper added in v1.4.529 

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

func NewBitgetScraper added in v1.4.529 

func NewBitgetScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BitgetScraper

NewBitgetScraper returns a new BitgetScraper initialized with default values. The instance is asynchronously scraping as soon as it is created.

func (*BitgetScraper) Channel added in v1.4.529 

func (ps *BitgetScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades/pricing information

func (*BitgetScraper) Close added in v1.4.529 

func (s *BitgetScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*BitgetScraper) FetchAvailablePairs added in v1.4.529 

func (s *BitgetScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*BitgetScraper) FillSymbolData added in v1.4.529 

func (s *BitgetScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

FillSymbolData collects all available information on an asset traded on Bitget

func (*BitgetScraper) NormalizePair added in v1.4.529 

func (s *BitgetScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BitgetScraper) ScrapePair added in v1.4.529 

func (s *BitgetScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type BitmartHttpSymbolsDetailsResponse added in v1.4.2 

type BitmartHttpSymbolsDetailsResponse struct {
	Message string `json:"message"`
	Code    int    `json:"code"`
	Trace   string `json:"trace"`
	Data    struct {
		Symbols []struct {
			Symbol            string `json:"symbol"`
			SymbolId          int    `json:"symbol_id"`
			BaseCurrency      string `json:"base_currency"`
			QuoteCurrency     string `json:"quote_currency"`
			QuoteIncrement    string `json:"quote_increment"`
			BaseMinSize       string `json:"base_min_size"`
			PriceMinPrecision int    `json:"price_min_precision"`
			PriceMaxPrecision int    `json:"price_max_precision"`
			Expiration        string `json:"expiration"`
			MinBuyAmount      string `json:"min_buy_amount"`
			MinSellAmount     string `json:"min_sell_amount"`
			TradeStatus       string `json:"trade_status"`
		} `json:"symbols"`
	} `json:"data"`
}

type BitmartWsRequest added in v1.4.2 

type BitmartWsRequest struct {
	Op   string   `json:"op"`
	Args []string `json:"args"`
}

type BitmartWsTradeResponse added in v1.4.2 

type BitmartWsTradeResponse struct {
	Table string `json:"table"`
	Data  []struct {
		Symbol       string `json:"symbol"`
		Price        string `json:"price"`
		Side         string `json:"side"`
		Size         string `json:"size"`
		TimestampSec int    `json:"s_t"`
	} `json:"data"`
	ErrorMessage string `json:"errorMessage"`
	ErrorCode    string `json:"errorCode"`
	Event        string `json:"event"`
}

type BitstampPairScraper added in v1.4.153 

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

func (*BitstampPairScraper) Close added in v1.4.153 

func (ps *BitstampPairScraper) Close() error

func (*BitstampPairScraper) Error added in v1.4.153 

func (ps *BitstampPairScraper) Error() error

func (*BitstampPairScraper) Pair added in v1.4.153 

func (ps *BitstampPairScraper) Pair() dia.ExchangePair

type BitstampPairsInfo added in v1.4.153 

type BitstampPairsInfo []struct {
	Name                        string `json:"name"`
	UrlSymbol                   string `json:"url_symbol"`
	BaseDecimal                 uint8  `json:"base_decimal"`
	CounterDecimals             uint8  `json:"counter_decimals"`
	InstantOrderCounterDecimals uint8  `json:"instant_order_counter_decimals"`
	MinimumOrder                string `json:"minimum_order"`
	Trading                     string `json:"trading"`
	InstantAndMarketOrders      string `json:"instant_and_market_orders"`
	Description                 string `json:"description"`
}

type BitstampPingData added in v1.4.153 

type BitstampPingData struct {
	Status string `json:"status"`
}

type BitstampScraper added in v1.4.153 

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

func NewBitstampScraper added in v1.4.153 

func NewBitstampScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BitstampScraper

func (*BitstampScraper) Channel added in v1.4.153 

func (s *BitstampScraper) Channel() chan *dia.Trade

func (*BitstampScraper) Close added in v1.4.153 

func (s *BitstampScraper) Close() error

func (*BitstampScraper) FetchAvailablePairs added in v1.4.153 

func (s *BitstampScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*BitstampScraper) FillSymbolData added in v1.4.153 

func (s *BitstampScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*BitstampScraper) NormalizePair added in v1.4.153 

func (s *BitstampScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BitstampScraper) ScrapePair added in v1.4.153 

func (s *BitstampScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

type BitstampTradeData added in v1.4.153 

type BitstampTradeData struct {
	Id             string  `json:"id"`
	Amount         float64 `json:"amount"`
	AmountStr      string  `json:"amount_str"`
	Price          float64 `json:"price"`
	PriceStr       string  `json:"price_str"`
	Type           uint8   `json:"type"`
	Timestamp      string  `json:"timestamp"`
	Microtimestamp string  `json:"microtimestamp"`
	BuyOrderId     uint64  `json:"buy_order_id"`
	SellOrderId    uint64  `json:"sell_order_id"`
}

type BitstampWsResponse added in v1.4.153 

type BitstampWsResponse struct {
	Event   string      `json:"event"`
	Channel string      `json:"channel"`
	Data    interface{} `json:"data"`
}

type BridgeSwapPair added in v1.4.2 

type BridgeSwapPair struct {
	Token0      BridgeSwapToken
	Token1      BridgeSwapToken
	ForeignName string
	Address     common.Address
}

type BridgeSwapPairScraper added in v1.4.2 

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

BridgeSwapPairScraper implements PairScraper for Uniswap

func (*BridgeSwapPairScraper) Close added in v1.4.2 

func (ps *BridgeSwapPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*BridgeSwapPairScraper) Error added in v1.4.2 

func (ps *BridgeSwapPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*BridgeSwapPairScraper) Pair added in v1.4.2 

func (ps *BridgeSwapPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type BridgeSwapScraper added in v1.4.2 

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

func NewBridgeSwapScraper added in v1.4.2 

func NewBridgeSwapScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *BridgeSwapScraper

NewBridgeSwapScraper returns a new BridgeSwapScraper for the given pair

func (*BridgeSwapScraper) Channel added in v1.4.2 

func (ps *BridgeSwapScraper) Channel() chan *dia.Trade

func (*BridgeSwapScraper) Close added in v1.4.2 

func (s *BridgeSwapScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*BridgeSwapScraper) FetchAvailablePairs added in v1.4.2 

func (b *BridgeSwapScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*BridgeSwapScraper) FillSymbolData added in v1.4.2 

func (s *BridgeSwapScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*BridgeSwapScraper) NormalizePair added in v1.4.2 

func (up *BridgeSwapScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*BridgeSwapScraper) ScrapePair added in v1.4.2 

func (s *BridgeSwapScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

type BridgeSwapSwap added in v1.4.2 

type BridgeSwapSwap struct {
	TransactionHash string
	TokenAddress    common.Address
	ToAddress       common.Address
	Amount          *big.Int
	FromChainId     *big.Int
	ToChainId       *big.Int
}

type BridgeSwapToken added in v1.4.2 

type BridgeSwapToken struct {
	Address  common.Address
	Symbol   string
	Decimals uint8
	Name     string
}

type ByBitMarket added in v1.4.0 

type ByBitMarket struct {
	Name           string `json:"name"`
	Alias          string `json:"alias"`
	Status         string `json:"status"`
	BaseCurrency   string `json:"base_currency"`
	QuoteCurrency  string `json:"quote_currency"`
	PriceScale     int    `json:"price_scale"`
	TakerFee       string `json:"taker_fee"`
	MakerFee       string `json:"maker_fee"`
	LeverageFilter struct {
		MinLeverage  int    `json:"min_leverage"`
		MaxLeverage  int    `json:"max_leverage"`
		LeverageStep string `json:"leverage_step"`
	} `json:"leverage_filter"`
	PriceFilter struct {
		MinPrice string `json:"min_price"`
		MaxPrice string `json:"max_price"`
		TickSize string `json:"tick_size"`
	} `json:"price_filter"`
	LotSizeFilter struct {
		MaxTradingQty float64 `json:"max_trading_qty"`
		MinTradingQty float64 `json:"min_trading_qty"`
		QtyStep       float64 `json:"qty_step"`
	} `json:"lot_size_filter"`
}

type ByBitMarketsResponse added in v1.4.0 

type ByBitMarketsResponse struct {
	RetCode int           `json:"ret_code"`
	RetMsg  string        `json:"ret_msg"`
	ExtCode string        `json:"ext_code"`
	ExtInfo string        `json:"ext_info"`
	Result  []ByBitMarket `json:"result"`
	TimeNow string        `json:"time_now"`
}

type ByBitPairScraper added in v1.4.0 

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

ByBitPairScraper implements PairScraper for ByBit

func (*ByBitPairScraper) Close added in v1.4.0 

func (ps *ByBitPairScraper) Close() error

Close stops listening for trades of the pair associated

func (*ByBitPairScraper) Error added in v1.4.0 

func (ps *ByBitPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*ByBitPairScraper) Pair added in v1.4.0 

func (ps *ByBitPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type ByBitScraper added in v1.4.0 

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

ByBitScraper provides methods needed to get Trade information from ByBit

func NewByBitScraper added in v1.4.0 

func NewByBitScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *ByBitScraper

NewByBitScraper get a scrapper for ByBit exchange

func (*ByBitScraper) Channel added in v1.4.0 

func (s *ByBitScraper) Channel() chan *dia.Trade

Channel returns the channel to get trades

func (*ByBitScraper) Close added in v1.4.0 

func (s *ByBitScraper) Close() error

Close any existing API connections, as well as channels, and terminates main loop

func (*ByBitScraper) Error added in v1.4.0 

func (s *ByBitScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*ByBitScraper) FetchAvailablePairs added in v1.4.0 

func (s *ByBitScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*ByBitScraper) FillSymbolData added in v1.4.0 

func (s *ByBitScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*ByBitScraper) NormalizePair added in v1.4.0 

func (s *ByBitScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*ByBitScraper) ScrapePair added in v1.4.0 

func (s *ByBitScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type ByBitSubscribe added in v1.4.0 

type ByBitSubscribe struct {
	OP   string   `json:"op"`
	Args []string `json:"args"`
}

type ByBitTradeResponse added in v1.4.0 

type ByBitTradeResponse struct {
	Data struct {
		TradeID   string `json:"v"`
		Timestamp int64  `json:"t"`
		Price     string `json:"p"`
		Size      string `json:"q"`
		Side      bool   `json:"m"`
		Type      string `json:"type"`
	} `json:"data"`
	Type      string `json:"type"`
	Topic     string `json:"topic"`
	Timestamp int64  `json:"ts"`
}

type CoinBasePairScraper 

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

CoinBasePairScraper implements PairScraper for GDax

func (*CoinBasePairScraper) Close 

func (ps *CoinBasePairScraper) Close() error

func (*CoinBasePairScraper) Error 

func (ps *CoinBasePairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*CoinBasePairScraper) Pair 

func (ps *CoinBasePairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type CoinBaseScraper 

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

func NewCoinBaseScraper 

func NewCoinBaseScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *CoinBaseScraper

NewCoinBaseScraper returns a new CoinBaseScraper initialized with default values. The instance is asynchronously scraping as soon as it is created.

func (*CoinBaseScraper) Channel 

func (ps *CoinBaseScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades/pricing information

func (*CoinBaseScraper) Close 

func (s *CoinBaseScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*CoinBaseScraper) FetchAvailablePairs 

func (s *CoinBaseScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*CoinBaseScraper) FillSymbolData 

func (s *CoinBaseScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

FillSymbolData collects all available information on an asset traded on CoinBase

func (*CoinBaseScraper) NormalizePair 

func (s *CoinBaseScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*CoinBaseScraper) ScrapePair 

func (s *CoinBaseScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type CryptoDotComPairScraper added in v1.4.0 

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

CryptoDotComPairScraper implements PairScraper for Crypto.com

func (*CryptoDotComPairScraper) Close added in v1.4.0 

func (p *CryptoDotComPairScraper) Close() error

Close stops listening for trades of the pair associated with the Crypto.com scraper

func (*CryptoDotComPairScraper) Error added in v1.4.0 

func (p *CryptoDotComPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*CryptoDotComPairScraper) Pair added in v1.4.0 

func (p *CryptoDotComPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type CryptoDotComScraper added in v1.4.0 

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

CryptoDotComScraper is a scraper for Crypto.com

func NewCryptoDotComScraper added in v1.4.0 

func NewCryptoDotComScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *CryptoDotComScraper

NewCryptoDotComScraper returns a new Crypto.com scraper

func (*CryptoDotComScraper) Channel added in v1.4.0 

func (s *CryptoDotComScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*CryptoDotComScraper) Close added in v1.4.0 

func (s *CryptoDotComScraper) Close() error

Close unsubscribes data and closes any existing WebSocket connections, as well as channels of CryptoDotComScraper

func (*CryptoDotComScraper) FetchAvailablePairs added in v1.4.0 

func (s *CryptoDotComScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns all traded pairs on Crypto.com

func (*CryptoDotComScraper) FillSymbolData added in v1.4.0 

func (s *CryptoDotComScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData adds the name to the asset underlying @symbol on Crypto.com

func (*CryptoDotComScraper) NormalizePair added in v1.4.0 

func (s *CryptoDotComScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*CryptoDotComScraper) ScrapePair added in v1.4.0 

func (s *CryptoDotComScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from the Crypto.com scraper

type CurveCoin 

type CurveCoin struct {
	Symbol   string
	Decimals uint8
	Address  string
	Name     string
}

type CurveFIPairScraper 

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

func (*CurveFIPairScraper) Close 

func (pairScraper *CurveFIPairScraper) Close() error

func (*CurveFIPairScraper) Error 

func (pairScraper *CurveFIPairScraper) Error() error

func (*CurveFIPairScraper) Pair 

func (pairScraper *CurveFIPairScraper) Pair() dia.ExchangePair

type CurveFIScraper 

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

CurveFIScraper is a curve finance scraper on a specific blockchain.

func NewCurveFIScraper 

func NewCurveFIScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *CurveFIScraper

func (*CurveFIScraper) Channel 

func (scraper *CurveFIScraper) Channel() chan *dia.Trade

func (*CurveFIScraper) Close 

func (scraper *CurveFIScraper) Close() error

func (*CurveFIScraper) FetchAvailablePairs 

func (scraper *CurveFIScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*CurveFIScraper) FillSymbolData 

func (scraper *CurveFIScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*CurveFIScraper) NormalizePair 

func (scraper *CurveFIScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*CurveFIScraper) ScrapePair 

func (scraper *CurveFIScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

type ECBPairScraper 

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

ECBPairScraper implements PairScraper for ECB

func (*ECBPairScraper) Close 

func (ps *ECBPairScraper) Close() error

func (*ECBPairScraper) Error 

func (ps *ECBPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*ECBPairScraper) Pair 

func (ps *ECBPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type ECBScraper 

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

func SpawnECBScraper 

func SpawnECBScraper(datastore models.Datastore) *ECBScraper

SpawnECBScraper returns a new ECBScraper initialized with default values. The instance is asynchronously scraping as soon as it is created.

func (*ECBScraper) Channel 

func (ps *ECBScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades/pricing information

func (*ECBScraper) Close 

func (s *ECBScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*ECBScraper) ScrapePair 

func (s *ECBScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

func (*ECBScraper) Update 

func (s *ECBScraper) Update() error

Update performs a HTTP Get request for the rss feed and decodes the results.

type Event 

type Event struct {
	Type       string      `json:"type"`
	Attributes []Attribute `json:"attributes"`
}

Contains info about a transaction log event

type EventType 

type EventType struct {
	Sub  string `json:"sub,omitempty"`
	Id   string `json:"id,omitempty"`
	Pong int    `json:"pong,omitempty"`
}

type EventsByMsgIndex added in v1.4.242 

type EventsByMsgIndex map[string]AttributesByEvent

Contains info about transaction events keyed by message index

func ParseEvents added in v1.4.242 

func ParseEvents(log string) EventsByMsgIndex

type FinageForexPairScraper 

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

ECBPairScraper implements PairScraper for ECB

func (*FinageForexPairScraper) Close 

func (pairScraper *FinageForexPairScraper) Close() error

func (*FinageForexPairScraper) Error 

func (pairScraper *FinageForexPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*FinageForexPairScraper) Pair 

func (pairScraper *FinageForexPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type FinageForexScraper 

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

func NewFinageForexScraper 

func NewFinageForexScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB, finageAPIkey string, finageWebsocketKey string) *FinageForexScraper

SpawnECBScraper returns a new ECBScraper initialized with default values. The instance is asynchronously scraping as soon as it is created.

func (*FinageForexScraper) Channel 

func (scraper *FinageForexScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades/pricing information

func (*FinageForexScraper) Close 

func (scraper *FinageForexScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*FinageForexScraper) FetchAvailablePairs 

func (scraper *FinageForexScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*FinageForexScraper) FillSymbolData 

func (scraper *FinageForexScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

func (*FinageForexScraper) NormalizePair 

func (scraper *FinageForexScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*FinageForexScraper) ScrapePair 

func (scraper *FinageForexScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

func (*FinageForexScraper) Update 

func (scraper *FinageForexScraper) Update() error

Update performs a HTTP Get request for the rss feed and decodes the results.

type FinageSymbolResponse 

type FinageSymbolResponse struct {
	Page      int `json:"page"`
	TotalPage int `json:"totalPage"`
	Symbols   []struct {
		Symbol string `json:"symbol"`
		Name   string `json:"name"`
	} `json:"symbols"`
}

type FinageTrade 

type FinageTrade struct {
	Symbol    string  `json:"s"`
	PriceAsk  float64 `json:"a"`
	PriceBid  float64 `json:"b"`
	VolumeAsk string  `json:"dc"`
	VolumeBid string  `json:"dd"`
	Timestamp int64   `json:"t"`
}

type FinageWSMessage 

type FinageWSMessage struct {
	Action  string `json:"action"`
	Symbols string `json:"symbols"`
}

type GateIOCurrency 

type GateIOCurrency struct {
	No          int    `json:"no"`
	Symbol      string `json:"symbol"`
	Name        string `json:"name"`
	NameEn      string `json:"name_en"`
	NameCn      string `json:"name_cn"`
	Pair        string `json:"pair"`
	Rate        string `json:"rate"`
	VolA        string `json:"vol_a"`
	VolB        string `json:"vol_b"`
	CurrA       string `json:"curr_a"`
	CurrB       string `json:"curr_b"`
	CurrSuffix  string `json:"curr_suffix"`
	RatePercent string `json:"rate_percent"`
	Trend       string `json:"trend"`
	Lq          string `json:"lq"`
	PRate       int    `json:"p_rate"`
}

type GateIOPair 

type GateIOPair struct {
	ID              string `json:"id"`
	Base            string `json:"base"`
	Quote           string `json:"quote"`
	Fee             string `json:"fee"`
	MinQuoteAmount  string `json:"min_quote_amount,omitempty"`
	AmountPrecision int    `json:"amount_precision"`
	Precision       int    `json:"precision"`
	TradeStatus     string `json:"trade_status"`
	SellStart       int    `json:"sell_start"`
	BuyStart        int    `json:"buy_start"`
	MinBaseAmount   string `json:"min_base_amount,omitempty"`
}

type GateIOPairScraper 

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

GateIOPairScraper implements PairScraper for GateIO

func (*GateIOPairScraper) Close 

func (ps *GateIOPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*GateIOPairScraper) Error 

func (ps *GateIOPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*GateIOPairScraper) Pair 

func (ps *GateIOPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type GateIOResponseTrade 

type GateIOResponseTrade struct {
	Time    int    `json:"time"`
	Channel string `json:"channel"`
	Event   string `json:"event"`
	Result  struct {
		ID           int    `json:"id"`
		CreateTime   int    `json:"create_time"`
		CreateTimeMs string `json:"create_time_ms"`
		Side         string `json:"side"`
		CurrencyPair string `json:"currency_pair"`
		Amount       string `json:"amount"`
		Price        string `json:"price"`
	} `json:"result"`
}

type GateIOScraper 

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

func NewGateIOScraper 

func NewGateIOScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *GateIOScraper

NewGateIOScraper returns a new GateIOScraper for the given pair

func (*GateIOScraper) Channel 

func (ps *GateIOScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*GateIOScraper) Close 

func (s *GateIOScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*GateIOScraper) FetchAvailablePairs 

func (s *GateIOScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*GateIOScraper) FillSymbolData 

func (s *GateIOScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

FetchTickerData collects all available information on an asset traded on GateIO

func (*GateIOScraper) NormalizePair 

func (s *GateIOScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*GateIOScraper) ScrapePair 

func (s *GateIOScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type GateIOTickerData 

type GateIOTickerData struct {
	Result string           `json:"result"`
	Data   []GateIOCurrency `json:"data"`
}

type GateIPPairResponse 

type GateIPPairResponse []GateIOPair

type HuobiCurrency 

type HuobiCurrency struct {
	Code int `json:"code"`
	Data []struct {
		Currency  string `json:"currency"`
		AssetType int    `json:"assetType"`
		Chains    []struct {
			Chain                  string      `json:"chain"`
			DisplayName            string      `json:"displayName"`
			BaseChain              string      `json:"baseChain"`
			BaseChainProtocol      string      `json:"baseChainProtocol"`
			IsDynamic              bool        `json:"isDynamic"`
			NumOfConfirmations     int         `json:"numOfConfirmations"`
			NumOfFastConfirmations int         `json:"numOfFastConfirmations"`
			DepositStatus          string      `json:"depositStatus"`
			MinDepositAmt          string      `json:"minDepositAmt"`
			WithdrawStatus         string      `json:"withdrawStatus"`
			MinWithdrawAmt         string      `json:"minWithdrawAmt"`
			WithdrawPrecision      int         `json:"withdrawPrecision"`
			MaxWithdrawAmt         string      `json:"maxWithdrawAmt"`
			WithdrawQuotaPerDay    string      `json:"withdrawQuotaPerDay"`
			WithdrawQuotaPerYear   interface{} `json:"withdrawQuotaPerYear"`
			WithdrawQuotaTotal     interface{} `json:"withdrawQuotaTotal"`
			WithdrawFeeType        string      `json:"withdrawFeeType"`
			TransactFeeWithdraw    string      `json:"transactFeeWithdraw"`
			AddrWithTag            bool        `json:"addrWithTag"`
			AddrDepositTag         bool        `json:"addrDepositTag"`
		} `json:"chains"`
		InstStatus string `json:"instStatus"`
	} `json:"data"`
}

type HuobiPairScraper 

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

HuobiPairScraper implements PairScraper for Huobi exchange

func (*HuobiPairScraper) Close 

func (ps *HuobiPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*HuobiPairScraper) Error 

func (ps *HuobiPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*HuobiPairScraper) Pair 

func (ps *HuobiPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type HuobiScraper 

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

func NewHuobiScraper 

func NewHuobiScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *HuobiScraper

NewHuobiScraper returns a new HuobiScraper for the given pair

func (*HuobiScraper) Channel 

func (ps *HuobiScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*HuobiScraper) Close 

func (s *HuobiScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*HuobiScraper) FetchAvailablePairs 

func (s *HuobiScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*HuobiScraper) FillSymbolData 

func (s *HuobiScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData collects all available information on an asset traded on huobi

func (*HuobiScraper) NormalizePair 

func (s *HuobiScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*HuobiScraper) ScrapePair 

func (s *HuobiScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type InfluxPairScraper 

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

GateIOPairScraper implements PairScraper for GateIO

func (*InfluxPairScraper) Close 

func (ps *InfluxPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*InfluxPairScraper) Error 

func (ps *InfluxPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*InfluxPairScraper) Pair 

func (ps *InfluxPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type InfluxScraper 

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

func NewInfluxScraper 

func NewInfluxScraper(scrape bool) *InfluxScraper

NewGateIOScraper returns a new GateIOScraper for the given pair

func (*InfluxScraper) Channel 

func (s *InfluxScraper) Channel() chan *dia.Trade

func (*InfluxScraper) Close 

func (s *InfluxScraper) Close() error

func (*InfluxScraper) FetchAvailablePairs 

func (s *InfluxScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*InfluxScraper) FillSymbolData 

func (s *InfluxScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

FetchTickerData collects all available information on an asset traded on GateIO

func (*InfluxScraper) NormalizePair 

func (s *InfluxScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*InfluxScraper) ScrapePair 

func (s *InfluxScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type KrakenPairScraper 

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

KrakenPairScraper implements PairScraper for Kraken

func (*KrakenPairScraper) Close 

func (ps *KrakenPairScraper) Close() error

func (*KrakenPairScraper) Error 

func (ps *KrakenPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*KrakenPairScraper) Pair 

func (ps *KrakenPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type KrakenScraper 

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

func NewKrakenScraper 

func NewKrakenScraper(key string, secret string, exchange dia.Exchange, scrape bool, relDB *models.RelDB) *KrakenScraper

NewKrakenScraper returns a new KrakenScraper initialized with default values. The instance is asynchronously scraping as soon as it is created.

func (*KrakenScraper) Channel 

func (ps *KrakenScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades/pricing information

func (*KrakenScraper) Close 

func (s *KrakenScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*KrakenScraper) FetchAvailablePairs 

func (s *KrakenScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*KrakenScraper) FillSymbolData 

func (s *KrakenScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*KrakenScraper) NormalizePair 

func (ps *KrakenScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

NormalizePair accounts for the par

func (*KrakenScraper) ScrapePair 

func (s *KrakenScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

func (*KrakenScraper) Update 

func (s *KrakenScraper) Update()

type KuCoinPairScraper 

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

KuCoinPairScraper implements PairScraper for kuCoin

func (*KuCoinPairScraper) Close 

func (ps *KuCoinPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*KuCoinPairScraper) Error 

func (ps *KuCoinPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*KuCoinPairScraper) Pair 

func (ps *KuCoinPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type KuCoinScraper 

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

func NewKuCoinScraper 

func NewKuCoinScraper(apiKey string, secretKey string, exchange dia.Exchange, scrape bool, relDB *models.RelDB) *KuCoinScraper

func (*KuCoinScraper) Channel 

func (ps *KuCoinScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*KuCoinScraper) Close 

func (s *KuCoinScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*KuCoinScraper) FetchAvailablePairs 

func (s *KuCoinScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns all traded pairs on kucoin.

func (*KuCoinScraper) FillSymbolData 

func (s *KuCoinScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

FillSymbolData adds the name to the asset underlying @symbol on kucoin.

func (*KuCoinScraper) NormalizePair 

func (s *KuCoinScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*KuCoinScraper) ScrapePair 

func (s *KuCoinScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type KuExchangePair 

type KuExchangePair struct {
	Symbol          string `json:"symbol"`
	Name            string `json:"name"`
	BaseCurrency    string `json:"baseCurrency"`
	QuoteCurrency   string `json:"quoteCurrency"`
	FeeCurrency     string `json:"feeCurrency"`
	Market          string `json:"market"`
	BaseMinSize     string `json:"baseMinSize"`
	QuoteMinSize    string `json:"quoteMinSize"`
	BaseMaxSize     string `json:"baseMaxSize"`
	QuoteMaxSize    string `json:"quoteMaxSize"`
	BaseIncrement   string `json:"baseIncrement"`
	QuoteIncrement  string `json:"quoteIncrement"`
	PriceIncrement  string `json:"priceIncrement"`
	PriceLimitRate  string `json:"priceLimitRate"`
	IsMarginEnabled bool   `json:"isMarginEnabled"`
	EnableTrading   bool   `json:"enableTrading"`
}

type KuExchangePairs 

type KuExchangePairs []KuExchangePair

type KucoinCurrency 

type KucoinCurrency struct {
	Symbol  string `json:"currency"`
	Name    string `json:"fullName"`
	Address string `json:"contractAddress"`
}

type KucoinMarketMatch 

type KucoinMarketMatch struct {
	Symbol       string `json:"symbol"`
	Sequence     string `json:"sequence"`
	Side         string `json:"side"`
	Size         string `json:"size"`
	Price        string `json:"price"`
	TakerOrderID string `json:"takerOrderId"`
	Time         string `json:"time"`
	Type         string `json:"type"`
	MakerOrderID string `json:"makerOrderId"`
	TradeID      string `json:"tradeId"`
}

type MEXCExchangeInfo added in v1.4.2 

type MEXCExchangeInfo struct {
	Timezone        string               `json:"timezone"`
	ServerTime      int                  `json:"serverTime"`
	RateLimits      string               `json:"rateLimits"`
	ExchangeFilters string               `json:"exchangeFilters"`
	Symbols         []MEXCExchangeSymbol `json:"symbols"`
}

type MEXCExchangeSymbol added in v1.4.2 

type MEXCExchangeSymbol struct {
	Symbol                     string   `json:"symbol"`
	Status                     string   `json:"status"`
	BaseAsset                  string   `json:"baseAsset"`
	BaseAssetPrecision         int      `json:"baseAssetPrecision"`
	QuoteAsset                 string   `json:"quoteAsset"`
	QuotePrecision             int      `json:"quotePrecision"`
	QuoteAssetPrecision        int      `json:"quoteAssetPrecision"`
	BaseCommissionPrecision    int      `json:"baseCommissionPrecision"`
	QuoteCommissionPrecision   int      `json:"quoteCommissionPrecision"`
	OrderTypes                 []string `json:"orderTypes"` // [LIMIT, LIMIT_MAKER]
	QuoteOrderQtyMarketAllowed bool     `json:"quoteOrderQtyMarketAllowed"`
	IsSpotTradingAllowed       bool     `json:"isSpotTradingAllowed"`
	IsMarginTradingAllowed     bool     `json:"isMarginTradingAllowed"`
	QuoteAmountPrecision       string   `json:"quoteAmountPrecision"`
	BaseSizePrecision          string   `json:"baseSizePrecision"`
	Permissions                []string `json:"permissions"`
	Filters                    []string `json:"filters"`
	MaxQuoteAmount             string   `json:"maxQuoteAmount"`
	MakerCommission            string   `json:"makerCommission"`
	TakerCommission            string   `json:"takerCommission"`
}

type MEXCPairScraper added in v1.4.2 

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

MEXCPairScraper implements PairScraper for MEXC

func (*MEXCPairScraper) Close added in v1.4.2 

func (ps *MEXCPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*MEXCPairScraper) Error added in v1.4.2 

func (ps *MEXCPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*MEXCPairScraper) Pair added in v1.4.2 

func (ps *MEXCPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type MEXCRequest added in v1.4.2 

type MEXCRequest struct {
	Method string   `json:"method"`
	Params []string `json:"params"`
	ID     int64    `json:"id"`
}

type MEXCScraper added in v1.4.2 

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

MEXCScraper is a scraper for MEXC

func NewMEXCScraper added in v1.4.2 

func NewMEXCScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *MEXCScraper

func (*MEXCScraper) Channel added in v1.4.2 

func (s *MEXCScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*MEXCScraper) Close added in v1.4.2 

func (s *MEXCScraper) Close() error

func (*MEXCScraper) FetchAvailablePairs added in v1.4.2 

func (s *MEXCScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*MEXCScraper) FillSymbolData added in v1.4.2 

func (s *MEXCScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

FillSymbolData from MEXCScraper @todo more update

func (*MEXCScraper) NormalizePair added in v1.4.2 

func (s *MEXCScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*MEXCScraper) ScrapePair added in v1.4.2 

func (s *MEXCScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

type MEXCTradeResponse added in v1.4.2 

type MEXCTradeResponse struct {
	C string `json:"c"`
	D struct {
		Deals []struct {
			Side   int    `json:"S"`
			Price  string `json:"p"`
			Volume string `json:"v"`
			TS     int64  `json:"t"`
		} `json:"deals"`
	} `json:"d"`
	Symbol string `json:"s"`
}

type MEXCWSConnection added in v1.4.52 

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

type MaverickPair added in v1.4.329 

type MaverickPair struct {
	Token0      Token
	Token1      Token
	ForeignName string
	Address     common.Address
}

type MaverickPairScraper added in v1.4.329 

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

MaverickPairScraper implements PairScraper for Uniswap

func (*MaverickPairScraper) Close added in v1.4.329 

func (ps *MaverickPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*MaverickPairScraper) Error added in v1.4.329 

func (ps *MaverickPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*MaverickPairScraper) Pair added in v1.4.329 

func (ps *MaverickPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type MaverickScraper added in v1.4.329 

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

func NewMaverickScraper added in v1.4.329 

func NewMaverickScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *MaverickScraper

NewMaverickScraper returns a new MaverickScraper for the given pair

func (*MaverickScraper) Channel added in v1.4.329 

func (s *MaverickScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*MaverickScraper) Close added in v1.4.329 

func (s *MaverickScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*MaverickScraper) FetchAvailablePairs added in v1.4.329 

func (s *MaverickScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs as dia.ExchangePair for the pairDiscorvery service

func (*MaverickScraper) FillSymbolData added in v1.4.329 

func (s *MaverickScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData is not used by DEX scrapers.

func (*MaverickScraper) GetSwapsChannel added in v1.4.329 

func (s *MaverickScraper) GetSwapsChannel(pairAddress common.Address) (chan *poolcontract.PoolSwap, error)

GetSwapsChannel returns a channel for swaps of the pair with address @pairAddress

func (*MaverickScraper) ListenToPair added in v1.4.329 

func (s *MaverickScraper) ListenToPair(address common.Address)

ListenToPair subscribes to a uniswap pool. If @byAddress is true, it listens by pool address, otherwise by index.

func (*MaverickScraper) NormalizePair added in v1.4.329 

func (s *MaverickScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*MaverickScraper) ScrapePair added in v1.4.329 

func (s *MaverickScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type Message 

type Message struct {
	Value string
	Token string
}

Contains info about a transaction message

func ParseMessages added in v1.4.242 

func ParseMessages(msgs []sdk.Msg, events EventsByMsgIndex) []Message

ParseMessages will parse any osmosis or cosmos-sdk message types

type MultiChainConfig added in v1.4.2 

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

type OKEXArgs 

type OKEXArgs struct {
	Channel string `json:"channel"`
	InstID  string `json:"instId"`
}

type OKEXMarket 

type OKEXMarket struct {
	Alias     string `json:"alias"`
	BaseCcy   string `json:"baseCcy"`
	Category  string `json:"category"`
	CtMult    string `json:"ctMult"`
	CtType    string `json:"ctType"`
	CtVal     string `json:"ctVal"`
	CtValCcy  string `json:"ctValCcy"`
	ExpTime   string `json:"expTime"`
	InstID    string `json:"instId"`
	InstType  string `json:"instType"`
	Lever     string `json:"lever"`
	ListTime  string `json:"listTime"`
	LotSz     string `json:"lotSz"`
	MinSz     string `json:"minSz"`
	OptType   string `json:"optType"`
	QuoteCcy  string `json:"quoteCcy"`
	SettleCcy string `json:"settleCcy"`
	State     string `json:"state"`
	Stk       string `json:"stk"`
	TickSz    string `json:"tickSz"`
	Uly       string `json:"uly"`
}

type OKEXWSResponse 

type OKEXWSResponse struct {
	Arg struct {
		Channel string `json:"channel"`
		InstID  string `json:"instId"`
	} `json:"arg"`
	Data []struct {
		InstID  string `json:"instId"`
		TradeID string `json:"tradeId"`
		Px      string `json:"px"`
		Sz      string `json:"sz"`
		Side    string `json:"side"`
		Ts      string `json:"ts"`
	} `json:"data"`
}

type OKExPairScraper 

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

OKExPairScraper implements PairScraper for OKEx exchange

func (*OKExPairScraper) Close 

func (ps *OKExPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*OKExPairScraper) Error 

func (ps *OKExPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*OKExPairScraper) Pair 

func (ps *OKExPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type OKExScraper 

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

func NewOKExScraper 

func NewOKExScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *OKExScraper

NewOKExScraper returns a new OKExScraper for the given pair

func (*OKExScraper) Channel 

func (s *OKExScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*OKExScraper) Close 

func (s *OKExScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*OKExScraper) FetchAvailablePairs 

func (s *OKExScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*OKExScraper) FillSymbolData 

func (s *OKExScraper) FillSymbolData(symbol string) (asset dia.Asset, err error)

func (*OKExScraper) NormalizePair 

func (s *OKExScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*OKExScraper) ScrapePair 

func (s *OKExScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type OrcaPairScraper added in v1.4.81 

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

func (*OrcaPairScraper) Close added in v1.4.81 

func (ps *OrcaPairScraper) Close() error

Close stops listening for trades of the pair associated with the scraper

func (*OrcaPairScraper) Error added in v1.4.81 

func (ps *OrcaPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*OrcaPairScraper) Pair added in v1.4.81 

func (ps *OrcaPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type OrcaScraper added in v1.4.81 

type OrcaScraper struct {
	RestClient *rpc.Client
	WsClient   *ws.Client
	// contains filtered or unexported fields
}

The scraper object for Orca

func NewOrcaScraper added in v1.4.81 

func NewOrcaScraper(exchange dia.Exchange, scrape bool) *OrcaScraper

Returns a new exchange scraper

func (*OrcaScraper) Channel added in v1.4.81 

func (s *OrcaScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*OrcaScraper) Close added in v1.4.81 

func (s *OrcaScraper) Close() error

Closes any existing API connections, as well as channels of pairScrapers from calls to ScrapePair

func (*OrcaScraper) FetchAvailablePairs added in v1.4.81 

func (s *OrcaScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

Returns the list of all available trade pairs in order to pairDiscoveryService service work

func (*OrcaScraper) FillSymbolData added in v1.4.81 

func (s *OrcaScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData adds the name to the asset underlying @symbol on scraper

func (*OrcaScraper) NormalizePair added in v1.4.81 

func (s *OrcaScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

NormalizePair accounts for the pair

func (*OrcaScraper) ScrapePair added in v1.4.81 

func (s *OrcaScraper) ScrapePair(pair dia.ExchangePair) (ps PairScraper, err error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from the scraper

type OrcaTokenMetadata added in v1.4.88 

type OrcaTokenMetadata interface {
	GetName() string
	GetSymbol() string
}

type OsmosisConfig added in v1.4.242 

type OsmosisConfig struct {
	Bech32AddrPrefix  string
	Bech32ValPrefix   string
	Bech32PkPrefix    string
	Bech32PkValPrefix string
	RpcURL            string
	WsURL             string
	Encoding          *OsmosisEncodingConfig
}

type OsmosisEncodingConfig added in v1.4.242 

type OsmosisEncodingConfig struct {
	InterfaceRegistry codectypes.InterfaceRegistry
	Marshaler         codec.Codec
	TxConfig          client.TxConfig
	Amino             *codec.LegacyAmino
}

func NewOsmosisEncoding added in v1.4.242 

func NewOsmosisEncoding() *OsmosisEncodingConfig

type OsmosisPairScraper added in v1.4.242 

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

OsmosisPairScraper implements PairScraper for Osmosis

func (*OsmosisPairScraper) Close added in v1.4.242 

func (ps *OsmosisPairScraper) Close() error

func (*OsmosisPairScraper) Error added in v1.4.242 

func (ps *OsmosisPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*OsmosisPairScraper) Pair added in v1.4.242 

func (ps *OsmosisPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type OsmosisScraper added in v1.4.242 

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

func NewOsmosisScraper added in v1.4.242 

func NewOsmosisScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *OsmosisScraper

NewOsmosisScraper returns a new OsmosisScraper initialized with default values. The instance is asynchronously scraping as soon as it is created.

func (*OsmosisScraper) Channel added in v1.4.242 

func (ps *OsmosisScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades/pricing information

func (*OsmosisScraper) Close added in v1.4.242 

func (s *OsmosisScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*OsmosisScraper) FetchAvailablePairs added in v1.4.242 

func (s *OsmosisScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs

func (*OsmosisScraper) FillSymbolData added in v1.4.242 

func (s *OsmosisScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*OsmosisScraper) GetBlock added in v1.4.242 

func (s *OsmosisScraper) GetBlock(height int) (*time.Time, error)

func (*OsmosisScraper) NormalizePair added in v1.4.242 

func (ps *OsmosisScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

NormalizePair accounts for the par

func (*OsmosisScraper) ScrapePair added in v1.4.242 

func (s *OsmosisScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

func (*OsmosisScraper) Start added in v1.4.242 

func (s *OsmosisScraper) Start() error

type PairScraper 

type PairScraper interface {
	io.Closer
	// Error returns an error when the channel Channel() is closed
	// and nil otherwise
	Error() error

	// Pair returns the pair this scraper is subscribed to
	Pair() dia.ExchangePair
}

PairScraper receives trades for a single pc.ExchangePair from a single exchange.

type PlatypusCoin added in v1.4.2 

type PlatypusCoin struct {
	Symbol   string
	Decimals uint8
	Address  string
	Name     string
}

type PlatypusPairScraper added in v1.4.2 

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

func (*PlatypusPairScraper) Close added in v1.4.2 

func (ps *PlatypusPairScraper) Close() error

Close stops listening for trades of the pair associated with the scraper

func (*PlatypusPairScraper) Error added in v1.4.2 

func (ps *PlatypusPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*PlatypusPairScraper) Pair added in v1.4.2 

func (ps *PlatypusPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type PlatypusPools added in v1.4.2 

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

type PlatypusScraper added in v1.4.2 

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

PlatypusScraper The scraper object for Platypus Finance

func NewPlatypusScraper added in v1.4.2 

func NewPlatypusScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *PlatypusScraper

NewPlatypusScraper Returns a new exchange scraper

func (*PlatypusScraper) Channel added in v1.4.2 

func (s *PlatypusScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*PlatypusScraper) Close added in v1.4.2 

func (s *PlatypusScraper) Close() error

Close Closes any existing API connections, as well as channels of pairScrapers from calls to ScrapePair

func (*PlatypusScraper) FetchAvailablePairs added in v1.4.2 

func (s *PlatypusScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

Returns the list of all available trade pairs

func (*PlatypusScraper) FillSymbolData added in v1.4.2 

func (s *PlatypusScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData adds the name to the asset underlying @symbol on scraper

func (*PlatypusScraper) NormalizePair added in v1.4.2 

func (s *PlatypusScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

NormalizePair accounts for the pair

func (*PlatypusScraper) ScrapePair added in v1.4.2 

func (s *PlatypusScraper) ScrapePair(pair dia.ExchangePair) (ps PairScraper, err error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from the scraper

type Pools 

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

type Response 

type Response struct {
	Channel string     `json:"channel"`
	Data    [][]string `json:"data"`
	Binary  int        `json:"binary"`
}

type ResponseGate 

type ResponseGate struct {
	Method string        `json:"method,omitempty"`
	Params []interface{} `json:"params,omitempty"`
	Id     interface{}   `json:"id,omitempty"`
}

type ResponseType 

type ResponseType struct {
	Id     string      `json:"id,omitempty"`
	Status string      `json:"status,omitempty"`
	Subbed string      `json:"subbed,omitempty"`
	Ts     int64       `json:"ts,omitempty"`
	Ping   int         `json:"ping,omitempty"`
	Ch     string      `json:"ch,omitempty"`
	Tick   interface{} `json:"tick,omitempty"`
}

type Responses 

type Responses []Response

type Subscribe 

type Subscribe struct {
	OP   string     `json:"op"`
	Args []OKEXArgs `json:"args"`
}

type SubscribeGate 

type SubscribeGate struct {
	Time    int64    `json:"time"`
	Channel string   `json:"channel"`
	Event   string   `json:"event"`
	Payload []string `json:"payload"`
}

type Token added in v1.4.329 

type Token struct {
	Address  common.Address
	Symbol   string
	Decimals uint8
	Name     string
}

type TraderJoePair added in v1.4.353 

type TraderJoePair struct {
	Token0      TraderJoeTokens
	Token1      TraderJoeTokens
	ForeignName string
	Address     common.Address
}

type TraderJoeScraper added in v1.4.353 

type TraderJoeScraper struct {
	// Ethereum WebSocket client for real-time data.
	WsClient *ethclient.Client
	// Ethereum REST client for querying historical data.
	RestClient *ethclient.Client
	// contains filtered or unexported fields
}

func NewTraderJoeScraper added in v1.4.353 

func NewTraderJoeScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *TraderJoeScraper

NewTraderJoeScraper initializes a Trader Joe scraper instance with the provided exchange information, scraping flag, and relational database connection. It configures parameters, sets up pool maps, and starts the scraping process if requested.

func (*TraderJoeScraper) Channel added in v1.4.353 

func (tjs *TraderJoeScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*TraderJoeScraper) Close added in v1.4.353 

func (tjs *TraderJoeScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*TraderJoeScraper) FetchAvailablePairs added in v1.4.357 

func (tjs *TraderJoeScraper) FetchAvailablePairs() ([]dia.ExchangePair, error)

func (*TraderJoeScraper) FillSymbolData added in v1.4.357 

func (tjs *TraderJoeScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*TraderJoeScraper) GetSwapsChannel added in v1.4.353 

func (tjs *TraderJoeScraper) GetSwapsChannel(pairAddress common.Address) (chan *traderjoeILBPair.ILBPairSwap, error)

GetSwapsChannel returns a channel for swaps of the pair with pair address.

func (*TraderJoeScraper) NormalizePair added in v1.4.357 

func (tjs *TraderJoeScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*TraderJoeScraper) ScrapePair added in v1.4.353 

func (tjs *TraderJoeScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair initiates a new scraping process for the specified dia.ExchangePair within the Trader Joe scraper. It checks for any previously encountered errors using a read lock on the error lock. If an error is present, it returns that error. Additionally, if the Trader Joe scraper has been closed, it returns an error indicating that ScrapePair cannot be called on a closed pair. Otherwise, it creates a new TraderJoeTradeScraper instance associated with the provided ExchangePair, adds it to the list of active pair scrapers, and returns it along with a nil error to indicate successful initiation.

type TraderJoeSwap added in v1.4.353 

type TraderJoeSwap struct {
	ID        string
	Timestamp int64
	Pair      TraderJoePair
	Amount0   float64
	Amount1   float64
}

type TraderJoeTokens added in v1.4.353 

type TraderJoeTokens struct {
	Address  common.Address
	Symbol   string
	Decimals uint8
	Name     string
}

type TraderJoeTradeScraper added in v1.4.353 

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

TraderJoeTradeScraper represents a scraper for collecting trade data associated with a specific dia.ExchangePair within the Trader Joe exchange.

func (TraderJoeTradeScraper) Close added in v1.4.353 

func (ps TraderJoeTradeScraper) Close() error

Close closes the TraderJoeTradeScraper instance.

func (TraderJoeTradeScraper) Error added in v1.4.353 

func (ps TraderJoeTradeScraper) Error() error

Error returns the error associated with the parent Trader Joe scraper. It retrieves the error from the parent scraper's state using a read lock on the error lock. This function is useful for obtaining any error that occurred during scraping tasks.

func (TraderJoeTradeScraper) Pair added in v1.4.353 

func (ps TraderJoeTradeScraper) Pair() dia.ExchangePair

Pair returns the dia.ExchangePair associated with the current Trader Joe trade scraper. It simply retrieves and returns the ExchangePair stored within the scraper's state.

type UniswapHistoryPairScraper 

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

UniswapPairScraper implements PairScraper for Uniswap

func (*UniswapHistoryPairScraper) Close 

func (ps *UniswapHistoryPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*UniswapHistoryPairScraper) Error 

func (ps *UniswapHistoryPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*UniswapHistoryPairScraper) Pair 

func (ps *UniswapHistoryPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type UniswapHistoryScraper 

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

func NewUniswapHistoryScraper 

func NewUniswapHistoryScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *UniswapHistoryScraper

NewUniswapScraper returns a new UniswapScraper for the given pair

func (*UniswapHistoryScraper) Channel 

func (ps *UniswapHistoryScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*UniswapHistoryScraper) Close 

func (s *UniswapHistoryScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*UniswapHistoryScraper) FetchAvailablePairs 

func (s *UniswapHistoryScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs as dia.ExchangePair for the pairDiscorvery service

func (*UniswapHistoryScraper) FillSymbolData 

func (s *UniswapHistoryScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData is not used by DEX scrapers.

func (*UniswapHistoryScraper) GetAllPairs 

func (s *UniswapHistoryScraper) GetAllPairs() ([]UniswapPair, error)

GetAllPairs is similar to FetchAvailablePairs. But instead of dia.ExchangePairs it returns all pairs as UniswapPairs, i.e. including the pair's address

func (*UniswapHistoryScraper) GetDecimals 

func (s *UniswapHistoryScraper) GetDecimals(tokenAddress common.Address) (decimals uint8, err error)

GetDecimals returns the decimals of the token with address @tokenAddress

func (*UniswapHistoryScraper) GetName 

func (s *UniswapHistoryScraper) GetName(tokenAddress common.Address) (name string, err error)

func (*UniswapHistoryScraper) GetPairByAddress 

func (s *UniswapHistoryScraper) GetPairByAddress(pairAddress common.Address) (pair UniswapPair, err error)

GetPairByAddress returns the UniswapPair with pair address @pairAddress

func (*UniswapHistoryScraper) GetPairByID 

func (s *UniswapHistoryScraper) GetPairByID(num int64) (UniswapPair, error)

GetPairByID returns the UniswapPair with the integer id @num

func (*UniswapHistoryScraper) NormalizePair 

func (up *UniswapHistoryScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*UniswapHistoryScraper) ScrapePair 

func (s *UniswapHistoryScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type UniswapPair 

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

type UniswapPairScraper 

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

UniswapPairScraper implements PairScraper for Uniswap

func (*UniswapPairScraper) Close 

func (ps *UniswapPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*UniswapPairScraper) Error 

func (ps *UniswapPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*UniswapPairScraper) Pair 

func (ps *UniswapPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type UniswapPairV3Scraper 

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

UniswapPairScraper implements PairScraper for Uniswap

func (*UniswapPairV3Scraper) Close 

func (ps *UniswapPairV3Scraper) Close() error

Close stops listening for trades of the pair associated with s

func (*UniswapPairV3Scraper) Error 

func (ps *UniswapPairV3Scraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*UniswapPairV3Scraper) Pair 

func (ps *UniswapPairV3Scraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type UniswapScraper 

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

func NewUniswapScraper 

func NewUniswapScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *UniswapScraper

NewUniswapScraper returns a new UniswapScraper for the given pair

func (*UniswapScraper) Channel 

func (ps *UniswapScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*UniswapScraper) Close 

func (s *UniswapScraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*UniswapScraper) FetchAvailablePairs 

func (s *UniswapScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs as dia.ExchangePair for the pairDiscorvery service

func (*UniswapScraper) FillSymbolData 

func (s *UniswapScraper) FillSymbolData(symbol string) (dia.Asset, error)

FillSymbolData is not used by DEX scrapers.

func (*UniswapScraper) GetAllPairs 

func (s *UniswapScraper) GetAllPairs() ([]UniswapPair, error)

GetAllPairs is similar to FetchAvailablePairs. But instead of dia.ExchangePairs it returns all pairs as UniswapPairs, i.e. including the pair's address

func (*UniswapScraper) GetDecimals 

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

GetDecimals returns the decimals of the token with address @tokenAddress

func (*UniswapScraper) GetName 

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

func (*UniswapScraper) GetPairByAddress 

func (s *UniswapScraper) GetPairByAddress(pairAddress common.Address) (pair UniswapPair, err error)

GetPairByAddress returns the UniswapPair with pair address @pairAddress

func (*UniswapScraper) GetPairByID 

func (s *UniswapScraper) GetPairByID(num int64) (UniswapPair, error)

GetPairByID returns the UniswapPair with the integer id @num

func (*UniswapScraper) GetSwapsChannel 

func (s *UniswapScraper) GetSwapsChannel(pairAddress common.Address) (chan *uniswap.UniswapV2PairSwap, error)

GetSwapsChannel returns a channel for swaps of the pair with address @pairAddress

func (*UniswapScraper) ListenToPair added in v1.3.4 

func (s *UniswapScraper) ListenToPair(i int, address common.Address)

ListenToPair subscribes to a uniswap pool. If @byAddress is true, it listens by pool address, otherwise by index.

func (*UniswapScraper) NormalizePair 

func (up *UniswapScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*UniswapScraper) ScrapePair 

func (s *UniswapScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type UniswapSwap 

type UniswapSwap struct {
	ID         string
	Timestamp  int64
	Pair       UniswapPair
	Amount0In  float64
	Amount0Out float64
	Amount1In  float64
	Amount1Out float64
}

type UniswapToken 

type UniswapToken struct {
	Address  common.Address
	Symbol   string
	Decimals uint8
	Name     string
}

type UniswapV3Scraper 

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

func NewUniswapV3Scraper 

func NewUniswapV3Scraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *UniswapV3Scraper

NewUniswapV3Scraper returns a new UniswapV3Scraper

func (*UniswapV3Scraper) Channel 

func (s *UniswapV3Scraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*UniswapV3Scraper) Close 

func (s *UniswapV3Scraper) Close() error

Close closes any existing API connections, as well as channels of PairScrapers from calls to ScrapePair

func (*UniswapV3Scraper) FetchAvailablePairs 

func (s *UniswapV3Scraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

FetchAvailablePairs returns a list with all available trade pairs as dia.Pair for the pairDiscorvery service

func (*UniswapV3Scraper) FillSymbolData 

func (s *UniswapV3Scraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*UniswapV3Scraper) GetDecimals 

func (s *UniswapV3Scraper) GetDecimals(tokenAddress common.Address) (decimals uint8, err error)

GetDecimals returns the decimals of the token with address @tokenAddress

func (*UniswapV3Scraper) GetPairByTokenAddress 

func (s *UniswapV3Scraper) GetPairByTokenAddress(address0 common.Address, address1 common.Address, pairAddress common.Address) (pair UniswapPair, err error)

func (*UniswapV3Scraper) GetPairData 

func (s *UniswapV3Scraper) GetPairData(poolEvent *uniswapcontractv3.UniswapV3PoolCreated) (UniswapPair, error)

GetPairByID returns the UniswapPair with the integer id @num

func (*UniswapV3Scraper) GetPancakeSwapsChannel added in v1.4.301 

func (s *UniswapV3Scraper) GetPancakeSwapsChannel(pairAddress common.Address) (chan *PancakeswapV3Pair.Pancakev3pairSwap, error)

func (*UniswapV3Scraper) GetSwapsChannel 

func (s *UniswapV3Scraper) GetSwapsChannel(pairAddress common.Address) (chan *UniswapV3Pair.UniswapV3PairSwap, error)

GetSwapsChannel returns a channel for swaps of the pair with address @pairAddress

func (*UniswapV3Scraper) NormalizePair 

func (s *UniswapV3Scraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*UniswapV3Scraper) ScrapePair 

func (s *UniswapV3Scraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

ScrapePair returns a PairScraper that can be used to get trades for a single pair from this APIScraper

type UniswapV3Swap 

type UniswapV3Swap struct {
	ID        string
	Timestamp int64
	Pair      UniswapPair
	Amount0   float64
	Amount1   float64
}

type ValueByAttribute added in v1.4.242 

type ValueByAttribute map[string]string

Contains info about an attribute value keyed by attribute type

type VelodromePairScraper added in v1.4.325 

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

func (*VelodromePairScraper) Close added in v1.4.325 

func (ps *VelodromePairScraper) Close() error

func (*VelodromePairScraper) Error added in v1.4.325 

func (ps *VelodromePairScraper) Error() error

func (*VelodromePairScraper) Pair added in v1.4.325 

func (ps *VelodromePairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type VelodromeScraper added in v1.4.325 

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

func NewVelodromeScraper added in v1.4.325 

func NewVelodromeScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *VelodromeScraper

func (*VelodromeScraper) Channel added in v1.4.325 

func (s *VelodromeScraper) Channel() chan *dia.Trade

func (*VelodromeScraper) Close added in v1.4.325 

func (s *VelodromeScraper) Close() error

func (*VelodromeScraper) FetchAvailablePairs added in v1.4.325 

func (s *VelodromeScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*VelodromeScraper) FillSymbolData added in v1.4.325 

func (s *VelodromeScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*VelodromeScraper) GetSwapsChannel added in v1.4.325 

func (s *VelodromeScraper) GetSwapsChannel(pairAddress common.Address) (chan *velodrome.IPoolSwap, error)

GetSwapsChannel returns a channel for swaps of the pair with address @pairAddress

func (*VelodromeScraper) NormalizePair added in v1.4.325 

func (up *VelodromeScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*VelodromeScraper) ScrapePair added in v1.4.325 

func (s *VelodromeScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

func (*VelodromeScraper) WatchSwaps added in v1.4.325 

func (s *VelodromeScraper) WatchSwaps(pool dia.Pool)

type VelodromeSwap added in v1.4.325 

type VelodromeSwap struct {
	ID         string
	Timestamp  int64
	IndexIn    int
	IndexOut   int
	Amount0In  float64
	Amount0Out float64
	Amount1In  float64
	Amount1Out float64
}

type XMLCube 

type XMLCube struct {
	XMLName  xml.Name `xml:"Cube"`
	Currency string   `xml:"currency,attr"`
	Rate     string   `xml:"rate,attr"`
}

type XMLCubeTime 

type XMLCubeTime struct {
	XMLName xml.Name  `xml:"Cube"`
	Time    string    `xml:"time,attr"`
	Cube    []XMLCube `xml:"Cube"`
}

type XMLEnvelope 

type XMLEnvelope struct {
	XMLName  xml.Name      `xml:"Envelope"`
	CubeTime []XMLCubeTime `xml:"Cube>Cube"`
}

type XMLHistoricalEnvelope 

type XMLHistoricalEnvelope struct {
	XMLName xml.Name `xml:"GenericData"`
	Obs     []XMLObs `xml:"DataSet>Series>Obs"`
}

type XMLObs 

type XMLObs struct {
	XMLName   xml.Name        `xml:"Obs"`
	Timestamp XMLObsDimension `xml:"ObsDimension"`
	Price     XMLObsValue     `xml:"ObsValue"`
}

type XMLObsDimension 

type XMLObsDimension struct {
	XMLName xml.Name `xml:"ObsDimension"`
	Value   string   `xml:"value,attr"`
}

type XMLObsValue 

type XMLObsValue struct {
	XMLName xml.Name `xml:"ObsValue"`
	Value   string   `xml:"value,attr"`
}

type ZenlinkPair added in v1.4.247 

type ZenlinkPair struct {
	Symbol                string `json:"symbol"`
	DisplayName           string `json:"displayName"`
	BaseAsset             string `json:"baseAsset"`
	QuoteAsset            string `json:"quoteAsset"`
	Status                string `json:"status"`
	MinNotional           string `json:"minNotional"`
	MaxNotional           string `json:"maxNotional"`
	MarginTradable        bool   `json:"marginTradable"`
	CommissionType        string `json:"commissionType"`
	CommissionReserveRate string `json:"commissionReserveRate"`
	TickSize              string `json:"tickSize"`
	LotSize               string `json:"lotSize"`
}

type ZenlinkPairResponse added in v1.4.247 

type ZenlinkPairResponse struct {
	Code int           `json:"code"`
	Data []ZenlinkPair `json:"data"`
}

type ZenlinkPairScraper added in v1.4.247 

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

func (*ZenlinkPairScraper) Close added in v1.4.247 

func (ps *ZenlinkPairScraper) Close() error

Close stops listening for trades of the pair associated with s

func (*ZenlinkPairScraper) Error added in v1.4.247 

func (ps *ZenlinkPairScraper) Error() error

Error returns an error when the channel Channel() is closed and nil otherwise

func (*ZenlinkPairScraper) Pair added in v1.4.247 

func (ps *ZenlinkPairScraper) Pair() dia.ExchangePair

Pair returns the pair this scraper is subscribed to

type ZenlinkScraper added in v1.4.247 

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

func NewZenlinkScraper added in v1.4.247 

func NewZenlinkScraper(exchange dia.Exchange, scrape bool) *ZenlinkScraper

func (*ZenlinkScraper) Channel added in v1.4.247 

func (ps *ZenlinkScraper) Channel() chan *dia.Trade

Channel returns a channel that can be used to receive trades

func (*ZenlinkScraper) Close added in v1.4.247 

func (s *ZenlinkScraper) Close() error

func (*ZenlinkScraper) FetchAvailablePairs added in v1.4.247 

func (s *ZenlinkScraper) FetchAvailablePairs() (pairs []dia.ExchangePair, err error)

func (*ZenlinkScraper) FillSymbolData added in v1.4.247 

func (s *ZenlinkScraper) FillSymbolData(symbol string) (dia.Asset, error)

func (*ZenlinkScraper) NormalizePair added in v1.4.247 

func (s *ZenlinkScraper) NormalizePair(pair dia.ExchangePair) (dia.ExchangePair, error)

func (*ZenlinkScraper) ScrapePair added in v1.4.247 

func (scraper *ZenlinkScraper) ScrapePair(pair dia.ExchangePair) (PairScraper, error)

Source Files

View all Source files

Directories

Path Synopsis
balancerv2
vault
BancorNetwork
ConverterTypeFour
ConverterTypeOne
ConverterTypeThree
ConverterTypeZero
camelotv3pair
curvepool
token
maverick
pairfactory
pool
position
orca
whirlpool
asset
pool
token
traderjoeILBPair
uniswapV3Pair

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.