transientstore

package
v0.0.0-...-95b87ed Latest Latest
Warning

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

Go to latest
Published: Sep 16, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrStoreEmpty = errors.New("Transient store is empty")
)

Functions

This section is empty.

Types

type EndorserPvtSimulationResults

type EndorserPvtSimulationResults struct {
	ReceivedAtBlockHeight          uint64
	PvtSimulationResultsWithConfig *transientstore.TxPvtReadWriteSetWithConfigInfo
}

type RWSetScanner

type RWSetScanner interface {
	Next() (*EndorserPvtSimulationResults, error)

	Close()
}

type RwsetScanner

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

func (*RwsetScanner) Close

func (scanner *RwsetScanner) Close()

func (*RwsetScanner) Next

func (scanner *RwsetScanner) Next() (*EndorserPvtSimulationResults, error)

type Store

type Store interface {
	Persist(txid string, blockHeight uint64, privateSimulationResultsWithConfig *transientstore.TxPvtReadWriteSetWithConfigInfo) error

	GetTxPvtRWSetByTxid(txid string, filter ledger.PvtNsCollFilter) (RWSetScanner, error)

	PurgeByTxids(txids []string) error

	PurgeByHeight(maxBlockNumToRetain uint64) error

	GetMinTransientBlkHt() (uint64, error)
	Shutdown()
}

type StoreEnv

type StoreEnv struct {
	TestStoreProvider StoreProvider
	TestStore         Store
	// contains filtered or unexported fields
}

func NewTestStoreEnv

func NewTestStoreEnv(t *testing.T) *StoreEnv

func (*StoreEnv) Cleanup

func (env *StoreEnv) Cleanup()

type StoreProvider

type StoreProvider interface {
	OpenStore(ledgerID string) (Store, error)
	Close()
}

func NewStoreProvider

func NewStoreProvider(path string) (StoreProvider, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL