transientstore

Documentation

Index

• Variables
• type EndorserPvtSimulationResults
• type RWSetScanner
• type RwsetScanner
  • func (scanner *RwsetScanner) Close()
  • func (scanner *RwsetScanner) Next() (*EndorserPvtSimulationResults, error)
• type Store
• type StoreEnv
  • func NewTestStoreEnv(t *testing.T) *StoreEnv
  • func (env *StoreEnv) Cleanup()
• type StoreProvider
  • func NewStoreProvider(path string) (StoreProvider, error)

Variables

var (
	ErrStoreEmpty = errors.New("Transient store 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)