Versions in this module Expand all Collapse all v0 v0.7.0 Dec 17, 2018 Changes in this version + type InfluxStorage struct + func NewInfluxStorage(sugar *zap.SugaredLogger, dbName string, influxClient client.Client, ...) (*InfluxStorage, error) + func (is *InfluxStorage) GetAggregatedBurnFee(from, to time.Time, freq string, reserveAddrs []ethereum.Address) (map[ethereum.Address]map[string]float64, error) + func (is *InfluxStorage) GetAggregatedWalletFee(reserveAddr, walletAddr, freq string, fromTime, toTime time.Time, ...) (map[uint64]float64, error) + func (is *InfluxStorage) GetAssetVolume(token core.Token, fromTime, toTime time.Time, frequency string) (map[uint64]*common.VolumeStats, error) + func (is *InfluxStorage) GetCountryStats(countryCode string, from, to time.Time, timezone int8) (map[uint64]*common.CountryStats, error) + func (is *InfluxStorage) GetIntegrationVolume(fromTime, toTime time.Time) (map[uint64]*common.IntegrationVolume, error) + func (is *InfluxStorage) GetReserveVolume(rsvAddr ethereum.Address, token core.Token, fromTime, toTime time.Time, ...) (map[uint64]*common.VolumeStats, error) + func (is *InfluxStorage) GetTokenHeatmap(asset core.Token, from, to time.Time, timezone int8) (map[string]common.Heatmap, error) + func (is *InfluxStorage) GetTradeSummary(from, to time.Time, timezone int8) (map[uint64]*common.TradeSummary, error) + func (is *InfluxStorage) GetUserList(fromTime, toTime time.Time, timezone int8) ([]common.UserInfo, error) + func (is *InfluxStorage) GetUserVolume(userAddress ethereum.Address, from, to time.Time, freq string) (map[uint64]common.UserVolume, error) + func (is *InfluxStorage) GetWalletStats(from, to time.Time, walletAddr string, timezone int8) (map[uint64]common.WalletStats, error) + func (is *InfluxStorage) LoadTradeLogs(from, to time.Time) ([]common.TradeLog, error) + func (is *InfluxStorage) SaveTradeLogs(logs []common.TradeLog) error + func (is InfluxStorage) LastBlock() (int64, error) + type Interface interface + GetAggregatedBurnFee func(from, to time.Time, freq string, reserveAddrs []ethereum.Address) (map[ethereum.Address]map[string]float64, error) + GetAggregatedWalletFee func(reserveAddr, walletAddr, freq string, fromTime, toTime time.Time, ...) (map[uint64]float64, error) + GetAssetVolume func(token core.Token, fromTime, toTime time.Time, frequency string) (map[uint64]*common.VolumeStats, error) + GetCountryStats func(countryCode string, from, to time.Time, timezone int8) (map[uint64]*common.CountryStats, error) + GetIntegrationVolume func(fromTime, toTime time.Time) (map[uint64]*common.IntegrationVolume, error) + GetReserveVolume func(rsvAddr ethereum.Address, token core.Token, fromTime, toTime time.Time, ...) (map[uint64]*common.VolumeStats, error) + GetTokenHeatmap func(asset core.Token, from, to time.Time, timezone int8) (map[string]common.Heatmap, error) + GetTradeSummary func(from, to time.Time, timezone int8) (map[uint64]*common.TradeSummary, error) + GetUserList func(from, to time.Time, timezone int8) ([]common.UserInfo, error) + GetUserVolume func(userAddr ethereum.Address, from, to time.Time, freq string) (map[uint64]common.UserVolume, error) + GetWalletStats func(fromTime, toTime time.Time, walletAddr string, timezone int8) (map[uint64]common.WalletStats, error) + LastBlock func() (int64, error) + LoadTradeLogs func(from, to time.Time) ([]common.TradeLog, error) + SaveTradeLogs func(logs []common.TradeLog) error + type UserKYCChecker struct + func NewUserKYCChecker(sugar *zap.SugaredLogger, db *sqlx.DB) *UserKYCChecker + func (c *UserKYCChecker) IsKYCed(userAddr common.Address, ts time.Time) (bool, error)
Go to main page