Versions in this module Expand all Collapse all v1 v1.0.0 Jul 20, 2018 Changes in this version + const DefaultStakeDbName + const TableNameStakeInfo + const TableNameSummaries + func DisableLog() + func InitWiredDB(dbInfo *DBInfo, statusC chan uint32, cl *rpcclient.Client, p *chaincfg.Params) (wiredDB, func() error, error) + func NewWiredDB(db *sql.DB, statusC chan uint32, cl *rpcclient.Client, p *chaincfg.Params) (wiredDB, func() error, error) + func UseLogger(logger btclog.Logger) + func ValidateNetworkAddress(address exccutil.Address, p *chaincfg.Params) bool + type BlockSummaryDatabaser interface + RetrieveBlockSummary func(ind int64) (*apitypes.BlockDataBasic, error) + StoreBlockSummary func(bd *apitypes.BlockDataBasic) error + type ChainMonitor struct + ConnectingLock chan struct{} + DoneConnecting chan struct{} + func (p *ChainMonitor) BlockConnectedHandler() + func (p *ChainMonitor) BlockConnectedSync(hash *chainhash.Hash) + func (p *ChainMonitor) ReorgHandler() + type DB struct + func InitDB(dbInfo *DBInfo) (*DB, error) + func NewDB(db *sql.DB) (*DB, error) + func (db *DB) GetBestBlockHash() string + func (db *DB) GetBestBlockHeight() int64 + func (db *DB) GetBlockSummaryHeight() (int64, error) + func (db *DB) GetStakeInfoHeight() (int64, error) + func (db *DB) RetrieveBestBlockHash() (string, error) + func (db *DB) RetrieveBestBlockHeight() (int64, error) + func (db *DB) RetrieveBlockHash(ind int64) (string, error) + func (db *DB) RetrieveBlockHeight(hash string) (int64, error) + func (db *DB) RetrieveBlockSizeRange(ind0, ind1 int64) ([]int32, error) + func (db *DB) RetrieveBlockSummary(ind int64) (*apitypes.BlockDataBasic, error) + func (db *DB) RetrieveBlockSummaryByHash(hash string) (*apitypes.BlockDataBasic, error) + func (db *DB) RetrieveLatestBlockSummary() (*apitypes.BlockDataBasic, error) + func (db *DB) RetrieveLatestStakeInfoExtended() (*apitypes.StakeInfoExtended, error) + func (db *DB) RetrievePoolInfo(ind int64) (*apitypes.TicketPoolInfo, error) + func (db *DB) RetrievePoolInfoByHash(hash string) (*apitypes.TicketPoolInfo, error) + func (db *DB) RetrievePoolInfoRange(ind0, ind1 int64) ([]apitypes.TicketPoolInfo, error) + func (db *DB) RetrievePoolValAndSizeRange(ind0, ind1 int64) ([]float64, []float64, error) + func (db *DB) RetrieveSDiff(ind int64) (float64, error) + func (db *DB) RetrieveSDiffRange(ind0, ind1 int64) ([]float64, error) + func (db *DB) RetrieveStakeInfoExtended(ind int64) (*apitypes.StakeInfoExtended, error) + func (db *DB) StoreBlockSummary(bd *apitypes.BlockDataBasic) error + func (db *DB) StoreStakeInfoExtended(si *apitypes.StakeInfoExtended) error + type DBDataSaver struct + func (db *DBDataSaver) Store(data *blockdata.BlockData, _ *wire.MsgBlock) error + type DBInfo struct + FileName string + type ReorgData struct + NewChainHead chainhash.Hash + NewChainHeight int32 + OldChainHead chainhash.Hash + OldChainHeight int32 + type StakeInfoDatabaser interface + RetrieveStakeInfoExtended func(ind int64) (*apitypes.StakeInfoExtended, error) + StoreStakeInfoExtended func(bd *apitypes.StakeInfoExtended) error