database

Documentation

Index

• Variables
• type ChainindexDB
  • func (odb *ChainindexDB) AddBlock(block *ci_pb.BcBlock) (bool, error)
  • func (odb *ChainindexDB) AddBlockRange(brange *ci_pb.BcBlocks) (int, error)
  • func (odb *ChainindexDB) AddMarkedTransaction(mtx *ci_pb.MarkedTransaction)
  • func (odb *ChainindexDB) AddTransaction(tx *ci_pb.Transaction)
  • func (odb *ChainindexDB) Close()
  • func (odb *ChainindexDB) FlushToDisk()
  • func (odb *ChainindexDB) FullLocalValidation()
  • func (odb *ChainindexDB) GetBlockByHash(blockHash []byte) (*ci_pb.BcBlock, error)
  • func (odb *ChainindexDB) GetBlockByHeight(blockHeight uint64) (*ci_pb.BcBlock, error)
  • func (odb *ChainindexDB) GetBlockByTx(txHash []byte) (*ci_pb.BcBlock, error)
  • func (odb *ChainindexDB) GetSyncStartingBlock() *ci_pb.BcBlock
  • func (odb *ChainindexDB) HighestBlock() *ci_pb.BcBlock
  • func (odb *ChainindexDB) HighestBlockHeight() uint64
  • func (odb *ChainindexDB) HighestSerializedBlock() ci_pb.BcBlock
  • func (odb *ChainindexDB) IsInitialBlockDownload() bool
  • func (odb *ChainindexDB) IsMultiplexPeers() bool
  • func (odb *ChainindexDB) Open(filepath string, dropChainstate bool, pruneDatabaseTo uint64) error
  • func (odb *ChainindexDB) Run()
  • func (odb *ChainindexDB) SerializedHeight() uint64
  • func (odb *ChainindexDB) SetInitialBlockDownload()
  • func (odb *ChainindexDB) SetMultiplexPeers()
  • func (odb *ChainindexDB) UnSetInitialBlockDownload()
  • func (odb *ChainindexDB) UnSetMultiplexPeers()
• type ChainindexDBConfig
  • func DefaultChainindexDBConfig() ChainindexDBConfig

Variables

var ChainindexBlockChunkMap = []byte("CHAININDEX-BLOCK-CHUNK-MAP")

var ChainindexBlockChunks = []byte("CHAININDEX-BLOCK-CHUNKS")

var ChainindexHeightToHashMap = []byte("CHAININDEX-BLOCK-HEIGHT-TO-HASH")

var ChainindexTxToHashMap = []byte("CHAININDEX-TX-TO-BLOCK")

var ChainstateBlocks = []byte("CHAINSTATE-BLOCKS")

var ChainstateMTxs = []byte("CHAINSTATE-MTXS")

var ChainstateTxs = []byte("CHAINSTATE-TXS")

var SyncInfo = []byte("SYNC-INFO")

Types

type ChainindexDB

type ChainindexDB struct {
	Config ChainindexDBConfig
	// contains filtered or unexported fields
}

func (*ChainindexDB) AddBlock

func (odb *ChainindexDB) AddBlock(block *ci_pb.BcBlock) (bool, error)

func (*ChainindexDB) AddBlockRange

func (odb *ChainindexDB) AddBlockRange(brange *ci_pb.BcBlocks) (int, error)

func (*ChainindexDB) AddMarkedTransaction

func (odb *ChainindexDB) AddMarkedTransaction(mtx *ci_pb.MarkedTransaction)

func (*ChainindexDB) AddTransaction

func (odb *ChainindexDB) AddTransaction(tx *ci_pb.Transaction)

func (*ChainindexDB) Close

func (odb *ChainindexDB) Close()

func (*ChainindexDB) FlushToDisk

func (odb *ChainindexDB) FlushToDisk()

func (*ChainindexDB) FullLocalValidation

func (odb *ChainindexDB) FullLocalValidation()

func (*ChainindexDB) GetBlockByHash

func (odb *ChainindexDB) GetBlockByHash(blockHash []byte) (*ci_pb.BcBlock, error)

func (*ChainindexDB) GetBlockByHeight

func (odb *ChainindexDB) GetBlockByHeight(blockHeight uint64) (*ci_pb.BcBlock, error)

func (*ChainindexDB) GetBlockByTx

func (odb *ChainindexDB) GetBlockByTx(txHash []byte) (*ci_pb.BcBlock, error)

func (*ChainindexDB) GetSyncStartingBlock

func (odb *ChainindexDB) GetSyncStartingBlock() *ci_pb.BcBlock

func (*ChainindexDB) HighestBlock

func (odb *ChainindexDB) HighestBlock() *ci_pb.BcBlock

func (*ChainindexDB) HighestBlockHeight

func (odb *ChainindexDB) HighestBlockHeight() uint64

func (*ChainindexDB) HighestSerializedBlock

func (odb *ChainindexDB) HighestSerializedBlock() ci_pb.BcBlock

func (*ChainindexDB) IsInitialBlockDownload

func (odb *ChainindexDB) IsInitialBlockDownload() bool

func (*ChainindexDB) IsMultiplexPeers

func (odb *ChainindexDB) IsMultiplexPeers() bool

func (*ChainindexDB) Open

func (odb *ChainindexDB) Open(filepath string, dropChainstate bool, pruneDatabaseTo uint64) error

func (*ChainindexDB) Run

func (odb *ChainindexDB) Run()

func (*ChainindexDB) SerializedHeight

func (odb *ChainindexDB) SerializedHeight() uint64

func (*ChainindexDB) SetInitialBlockDownload

func (odb *ChainindexDB) SetInitialBlockDownload()

func (*ChainindexDB) SetMultiplexPeers

func (odb *ChainindexDB) SetMultiplexPeers()

func (*ChainindexDB) UnSetInitialBlockDownload

func (odb *ChainindexDB) UnSetInitialBlockDownload()

func (*ChainindexDB) UnSetMultiplexPeers

func (odb *ChainindexDB) UnSetMultiplexPeers()

type ChainindexDBConfig

type ChainindexDBConfig struct {
	Maturity           int `json:"maturity"`           // how many blocks until maturity is reached
	IncomingBlocksSize int `json:"incomingBlocksSize"` // how big is the map of incoming blocks
	ActiveSet          int `json:"activeSet"`          // how many blocks past maturity to keep in memory
	AncientChunkSize   int `json:"ancientChunkSize"`   // how many blocks to serialize to disk together
}

func DefaultChainindexDBConfig

func DefaultChainindexDBConfig() ChainindexDBConfig