Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

fetcher

package

Go to main page

Versions in this module

v1

v1.1.2

Apr 25, 2019

Changes in this version

type Fetcher

+ func (self *Fetcher) CheckStatus(listToken, listFailed []ethereum.Token) []ethereum.Token

+ func (self *Fetcher) GetArrToken() []ethereum.Token

+ func (self *Fetcher) GetMapBadToken() map[string]ethereum.Token

+ func (self *Fetcher) GetMapGoodToken() map[string]ethereum.Token

+ func (self *Fetcher) GetRateBuy(mapToken map[string]ethereum.Token) ([]ethereum.Rate, error)

+ func (self *Fetcher) UpdateListStatusToken(mapGoodToken, mapBadToken map[string]ethereum.Token)

type InfoData

+ func (self *InfoData) GetArrToken() []ethereum.Token

+ func (self *InfoData) GetMapBadToken() map[string]ethereum.Token

+ func (self *InfoData) GetMapGoodToken() map[string]ethereum.Token

+ func (self *InfoData) UpdateListStatusToken(mapGoodToken, mapBadToken map[string]ethereum.Token)

v1.1.1

Apr 18, 2019

Changes in this version

+ const API_KEY_TRACKER

+ const ETH_TO_WEI

+ const KEY

+ const MIN_ETH

+ const TIME_TO_DELETE

+ type Connection struct

+ Apikey string

+ Endpoint string

+ Type string

+ type Ethereum struct

+ func NewEthereum(network string, networkAbiStr string, tradeTopic string, wrapper string, ...) (*Ethereum, error)

+ func (self *Ethereum) EncodeKyberEnable() (string, error)

+ func (self *Ethereum) EncodeMaxGasPrice() (string, error)

+ func (self *Ethereum) EncodeRateData(source, dest string, quantity *big.Int) (string, error)

+ func (self *Ethereum) EncodeRateDataWrapper(source, dest []string, quantity []*big.Int) (string, error)

+ func (self *Ethereum) ExtractEnabled(result string) (bool, error)

+ func (self *Ethereum) ExtractMaxGasPrice(result string) (string, error)

+ func (self *Ethereum) ExtractRateData(result string, sourceSymbol, destSymbol string) (ethereum.Rate, error)

+ func (self *Ethereum) ExtractRateDataWrapper(result string, sourceArr, destAddr []string) ([]ethereum.Rate, error)

+ func (self *Ethereum) Gettimestamp(block string, latestBlock string, averageBlockTime int64) (string, error)

+ func (self *Ethereum) IsSmallAmount(eventRaw ethereum.EventRaw) (bool, error)

+ func (self *Ethereum) ReadEvents(listEventAddr *[]ethereum.EventRaw, typeFetch string, latestBlock string) (*[]ethereum.EventHistory, error)

+ func (self *Ethereum) ReadEventsWithBlockNumber(eventRaw *[]ethereum.EventRaw, latestBlock string) (*[]ethereum.EventHistory, error)

+ func (self *Ethereum) ReadEventsWithTimeStamp(eventRaw *[]ethereum.EventRaw) (*[]ethereum.EventHistory, error)

+ type Fetcher struct

+ func NewFetcher(kyberENV string) (*Fetcher, error)

+ func (self *Fetcher) CheckKyberEnable() (bool, error)

+ func (self *Fetcher) FetchRate7dData() (map[string]*ethereum.Rates, error)

+ func (self *Fetcher) FetchUserInfo(address string) (*common.UserInfo, error)

+ func (self *Fetcher) GetGasPrice() (*ethereum.GasPrice, error)

+ func (self *Fetcher) GetGeneralInfoTokens() map[string]*ethereum.TokenGeneralInfo

+ func (self *Fetcher) GetLatestBlock() (string, error)

+ func (self *Fetcher) GetListToken() map[string]ethereum.Token

+ func (self *Fetcher) GetListTokenAPI() []ethereum.TokenAPI

+ func (self *Fetcher) GetListTokenPriority() map[string]ethereum.Token

+ func (self *Fetcher) GetMaxGasPrice() (string, error)

+ func (self *Fetcher) GetNumTokens() int

+ func (self *Fetcher) GetRate(currentRate []ethereum.Rate, isNewRate bool, ...) ([]ethereum.Rate, error)

+ func (self *Fetcher) GetRateUsdEther() (string, error)

+ func (self *Fetcher) GetStepRate() ([]ethereum.StepRate, error)

+ func (self *Fetcher) GetTokenBySymbol(symbol string) (*ethereum.Token, error)

+ func (self *Fetcher) TryUpdateListToken() error

+ func (self *Fetcher) UpdateListToken() error

+ type FetcherInterface interface

+ EthCall func(string, string) (string, error)

+ GetLatestBlock func() (string, error)

+ GetRate func(string, string) (string, error)

+ GetTypeName func() string

+ func NewFetcherIns(typeName string, endpoint string, apiKey string) (FetcherInterface, error)

+ type GasStation struct

+ Fast float64

+ Low float64

+ Standard float64

+ type HTTPFetcher struct

+ func NewHTTPFetcher(tradingAPIEndpoint, gasStationEndpoint, apiEndpoint string) *HTTPFetcher

+ func (self *HTTPFetcher) GetGasPrice() (*ethereum.GasPrice, error)

+ func (self *HTTPFetcher) GetListToken() ([]ethereum.Token, error)

+ func (self *HTTPFetcher) GetRate7dData() (map[string]*ethereum.Rates, error)

+ func (self *HTTPFetcher) GetRateUsdEther() (string, error)

+ func (self *HTTPFetcher) GetUserInfo(url string) (*common.UserInfo, error)

+ type InfoData struct

+ APIEndpoint string

+ ApiUsd string

+ AverageBlockTime int64

+ BackupTokens map[string]ethereum.Token

+ CanDeleteToken []string

+ CoinMarket []string

+ ConfigEndpoint string

+ Connections []Connection

+ EthAdress string

+ EthSymbol string

+ GasStationEndpoint string

+ Network string

+ NetworkAbi string

+ RateCache []string

+ TokenAPI []ethereum.TokenAPI

+ TokenPriority map[string]ethereum.Token

+ Tokens map[string]ethereum.Token

+ TradeTopic string

+ UserStatsEndpoint string

+ Wapper string

+ WrapperAbi string

+ func (self *InfoData) GetListToken() map[string]ethereum.Token

+ func (self *InfoData) GetListTokenPriority() map[string]ethereum.Token

+ func (self *InfoData) GetTokenAPI() []ethereum.TokenAPI

+ func (self *InfoData) UpdateByBackupToken()

+ func (self *InfoData) UpdateListToken(tokens, tokenPriority map[string]ethereum.Token)

+ type LogData struct

+ ActualDestAmount *big.Int

+ ActualSrcAmount *big.Int

+ Dest common.Address

+ Source common.Address

+ type MarketFetcherInterface interface

+ GetGeneralInfo func(string) (*ethereum.TokenGeneralInfo, error)

+ GetRateUsdEther func() (string, error)

+ func NewMarketFetcherInterface() MarketFetcherInterface

+ type RateNetwork struct

+ ExpectedRate *big.Int

+ SlippageRate *big.Int

+ type RateUSD struct

+ PriceUsd string

+ Symbol string

+ type RateWrapper struct

+ ExpectedRate []*big.Int

+ SlippageRate []*big.Int

+ type TokenPrice struct

+ Data []struct{ ... }

+ Error bool

+ TimeUpdate uint64