Versions in this module Expand all Collapse all v3 v3.0.1 Dec 28, 2023 Changes in this version type BlockStoreImpl + func (bs *BlockStoreImpl) GetArchiveStatus() (*storePb.ArchiveStatus, error) + func (bs *BlockStoreImpl) GetHotColdDataSeparationMaxHeight() (uint64, error) + func (bs *BlockStoreImpl) GetLastHeight() (uint64, error) v3.0.0 Dec 23, 2022 Changes in this version + const BigFilter + const BlockFile + const BlockFileDB + const BlockKvDB + const BlockSQLDB + const DBHandleBlockName + const DBHandleEventName + const DBHandleHistoryName + const DBHandleLocalName + const DBHandleResultName + const DBHandleStateName + const DBHandleTxExistName + const DBName_BlockDB + const DBName_EventDB + const DBName_HistoryDB + const DBName_LocalDB + const DBName_ResultDB + const DBName_StateDB + const DBName_TxExistDB + const Encryptor + const EventSQLDB + const HistoryKvDB + const HistorySQLDB + const ImportLedgerSnapshot + const LedgerSnapshot + const META + const RWC + const ResultFileDB + const ResultKvDB + const ResultSQLDB + const SqlDBHandleBlockName + const SqlDBHandleEventName + const SqlDBHandleHistoryName + const SqlDBHandleLocalName + const SqlDBHandleResultName + const SqlDBHandleStateName + const SqlDBHandleTxExistName + const StateKvDB + const StateSQLDB + const StoreBlockDBDir + const StoreEventLogDBDir + const StoreHistoryDBDir + const StoreLocalDBDir + const StoreResultDBDir + const StoreStateDBDir + const StoreTxExistDbDir + const TxExistKvDB + const WAL + const WrapTxExistDB + var ErrConversionInterface = errors.New("interface conversion error") + func NewAsyncBlockStoreImpl(blockStoreImpl protocol.BlockchainStore, logger protocol.Logger) protocol.BlockchainStore + func WrapBlockDB2TxExistDB(db blockdb.BlockDB, log protocol.Logger) txexistdb.TxExistDB + type AsyncBlockStoreImpl struct + func (async *AsyncBlockStoreImpl) GetBlock(height uint64) (*commonPb.Block, error) + func (async *AsyncBlockStoreImpl) PutBlock(block *commonPb.Block, txRWSets []*commonPb.TxRWSet) error + type BlockStoreImpl struct + ArchiveMgr *archive.ArchiveMgr + func NewBlockStoreImpl(chainId string, storeConfig *conf.StorageConfig, blockDB blockdb.BlockDB, ...) (*BlockStoreImpl, error) + func (bs *BlockStoreImpl) ArchiveBlock(archiveHeight uint64) error + func (bs *BlockStoreImpl) BeginDbTransaction(txName string) (protocol.SqlDBTransaction, error) + func (bs *BlockStoreImpl) BlockExists(blockHash []byte) (bool, error) + func (bs *BlockStoreImpl) Close() error + func (bs *BlockStoreImpl) CommitDbTransaction(txName string) error + func (bs *BlockStoreImpl) CommonPutBlock(block *commonPb.Block, txRWSets []*commonPb.TxRWSet) error + func (bs *BlockStoreImpl) CreateDatabase(contractName string) error + func (bs *BlockStoreImpl) DoHotColdDataSeparation(startHeight uint64, endHeight uint64) (string, error) + func (bs *BlockStoreImpl) DropDatabase(contractName string) error + func (bs *BlockStoreImpl) ExecDdlSql(contractName, sql, version string) error + func (bs *BlockStoreImpl) GetAccountTxHistory(accountId []byte) (protocol.TxHistoryIterator, error) + func (bs *BlockStoreImpl) GetArchivedPivot() uint64 + func (bs *BlockStoreImpl) GetBlock(height uint64) (*commonPb.Block, error) + func (bs *BlockStoreImpl) GetBlockByHash(blockHash []byte) (*commonPb.Block, error) + func (bs *BlockStoreImpl) GetBlockByTx(txId string) (*commonPb.Block, error) + func (bs *BlockStoreImpl) GetBlockHeaderByHeight(height uint64) (*commonPb.BlockHeader, error) + func (bs *BlockStoreImpl) GetBlockWithRWSets(height uint64) (*storePb.BlockWithRWSet, error) + func (bs *BlockStoreImpl) GetContractByName(name string) (*commonPb.Contract, error) + func (bs *BlockStoreImpl) GetContractBytecode(name string) ([]byte, error) + func (bs *BlockStoreImpl) GetContractDbName(contractName string) string + func (bs *BlockStoreImpl) GetContractTxHistory(contractName string) (protocol.TxHistoryIterator, error) + func (bs *BlockStoreImpl) GetDBHandle(dbName string) protocol.DBHandle + func (bs *BlockStoreImpl) GetDbTransaction(txName string) (protocol.SqlDBTransaction, error) + func (bs *BlockStoreImpl) GetHeightByHash(blockHash []byte) (uint64, error) + func (bs *BlockStoreImpl) GetHistoryForKey(contractName string, key []byte) (protocol.KeyHistoryIterator, error) + func (bs *BlockStoreImpl) GetHotColdDataSeparationJobByID(jobID string) (storePb.ArchiveJob, error) + func (bs *BlockStoreImpl) GetLastBlock() (*commonPb.Block, error) + func (bs *BlockStoreImpl) GetLastChainConfig() (*configPb.ChainConfig, error) + func (bs *BlockStoreImpl) GetLastConfigBlock() (*commonPb.Block, error) + func (bs *BlockStoreImpl) GetMemberExtraData(member *accesscontrol.Member) (*accesscontrol.MemberExtraData, error) + func (bs *BlockStoreImpl) GetSnapshotStatus() uint64 + func (bs *BlockStoreImpl) GetTx(txId string) (*commonPb.Transaction, error) + func (bs *BlockStoreImpl) GetTxConfirmedTime(txId string) (int64, error) + func (bs *BlockStoreImpl) GetTxHeight(txId string) (uint64, error) + func (bs *BlockStoreImpl) GetTxInfoWithRWSet(txId string) (*commonPb.TransactionInfoWithRWSet, error) + func (bs *BlockStoreImpl) GetTxRWSet(txId string) (*commonPb.TxRWSet, error) + func (bs *BlockStoreImpl) GetTxRWSetsByHeight(height uint64) ([]*commonPb.TxRWSet, error) + func (bs *BlockStoreImpl) GetTxWithRWSet(txId string) (*commonPb.TransactionWithRWSet, error) + func (bs *BlockStoreImpl) InitArchiveMgr(chainId string) error + func (bs *BlockStoreImpl) InitGenesis(genesisBlock *storePb.BlockWithRWSet) error + func (bs *BlockStoreImpl) MakeSnapshot(snapshotHeight uint64) error + func (bs *BlockStoreImpl) PutBlock(block *commonPb.Block, txRWSets []*commonPb.TxRWSet) error + func (bs *BlockStoreImpl) QueryMulti(contractName, sql string, values ...interface{}) (protocol.SqlRows, error) + func (bs *BlockStoreImpl) QuerySingle(contractName, sql string, values ...interface{}) (protocol.SqlRow, error) + func (bs *BlockStoreImpl) QuickPutBlock(block *commonPb.Block, txRWSets []*commonPb.TxRWSet) error + func (bs *BlockStoreImpl) ReadObject(contractName string, key []byte) ([]byte, error) + func (bs *BlockStoreImpl) ReadObjects(contractName string, keys [][]byte) ([][]byte, error) + func (bs *BlockStoreImpl) RestoreBlocks(serializedBlocks [][]byte) error + func (bs *BlockStoreImpl) RollbackDbTransaction(txName string) error + func (bs *BlockStoreImpl) SelectObject(contractName string, startKey []byte, limit []byte) (protocol.StateIterator, error) + func (bs *BlockStoreImpl) TxExists(txId string) (bool, error) + func (bs *BlockStoreImpl) TxExistsInFullDB(txId string) (bool, uint64, error) + func (bs *BlockStoreImpl) TxExistsInIncrementDB(txId string, startHeight uint64) (bool, error) + func (bs *BlockStoreImpl) TxExistsInIncrementDBState(txId string, startHeight uint64) (bool, bool, error) + func (bs *BlockStoreImpl) WriteBatchFromChanToDB() + func (bs *BlockStoreImpl) WriteKvDb(blockWithSerializedInfo *serialization.BlockWithSerializedInfo, ...) error + func (bs *BlockStoreImpl) WriteKvDbCacheSqlDb(blockWithSerializedInfo *serialization.BlockWithSerializedInfo, ...) error + func (d *BlockStoreImpl) GetTxInfoOnly(txId string) (*commonPb.TransactionInfo, error) + func (d *BlockStoreImpl) GetTxWithInfo(txId string) (*commonPb.TransactionInfo, error) + type Factory struct + func NewFactory() *Factory + func (m *Factory) NewImportStore(chainId string, storeConfig *conf.StorageConfig, logger protocol.Logger, ...) (protocol.ImportLedgerSnapshot, error) + func (m *Factory) NewStore(chainId string, storeConfig *conf.StorageConfig, logger protocol.Logger, ...) (protocol.BlockchainStore, error)