history

Documentation

Index

• type DB
  • func (d *DB) Commit(block *common.Block) error
  • func (d *DB) CommitLostBlock(blockAndPvtdata *ledger.BlockAndPvtData) error
  • func (d *DB) GetLastSavepoint() (*version.Height, error)
  • func (d *DB) Name() string
  • func (d *DB) NewQueryExecutor(blockStore blkstorage.BlockStore) (ledger.HistoryQueryExecutor, error)
  • func (d *DB) ShouldRecover(lastAvailableBlock uint64) (bool, uint64, error)
• type DBProvider
  • func NewDBProvider(path string) (*DBProvider, error)
  • func (p *DBProvider) Close()
  • func (p *DBProvider) GetDBHandle(name string) (*DB, error)
• type QueryExecutor
  • func (q *QueryExecutor) GetHistoryForKey(namespace string, key string) (commonledger.ResultsIterator, error)

Types

type DB

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

func (*DB) Commit

func (d *DB) Commit(block *common.Block) error

func (*DB) CommitLostBlock

func (d *DB) CommitLostBlock(blockAndPvtdata *ledger.BlockAndPvtData) error

func (*DB) GetLastSavepoint

func (d *DB) GetLastSavepoint() (*version.Height, error)

func (*DB) Name

func (d *DB) Name() string

func (*DB) NewQueryExecutor

func (d *DB) NewQueryExecutor(blockStore blkstorage.BlockStore) (ledger.HistoryQueryExecutor, error)

func (*DB) ShouldRecover

func (d *DB) ShouldRecover(lastAvailableBlock uint64) (bool, uint64, error)

type DBProvider

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

func NewDBProvider

func NewDBProvider(path string) (*DBProvider, error)

func (*DBProvider) Close

func (p *DBProvider) Close()

func (*DBProvider) GetDBHandle

func (p *DBProvider) GetDBHandle(name string) (*DB, error)

type QueryExecutor

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

func (*QueryExecutor) GetHistoryForKey

func (q *QueryExecutor) GetHistoryForKey(namespace string, key string) (commonledger.ResultsIterator, error)