resultdb

README

结果（收据）数据库

保存了合约执行的结果集，包括：

• 结果状态
• 读写集
• 事件日志

结果对象

主键为txId

事件日志

SQL DB

数据库名： chainId+"_resultdb"

Documentation

Overview

Package resultdb package

Package resultdb is a generated GoMock package.

Index

• type MockResultDB
  • func NewMockResultDB(ctrl *gomock.Controller) *MockResultDB
  • func (m *MockResultDB) Close()
  • func (m *MockResultDB) CommitBlock(blockInfo *serialization.BlockWithSerializedInfo, isCache bool) error
  • func (m *MockResultDB) EXPECT() *MockResultDBMockRecorder
  • func (m *MockResultDB) GetLastSavepoint() (uint64, error)
  • func (m *MockResultDB) GetRWSetIndex(txId string) (*store.StoreInfo, error)
  • func (m *MockResultDB) GetTxRWSet(txid string) (*common.TxRWSet, error)
  • func (m *MockResultDB) InitGenesis(genesisBlock *serialization.BlockWithSerializedInfo) error
  • func (m *MockResultDB) RestoreBlocks(blockInfos []*serialization.BlockWithSerializedInfo) error
  • func (m *MockResultDB) ShrinkBlocks(txIdsMap map[uint64][]string, height uint64, bfdbPath string) error
• type MockResultDBMockRecorder
  • func (mr *MockResultDBMockRecorder) Close() *gomock.Call
  • func (mr *MockResultDBMockRecorder) CommitBlock(blockInfo, isCache interface{}) *gomock.Call
  • func (mr *MockResultDBMockRecorder) GetLastSavepoint() *gomock.Call
  • func (mr *MockResultDBMockRecorder) GetRWSetIndex(txId interface{}) *gomock.Call
  • func (mr *MockResultDBMockRecorder) GetTxRWSet(txid interface{}) *gomock.Call
  • func (mr *MockResultDBMockRecorder) InitGenesis(genesisBlock interface{}) *gomock.Call
  • func (mr *MockResultDBMockRecorder) RestoreBlocks(blockInfos interface{}) *gomock.Call
  • func (mr *MockResultDBMockRecorder) ShrinkBlocks(txIdsMap, height, bfdbPath interface{}) *gomock.Call
• type ResultDB

Types

type MockResultDB

type MockResultDB struct {
	// contains filtered or unexported fields
}

MockResultDB is a mock of ResultDB interface.

func NewMockResultDB

func NewMockResultDB(ctrl *gomock.Controller) *MockResultDB

NewMockResultDB creates a new mock instance.

func (*MockResultDB) Close

func (m *MockResultDB) Close()

Close mocks base method.

func (*MockResultDB) CommitBlock

func (m *MockResultDB) CommitBlock(blockInfo *serialization.BlockWithSerializedInfo, isCache bool) error

CommitBlock mocks base method.

func (*MockResultDB) EXPECT

func (m *MockResultDB) EXPECT() *MockResultDBMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockResultDB) GetLastSavepoint

func (m *MockResultDB) GetLastSavepoint() (uint64, error)

GetLastSavepoint mocks base method.

func (*MockResultDB) GetRWSetIndex

func (m *MockResultDB) GetRWSetIndex(txId string) (*store.StoreInfo, error)

GetRWSetIndex mocks base method.

func (*MockResultDB) GetTxRWSet

func (m *MockResultDB) GetTxRWSet(txid string) (*common.TxRWSet, error)

GetTxRWSet mocks base method.

func (*MockResultDB) InitGenesis

func (m *MockResultDB) InitGenesis(genesisBlock *serialization.BlockWithSerializedInfo) error

InitGenesis mocks base method.

func (*MockResultDB) RestoreBlocks

func (m *MockResultDB) RestoreBlocks(blockInfos []*serialization.BlockWithSerializedInfo) error

RestoreBlocks mocks base method.

func (*MockResultDB) ShrinkBlocks

func (m *MockResultDB) ShrinkBlocks(txIdsMap map[uint64][]string, height uint64, bfdbPath string) error

ShrinkBlocks mocks base method.

type MockResultDBMockRecorder

type MockResultDBMockRecorder struct {
	// contains filtered or unexported fields
}

MockResultDBMockRecorder is the mock recorder for MockResultDB.

func (*MockResultDBMockRecorder) Close

func (mr *MockResultDBMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockResultDBMockRecorder) CommitBlock

func (mr *MockResultDBMockRecorder) CommitBlock(blockInfo, isCache interface{}) *gomock.Call

CommitBlock indicates an expected call of CommitBlock.

func (*MockResultDBMockRecorder) GetLastSavepoint

func (mr *MockResultDBMockRecorder) GetLastSavepoint() *gomock.Call

GetLastSavepoint indicates an expected call of GetLastSavepoint.

func (*MockResultDBMockRecorder) GetRWSetIndex

func (mr *MockResultDBMockRecorder) GetRWSetIndex(txId interface{}) *gomock.Call

GetRWSetIndex indicates an expected call of GetRWSetIndex.

func (*MockResultDBMockRecorder) GetTxRWSet

func (mr *MockResultDBMockRecorder) GetTxRWSet(txid interface{}) *gomock.Call

GetTxRWSet indicates an expected call of GetTxRWSet.

func (*MockResultDBMockRecorder) InitGenesis

func (mr *MockResultDBMockRecorder) InitGenesis(genesisBlock interface{}) *gomock.Call

InitGenesis indicates an expected call of InitGenesis.

func (*MockResultDBMockRecorder) RestoreBlocks

func (mr *MockResultDBMockRecorder) RestoreBlocks(blockInfos interface{}) *gomock.Call

RestoreBlocks indicates an expected call of RestoreBlocks.

func (*MockResultDBMockRecorder) ShrinkBlocks

func (mr *MockResultDBMockRecorder) ShrinkBlocks(txIdsMap, height, bfdbPath interface{}) *gomock.Call

ShrinkBlocks indicates an expected call of ShrinkBlocks.

type ResultDB

type ResultDB interface {
	InitGenesis(genesisBlock *serialization.BlockWithSerializedInfo) error

	// CommitBlock commits the block rwsets in an atomic operation
	CommitBlock(blockInfo *serialization.BlockWithSerializedInfo, isCache bool) error

	// ShrinkBlocks archive old blocks rwsets in an atomic operation
	ShrinkBlocks(txIdsMap map[uint64][]string, height uint64, bfdbPath string) error

	// RestoreBlocks restore blocks from outside serialized block data
	RestoreBlocks(blockInfos []*serialization.BlockWithSerializedInfo) error

	// GetTxRWSet returns an txRWSet for given txId, or returns nil if none exists.
	GetTxRWSet(txid string) (*commonPb.TxRWSet, error)

	// GetRWSetIndex returns the offset of the rwset in the file
	GetRWSetIndex(txId string) (*storePb.StoreInfo, error)

	// GetLastSavepoint returns the last block height
	GetLastSavepoint() (uint64, error)

	// Close is used to close database
	Close()
}

ResultDB provides handle to rwSets instances