persister

package

v1.1.2 Latest Latest Go to latest Published: Apr 25, 2019 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/KyberNetwork/wallet-cache

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func CalculateRateUSD(rateEther string, rateUSD string) (string, error)
type BoltInterface
type BoltStorage
- func NewBoltStorage() (*BoltStorage, error)
- func (bs *BoltStorage) GetGeneralInfo(mapToken map[string]ethereum.Token) (map[string]*ethereum.TokenGeneralInfo, error)
- func (bs *BoltStorage) StoreGeneralInfo(mapInfo map[string]*ethereum.TokenGeneralInfo) error
type Persister
- func NewPersister(name string) (Persister, error)
type RamPersister
- func NewRamPersister() (*RamPersister, error)
type RateUSD

Constants ¶

View Source

const (
	STEP_SAVE_RATE      = 10 //1 minute
	MAXIMUM_SAVE_RECORD = 60 //60 records

	INTERVAL_UPDATE_KYBER_ENABLE       = 20
	INTERVAL_UPDATE_MAX_GAS            = 70
	INTERVAL_UPDATE_GAS                = 40
	INTERVAL_UPDATE_RATE_USD           = 610
	INTERVAL_UPDATE_GENERAL_TOKEN_INFO = 3600
	INTERVAL_UPDATE_GET_BLOCKNUM       = 20
	INTERVAL_UPDATE_GET_RATE           = 30
	INTERVAL_UPDATE_DATA_TRACKER       = 310
)

Variables ¶

This section is empty.

Functions ¶

func CalculateRateUSD ¶

func CalculateRateUSD(rateEther string, rateUSD string) (string, error)

Types ¶

type BoltInterface ¶

type BoltInterface interface {
	StoreGeneralInfo(map[string]*ethereum.TokenGeneralInfo) error
	GetGeneralInfo(map[string]ethereum.Token) (map[string]*ethereum.TokenGeneralInfo, error)
}

type BoltStorage ¶

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

BoltStorage storage for cache

func NewBoltStorage ¶

func NewBoltStorage() (*BoltStorage, error)

NewBoltStorage make bolt instance

func (*BoltStorage) GetGeneralInfo ¶

func (bs *BoltStorage) GetGeneralInfo(mapToken map[string]ethereum.Token) (map[string]*ethereum.TokenGeneralInfo, error)

GetGeneralInfo store market info

func (*BoltStorage) StoreGeneralInfo ¶

func (bs *BoltStorage) StoreGeneralInfo(mapInfo map[string]*ethereum.TokenGeneralInfo) error

StoreGeneralInfo store market info

type Persister ¶

type Persister interface {
	GetRate() []ethereum.Rate
	GetIsNewRate() bool
	SetIsNewRate(bool)
	GetTimeUpdateRate() int64

	SaveRate([]ethereum.Rate, int64)

	SaveGeneralInfoTokens(map[string]*ethereum.TokenGeneralInfo)
	GetTokenInfo() map[string]*ethereum.TokenGeneralInfo

	GetLatestBlock() string
	GetIsNewLatestBlock() bool
	SaveLatestBlock(string) error
	SetNewLatestBlock(bool)

	GetRateUSD() []RateUSD
	GetRateETH() string
	GetIsNewRateUSD() bool
	SaveRateUSD(string) error
	SetNewRateUSD(bool)

	SaveKyberEnabled(bool)
	SetNewKyberEnabled(bool)
	GetKyberEnabled() bool
	GetNewKyberEnabled() bool

	SetNewMaxGasPrice(bool)
	SaveMaxGasPrice(string)
	GetMaxGasPrice() string
	GetNewMaxGasPrice() bool

	SaveGasPrice(*ethereum.GasPrice)
	SetNewGasPrice(bool)
	GetGasPrice() *ethereum.GasPrice
	GetNewGasPrice() bool

	SaveMarketData(rates map[string]*ethereum.Rates, mapTokenInfo map[string]*ethereum.TokenGeneralInfo, tokens map[string]ethereum.Token)
	GetRightMarketData() map[string]*ethereum.RightMarketInfo
	// GetRightMarketDataCG() map[string]*ethereum.RightMarketInfo
	GetLast7D(listTokens string) map[string][]float64
	GetIsNewTrackerData() bool
	SetIsNewTrackerData(isNewTrackerData bool)
	SetIsNewMarketInfo(isNewMarketInfo bool)
	GetIsNewMarketInfo() bool
	// GetIsNewMarketInfoCG() bool
	GetTimeVersion() string

	IsFailedToFetchTracker() bool

	SaveStepRate([]ethereum.StepRate)
	ResetStepRate()
	GetStepRate() []ethereum.StepRate
}

func NewPersister ¶

func NewPersister(name string) (Persister, error)

type RamPersister ¶

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

func NewRamPersister ¶

func NewRamPersister() (*RamPersister, error)

func (*RamPersister) GetGasPrice ¶

func (self *RamPersister) GetGasPrice() *ethereum.GasPrice

func (*RamPersister) GetIsNewLatestBlock ¶

func (self *RamPersister) GetIsNewLatestBlock() bool

func (*RamPersister) GetIsNewMarketInfo ¶

func (self *RamPersister) GetIsNewMarketInfo() bool

func (*RamPersister) GetIsNewRate ¶

func (self *RamPersister) GetIsNewRate() bool

func (*RamPersister) GetIsNewRateUSD ¶

func (self *RamPersister) GetIsNewRateUSD() bool

func (*RamPersister) GetIsNewTrackerData ¶

func (self *RamPersister) GetIsNewTrackerData() bool

func (*RamPersister) GetKyberEnabled ¶

func (self *RamPersister) GetKyberEnabled() bool

func (*RamPersister) GetLast7D ¶

func (self *RamPersister) GetLast7D(listTokens string) map[string][]float64

func (*RamPersister) GetLatestBlock ¶

func (self *RamPersister) GetLatestBlock() string

func (*RamPersister) GetMaxGasPrice ¶

func (self *RamPersister) GetMaxGasPrice() string

func (*RamPersister) GetNewGasPrice ¶

func (self *RamPersister) GetNewGasPrice() bool

func (*RamPersister) GetNewKyberEnabled ¶

func (self *RamPersister) GetNewKyberEnabled() bool

func (*RamPersister) GetNewMaxGasPrice ¶

func (self *RamPersister) GetNewMaxGasPrice() bool

func (*RamPersister) GetRate ¶

func (self *RamPersister) GetRate() []ethereum.Rate

///------------------------------

func (*RamPersister) GetRateETH ¶

func (self *RamPersister) GetRateETH() string

func (*RamPersister) GetRateUSD ¶

func (self *RamPersister) GetRateUSD() []RateUSD

func (*RamPersister) GetRightMarketData ¶

func (self *RamPersister) GetRightMarketData() map[string]*ethereum.RightMarketInfo

use this api for 3 infomations change, marketcap, volume

func (*RamPersister) GetStepRate ¶

func (self *RamPersister) GetStepRate() []ethereum.StepRate

func (*RamPersister) GetTimeUpdateRate ¶

func (self *RamPersister) GetTimeUpdateRate() int64

func (*RamPersister) GetTimeVersion ¶

func (self *RamPersister) GetTimeVersion() string

func (*RamPersister) GetTokenInfo ¶

func (self *RamPersister) GetTokenInfo() map[string]*ethereum.TokenGeneralInfo

func (*RamPersister) IsFailedToFetchTracker ¶

func (self *RamPersister) IsFailedToFetchTracker() bool

func (*RamPersister) ResetStepRate ¶

func (self *RamPersister) ResetStepRate()

func (*RamPersister) SaveGasPrice ¶

func (self *RamPersister) SaveGasPrice(gasPrice *ethereum.GasPrice)

func (*RamPersister) SaveGeneralInfoTokens ¶

func (self *RamPersister) SaveGeneralInfoTokens(generalInfo map[string]*ethereum.TokenGeneralInfo)

func (*RamPersister) SaveKyberEnabled ¶

func (self *RamPersister) SaveKyberEnabled(enabled bool)

--------------------------------------------------------

func (*RamPersister) SaveLatestBlock ¶

func (self *RamPersister) SaveLatestBlock(blockNumber string) error

func (*RamPersister) SaveMarketData ¶

func (self *RamPersister) SaveMarketData(marketRate map[string]*ethereum.Rates, mapTokenInfo map[string]*ethereum.TokenGeneralInfo, tokens map[string]ethereum.Token)

func (*RamPersister) SaveMaxGasPrice ¶

func (self *RamPersister) SaveMaxGasPrice(maxGasPrice string)

func (*RamPersister) SaveRate ¶

func (self *RamPersister) SaveRate(rates []ethereum.Rate, timestamp int64)

func (*RamPersister) SaveRateUSD ¶

func (self *RamPersister) SaveRateUSD(rateUSDEth string) error

func (*RamPersister) SaveStepRate ¶

func (self *RamPersister) SaveStepRate(rates []ethereum.StepRate)

func (*RamPersister) SetIsNewMarketInfo ¶

func (self *RamPersister) SetIsNewMarketInfo(isNewMarketInfo bool)

func (*RamPersister) SetIsNewRate ¶

func (self *RamPersister) SetIsNewRate(isNewRate bool)

func (*RamPersister) SetIsNewTrackerData ¶

func (self *RamPersister) SetIsNewTrackerData(isNewTrackerData bool)

func (*RamPersister) SetNewGasPrice ¶

func (self *RamPersister) SetNewGasPrice(isNew bool)

func (*RamPersister) SetNewKyberEnabled ¶

func (self *RamPersister) SetNewKyberEnabled(isNew bool)

func (*RamPersister) SetNewLatestBlock ¶

func (self *RamPersister) SetNewLatestBlock(isNew bool)

func (*RamPersister) SetNewMaxGasPrice ¶

func (self *RamPersister) SetNewMaxGasPrice(isNew bool)

func (*RamPersister) SetNewRateUSD ¶

func (self *RamPersister) SetNewRateUSD(isNew bool)

type RateUSD ¶

type RateUSD struct {
	Symbol   string `json:"symbol"`
	PriceUsd string `json:"price_usd"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL