Versions in this module Expand all Collapse all v0 v0.7.0 Dec 17, 2018 Changes in this version + type RateStorage struct + func NewRateInfluxDBStorage(sugar *zap.SugaredLogger, client influxClient.Client, dbName string, ...) (*RateStorage, error) + func (rs *RateStorage) GetRatesByTimePoint(addrs []ethereum.Address, fromTime, toTime uint64) (map[string]map[string][]common.ReserveRates, error) + func (rs *RateStorage) LastBlock() (int64, error) + func (rs *RateStorage) UpdateRatesRecords(blockNumber uint64, rateRecords map[string]map[string]common.ReserveRateEntry) error + type RateStorageOption func(rs *RateStorage) + func RateStorageOptionWithRetentionPolicy(duration, shardDuration time.Duration) RateStorageOption