Versions in this module Expand all Collapse all v0 v0.1.1 Jan 8, 2019 v0.1.0 Dec 6, 2017 Changes in this version + const ACTIVITY_BUCKET + const BALANCE_BUCKET + const EXCHANGE_BALANCE_BUCKET + const ORDER_BUCKET + const PENDING_ACTIVITY_BUCKET + const PRICE_BUCKET + const RATE_BUCKET + type BoltStorage struct + func NewBoltStorage(path string) (*BoltStorage, error) + func (self *BoltStorage) CurrentBalanceVersion(timepoint uint64) (common.Version, error) + func (self *BoltStorage) CurrentEBalanceVersion(timepoint uint64) (common.Version, error) + func (self *BoltStorage) CurrentPriceVersion(timepoint uint64) (common.Version, error) + func (self *BoltStorage) CurrentRateVersion(timepoint uint64) (common.Version, error) + func (self *BoltStorage) GetAllBalances(version common.Version) (map[string]common.BalanceEntry, error) + func (self *BoltStorage) GetAllEBalances(version common.Version) (map[common.ExchangeID]common.EBalanceEntry, error) + func (self *BoltStorage) GetAllPrices(version common.Version) (map[common.TokenPairID]common.OnePrice, error) + func (self *BoltStorage) GetAllRates(version common.Version) (common.AllRateEntry, error) + func (self *BoltStorage) GetAllRecords() ([]common.ActivityRecord, error) + func (self *BoltStorage) GetOnePrice(pair common.TokenPairID, version common.Version) (common.OnePrice, error) + func (self *BoltStorage) GetPendingActivities() ([]common.ActivityRecord, error) + func (self *BoltStorage) Record(action string, id common.ActivityID, destination string, ...) error + func (self *BoltStorage) StoreBalance(data map[string]common.BalanceEntry, timepoint uint64) error + func (self *BoltStorage) StoreEBalance(data map[common.ExchangeID]common.EBalanceEntry, timepoint uint64) error + func (self *BoltStorage) StorePrice(data map[common.TokenPairID]common.OnePrice, timepoint uint64) error + func (self *BoltStorage) StoreRate(data common.AllRateEntry, timepoint uint64) error + func (self *BoltStorage) UpdateActivityStatus(action string, id common.ActivityID, destination string, status string) error + type RamActivityStorage struct + func NewRamActivityStorage() *RamActivityStorage + func (self *RamActivityStorage) GetAllRecords() ([]common.ActivityRecord, error) + func (self *RamActivityStorage) GetPendingRecords() ([]common.ActivityRecord, error) + func (self *RamActivityStorage) StoreNewData(action string, id common.ActivityID, destination string, ...) error + func (self *RamActivityStorage) UpdateActivityStatus(action string, id common.ActivityID, destination string, status string) error + type RamBalanceStorage struct + func NewRamBalanceStorage() *RamBalanceStorage + func (self *RamBalanceStorage) CurrentVersion(timepoint uint64) (int64, error) + func (self *RamBalanceStorage) GetAllBalances(version int64) (map[string]common.BalanceEntry, error) + func (self *RamBalanceStorage) StoreNewData(data map[string]common.BalanceEntry, timepoint uint64) error + type RamEBalanceStorage struct + func NewRamEBalanceStorage() *RamEBalanceStorage + func (self *RamEBalanceStorage) CurrentVersion(timepoint uint64) (int64, error) + func (self *RamEBalanceStorage) GetAllBalances(version int64) (map[common.ExchangeID]common.EBalanceEntry, error) + func (self *RamEBalanceStorage) StoreNewData(data map[common.ExchangeID]common.EBalanceEntry, timepoint uint64) error + type RamPriceStorage struct + func NewRamPriceStorage() *RamPriceStorage + func (self *RamPriceStorage) CurrentVersion(timepoint uint64) (int64, error) + func (self *RamPriceStorage) GetAllPrices(version int64) (map[common.TokenPairID]common.OnePrice, error) + func (self *RamPriceStorage) GetOnePrice(pair common.TokenPairID, version int64) (common.OnePrice, error) + func (self *RamPriceStorage) StoreNewData(data map[common.TokenPairID]common.OnePrice, timepoint uint64) error + type RamRateStorage struct + func NewRamRateStorage() *RamRateStorage + func (self *RamRateStorage) CurrentVersion(timepoint uint64) (int64, error) + func (self *RamRateStorage) GetRates(version int64) (common.AllRateEntry, error) + func (self *RamRateStorage) StoreNewData(data common.AllRateEntry, timepoint uint64) error + type RamStorage struct + func NewRamStorage() *RamStorage + func (self *RamStorage) CurrentBalanceVersion(timepoint uint64) (common.Version, error) + func (self *RamStorage) CurrentEBalanceVersion(timepoint uint64) (common.Version, error) + func (self *RamStorage) CurrentPriceVersion(timepoint uint64) (common.Version, error) + func (self *RamStorage) CurrentRateVersion(timepoint uint64) (common.Version, error) + func (self *RamStorage) GetAllBalances(version common.Version) (map[string]common.BalanceEntry, error) + func (self *RamStorage) GetAllEBalances(version common.Version) (map[common.ExchangeID]common.EBalanceEntry, error) + func (self *RamStorage) GetAllPrices(version common.Version) (map[common.TokenPairID]common.OnePrice, error) + func (self *RamStorage) GetAllRates(version common.Version) (common.AllRateEntry, error) + func (self *RamStorage) GetAllRecords() ([]common.ActivityRecord, error) + func (self *RamStorage) GetOnePrice(pair common.TokenPairID, version common.Version) (common.OnePrice, error) + func (self *RamStorage) GetPendingActivities() ([]common.ActivityRecord, error) + func (self *RamStorage) Record(action string, id common.ActivityID, destination string, ...) error + func (self *RamStorage) StoreBalance(data map[string]common.BalanceEntry, timepoint uint64) error + func (self *RamStorage) StoreEBalance(data map[common.ExchangeID]common.EBalanceEntry, timepoint uint64) error + func (self *RamStorage) StorePrice(data map[common.TokenPairID]common.OnePrice, timepoint uint64) error + func (self *RamStorage) StoreRate(data common.AllRateEntry, timepoint uint64) error + func (self *RamStorage) UpdateActivityStatus(action string, id common.ActivityID, destination string, status string) error