db

Mar 5, 2020

Changes in this version

+ const FiatRatesTimeFormat

+ func FiatRatesConvertDate(date string) (*time.Time, error)

+ type CurrencyRatesTicker struct

+ Rates map[string]float64

+ Timestamp *time.Time

+ type ResultTickerAsString struct

+ Error string

+ Rates map[string]float64

+ Timestamp int64

+ type ResultTickerListAsString struct

+ Error string

+ Tickers []string

+ Timestamp int64

+ type ResultTickersAsString struct

+ Tickers []ResultTickerAsString

type RocksDB

+ func (d *RocksDB) FiatRatesFindLastTicker() (*CurrencyRatesTicker, error)

+ func (d *RocksDB) FiatRatesFindTicker(tickerTime *time.Time) (*CurrencyRatesTicker, error)

+ func (d *RocksDB) FiatRatesStoreTicker(ticker *CurrencyRatesTicker) error

+ func (d *RocksDB) FixUtxos(stop chan os.Signal) error

May 27, 2019

Changes in this version

+ const AddressBalanceDetailNoUTXO

+ const AddressBalanceDetailUTXO

+ var ErrOperationInterrupted = errors.New("ErrOperationInterrupted")

type AddrBalance

+ Utxos []Utxo

+ type AddressBalanceDetail int

+ type Utxo struct

+ BtxID []byte

+ Height uint32

+ ValueSat big.Int

+ Vout int32

Apr 15, 2019

Changes in this version

type RocksDB

+ func (d *RocksDB) AddrDescForOutpoint(outpoint bchain.Outpoint) bchain.AddressDescriptor

Jan 23, 2019

Changes in this version

+ type AddrContract struct

+ Contract bchain.AddressDescriptor

+ Txs uint

+ type AddrContracts struct

+ Contracts []AddrContract

+ NonContractTxs uint

+ TotalTxs uint

+ type GetTransactionsCallback func(txid string, height uint32, indexes []int32) error

type RocksDB

+ func (d *RocksDB) DisconnectBlockRangeBitcoinType(lower uint32, higher uint32) error

+ func (d *RocksDB) DisconnectBlockRangeEthereumType(lower uint32, higher uint32) error

+ func (d *RocksDB) GetAddrDescContracts(addrDesc bchain.AddressDescriptor) (*AddrContracts, error)

Oct 10, 2018

Changes in this version

+ type AddrBalance struct

+ BalanceSat big.Int

+ SentSat big.Int

+ Txs uint32

+ func (ab *AddrBalance) ReceivedSat() *big.Int

+ type BlockInfo struct

+ Hash string

+ Height uint32

+ Size uint32

+ Time int64

+ Txs uint32

+ type BulkConnect struct

+ func (b *BulkConnect) Close() error

+ func (b *BulkConnect) ConnectBlock(block *bchain.Block, storeBlockTxs bool) error

type RocksDB

+ func (d *RocksDB) DisconnectBlockRangeNonUTXO(lower uint32, higher uint32) error

+ func (d *RocksDB) DisconnectBlockRangeUTXO(lower uint32, higher uint32) error

+ func (d *RocksDB) GetAddrDescBalance(addrDesc bchain.AddressDescriptor) (*AddrBalance, error)

+ func (d *RocksDB) GetAddrDescTransactions(addrDesc bchain.AddressDescriptor, lower uint32, higher uint32, ...) (err error)

+ func (d *RocksDB) GetAddressBalance(address string) (*AddrBalance, error)

+ func (d *RocksDB) GetAndResetConnectBlockStats() string

+ func (d *RocksDB) GetBlockInfo(height uint32) (*BlockInfo, error)

+ func (d *RocksDB) GetMemoryStats() string

+ func (d *RocksDB) GetTxAddresses(txid string) (*TxAddresses, error)

+ func (d *RocksDB) InitBulkConnect() (*BulkConnect, error)

+ func (d *RocksDB) SetInconsistentState(inconsistent bool) error

+ type StopIteration struct

+ func (e *StopIteration) Error() string

+ type TxAddresses struct

+ Height uint32

+ Inputs []TxInput

+ Outputs []TxOutput

+ type TxInput struct

+ AddrDesc bchain.AddressDescriptor

+ ValueSat big.Int

+ func (ti *TxInput) Addresses(p bchain.BlockChainParser) ([]string, bool, error)

+ type TxOutput struct

+ AddrDesc bchain.AddressDescriptor

+ Spent bool

+ ValueSat big.Int

+ func (to *TxOutput) Addresses(p bchain.BlockChainParser) ([]string, bool, error)

Sep 12, 2018

Changes in this version

+ func RepairRocksDB(name string) error

+ type RocksDB struct

+ func NewRocksDB(path string, parser bchain.BlockChainParser, metrics *common.Metrics) (d *RocksDB, err error)

+ func (d *RocksDB) Close() error

+ func (d *RocksDB) ComputeInternalStateColumnStats(stopCompute chan os.Signal) error

+ func (d *RocksDB) ConnectBlock(block *bchain.Block) error

+ func (d *RocksDB) DatabaseSizeOnDisk() int64

+ func (d *RocksDB) DeleteTx(txid string) error

+ func (d *RocksDB) DisconnectBlock(block *bchain.Block) error

+ func (d *RocksDB) DisconnectBlockRange(lower uint32, higher uint32) error

+ func (d *RocksDB) GetBestBlock() (uint32, string, error)

+ func (d *RocksDB) GetBlockHash(height uint32) (string, error)

+ func (d *RocksDB) GetTransactions(address string, lower uint32, higher uint32, ...) (err error)

+ func (d *RocksDB) GetTx(txid string) (*bchain.Tx, uint32, error)

+ func (d *RocksDB) LoadInternalState(rpcCoin string) (*common.InternalState, error)

+ func (d *RocksDB) PutTx(tx *bchain.Tx, height uint32, blockTime int64) error

+ func (d *RocksDB) Reopen() error

+ func (d *RocksDB) SetInternalState(is *common.InternalState)

+ func (d *RocksDB) StoreInternalState(is *common.InternalState) error

+ type SyncWorker struct

+ func NewSyncWorker(db *RocksDB, chain bchain.BlockChain, syncWorkers, syncChunk int, ...) (*SyncWorker, error)

+ func (w *SyncWorker) ConnectBlocksParallel(lower, higher uint32) error

+ func (w *SyncWorker) DisconnectBlocks(lower uint32, higher uint32, hashes []string) error

+ func (w *SyncWorker) ResyncIndex(onNewBlock bchain.OnNewBlockFunc) error

+ type TxCache struct

+ func NewTxCache(db *RocksDB, chain bchain.BlockChain, metrics *common.Metrics, enabled bool) (*TxCache, error)

+ func (c *TxCache) GetTransaction(txid string, bestheight uint32) (*bchain.Tx, uint32, error)