blockkvdb

package
v2.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 7, 2022 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DbType_Mysql = "mysql"

nolint

Functions

This section is empty.

Types

type BlockKvDB 

type BlockKvDB struct {
	sync.Mutex
	// contains filtered or unexported fields
}

BlockKvDB provider a implementation of `blockdb.BlockDB` 

@Description:

This implementation provides a key-value based data model

func NewBlockKvDB 

func NewBlockKvDB(chainId string, dbHandle protocol.DBHandle, logger protocol.Logger,
	storeConfig *conf.StorageConfig) *BlockKvDB

NewBlockKvDB 创建blockKvDB 

@Description:
@param chainId
@param dbHandle
@param logger
@param storeConfig
@return *BlockKvDB

func (*BlockKvDB) BlockExists 

func (b *BlockKvDB) BlockExists(blockHash []byte) (bool, error)

BlockExists returns true if the block hash exist, or returns false if none exists. 

@Description:
@receiver b
@param blockHash
@return bool
@return error

func (*BlockKvDB) Close 

func (b *BlockKvDB) Close()

Close is used to close database 

@Description:
@receiver b

func (*BlockKvDB) CommitBlock 

func (b *BlockKvDB) CommitBlock(blockInfo *serialization.BlockWithSerializedInfo, isCache bool) error

CommitBlock commits the block and the corresponding rwsets in an atomic operation 

@Description:
@receiver b
@param blockInfo
@param isCache
@return error

func (*BlockKvDB) CommitCache added in v2.2.0 

func (b *BlockKvDB) CommitCache(blockInfo *serialization.BlockWithSerializedInfo) error

CommitCache 提交数据到cache 

@Description:
@receiver b
@param blockInfo
@return error

func (*BlockKvDB) CommitDB added in v2.2.0 

func (b *BlockKvDB) CommitDB(blockInfo *serialization.BlockWithSerializedInfo) error

CommitDB 提交数据到kvdb 

@Description:
@receiver b
@param blockInfo
@return error

func (*BlockKvDB) GetArchivedPivot 

func (b *BlockKvDB) GetArchivedPivot() (uint64, error)

GetArchivedPivot return archived pivot 

@Description:
@receiver b
@return uint64
@return error

func (*BlockKvDB) GetBlock 

func (b *BlockKvDB) GetBlock(height uint64) (*commonPb.Block, error)

GetBlock returns a block given it's block height, or returns nil if none exists. 

@Description:
@receiver b
@param height
@return *commonPb.Block
@return error

func (*BlockKvDB) GetBlockByHash 

func (b *BlockKvDB) GetBlockByHash(blockHash []byte) (*commonPb.Block, error)

GetBlockByHash returns a block given it's hash, or returns nil if none exists. 

@Description:
@receiver b
@param blockHash
@return *commonPb.Block
@return error

func (*BlockKvDB) GetBlockByTx 

func (b *BlockKvDB) GetBlockByTx(txId string) (*commonPb.Block, error)

GetBlockByTx returns a block which contains a tx. 

@Description:
@receiver b
@param txId
@return *commonPb.Block
@return error

func (*BlockKvDB) GetBlockHeaderByHeight 

func (b *BlockKvDB) GetBlockHeaderByHeight(height uint64) (*commonPb.BlockHeader, error)

GetBlockHeaderByHeight returns a block header by given it's height, or returns nil if none exists. 

@Description:
@receiver b
@param height
@return *commonPb.BlockHeader
@return error

func (*BlockKvDB) GetBlockIndex added in v2.2.0 

func (b *BlockKvDB) GetBlockIndex(height uint64) (*storePb.StoreInfo, error)

GetBlockIndex not implement 

@Description:
@receiver b
@param height
@return *storePb.StoreInfo
@return error

func (*BlockKvDB) GetBlockMetaIndex added in v2.2.0 

func (b *BlockKvDB) GetBlockMetaIndex(height uint64) (*storePb.StoreInfo, error)

GetBlockMetaIndex not implement 

@Description:
@receiver b
@param height
@return *storePb.StoreInfo
@return error

func (*BlockKvDB) GetFilteredBlock 

func (b *BlockKvDB) GetFilteredBlock(height uint64) (*storePb.SerializedBlock, error)

GetFilteredBlock returns a filtered block given it's block height, or return nil if none exists. 

@Description:
@receiver b
@param height
@return *storePb.SerializedBlock
@return error

func (*BlockKvDB) GetHeightByHash 

func (b *BlockKvDB) GetHeightByHash(blockHash []byte) (uint64, error)

GetHeightByHash returns a block height given it's hash, or returns nil if none exists. 

@Description:
@receiver b
@param blockHash
@return uint64
@return error

func (*BlockKvDB) GetLastBlock 

func (b *BlockKvDB) GetLastBlock() (*commonPb.Block, error)

GetLastBlock returns the last block. 

@Description:
@receiver b
@return *commonPb.Block
@return error

func (*BlockKvDB) GetLastConfigBlock 

func (b *BlockKvDB) GetLastConfigBlock() (*commonPb.Block, error)

GetLastConfigBlock returns the last config block. 

@Description:
@receiver b
@return *commonPb.Block
@return error

func (*BlockKvDB) GetLastConfigBlockHeight added in v2.2.0 

func (b *BlockKvDB) GetLastConfigBlockHeight() (uint64, error)

GetLastConfigBlockHeight returns the last config block height. 

@Description:
@receiver b
@return uint64
@return error

func (*BlockKvDB) GetLastSavepoint 

func (b *BlockKvDB) GetLastSavepoint() (uint64, error)

GetLastSavepoint returns the last block height 

@Description:
@receiver b
@return uint64
@return error

func (*BlockKvDB) GetTx 

func (b *BlockKvDB) GetTx(txId string) (*commonPb.Transaction, error)

GetTx retrieves a transaction by txid, or returns nil if none exists. 

@Description:
@receiver b
@param txId
@return *commonPb.Transaction
@return error

func (*BlockKvDB) GetTxConfirmedTime 

func (b *BlockKvDB) GetTxConfirmedTime(txId string) (int64, error)

GetTxConfirmedTime returns the confirmed time of a given tx 

@Description:
@receiver b
@param txId
@return int64
@return error

func (*BlockKvDB) GetTxHeight 

func (b *BlockKvDB) GetTxHeight(txId string) (uint64, error)

GetTxHeight retrieves a transaction height by txid, or returns nil if none exists. 

@Description:
@receiver b
@param txId
@return uint64
@return error

func (*BlockKvDB) GetTxIndex added in v2.2.0 

func (b *BlockKvDB) GetTxIndex(txId string) (*storePb.StoreInfo, error)

GetTxIndex not implement 

@Description:
@receiver b
@param txId
@return *storePb.StoreInfo
@return error

func (*BlockKvDB) GetTxInfoOnly added in v2.2.0 

func (b *BlockKvDB) GetTxInfoOnly(txId string) (*storePb.TransactionStoreInfo, error)

GetTxInfoOnly 获得除Tx之外的其他TxInfo信息 

@Description:
@receiver b
@param txId
@return *storePb.TransactionStoreInfo
@return error

func (*BlockKvDB) GetTxWithBlockInfo 

func (b *BlockKvDB) GetTxWithBlockInfo(txId string) (*storePb.TransactionStoreInfo, error)

GetTxWithBlockInfo 根据txId获得交易 

@Description:
@receiver b
@param txId
@return *storePb.TransactionStoreInfo
@return error

func (*BlockKvDB) InitGenesis 

func (b *BlockKvDB) InitGenesis(genesisBlock *serialization.BlockWithSerializedInfo) error

InitGenesis 初始化创世区块 

@Description:
@receiver b
@param genesisBlock
@return error

func (*BlockKvDB) RestoreBlocks 

func (b *BlockKvDB) RestoreBlocks(blockInfos []*serialization.BlockWithSerializedInfo) error

RestoreBlocks restore block data from outside to kvdb: txid--SerializedTx 

@Description:
@receiver b
@param blockInfos
@return error

func (*BlockKvDB) ShrinkBlocks 

func (b *BlockKvDB) ShrinkBlocks(startHeight uint64, endHeight uint64) (map[uint64][]string, error)

ShrinkBlocks remove ranged txid--SerializedTx from kvdb 

@Description:
@receiver b
@param startHeight
@param endHeight
@return map[uint64][]string
@return error

func (*BlockKvDB) TxArchived 

func (b *BlockKvDB) TxArchived(txId string) (bool, error)

TxArchived returns true if the tx archived, or returns false. 

@Description:
@receiver b
@param txId
@return bool
@return error

func (*BlockKvDB) TxExists 

func (b *BlockKvDB) TxExists(txId string) (bool, error)

TxExists returns true if the tx exist, or returns false if none exists. 

@Description:
@receiver b
@param txId
@return bool
@return error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.