Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventsStore ¶
type EventsStore struct {
// contains filtered or unexported fields
}
EventsStore handles persisting events
func NewEventsStore ¶
func NewEventsStore( inMemoryEvents *unsynchronized.Events, persistedEvents storage.Events, blockID flow.Identifier, ) *EventsStore
func (*EventsStore) Persist ¶
func (e *EventsStore) Persist(lctx lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds events to the batch. No errors are expected during normal operations
type LatestSealedResultStore ¶
type LatestSealedResultStore struct {
// contains filtered or unexported fields
}
LatestSealedResultStore handles persisting transaction result error messages
func NewLatestSealedResultStore ¶
func NewLatestSealedResultStore( latestPersistedSealedResult storage.LatestPersistedSealedResult, executionResultID flow.Identifier, height uint64, ) *LatestSealedResultStore
func (*LatestSealedResultStore) Persist ¶
func (t *LatestSealedResultStore) Persist(lctx lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds the latest sealed result to the batch. No errors are expected during normal operations
type LightCollectionsStore ¶
type LightCollectionsStore struct {
// contains filtered or unexported fields
}
LightCollectionsStore handles persisting light collections
func NewCollectionsStore ¶
func NewCollectionsStore( inMemoryCollections *unsynchronized.Collections, persistedCollections storage.Collections, lockManager storage.LockManager, ) *LightCollectionsStore
func (*LightCollectionsStore) Persist ¶
func (c *LightCollectionsStore) Persist(lctx lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds light collections to the batch. No errors are expected during normal operations
type PersisterStore ¶
type PersisterStore interface {
// Persist adds data to the batch for later commitment.
// No errors are expected during normal operations
Persist(lctx lockctx.Proof, batch storage.ReaderBatchWriter) error
}
PersisterStore is the interface to handle persisting of a data type to persisted storage using batch operation.
type ResultsStore ¶
type ResultsStore struct {
// contains filtered or unexported fields
}
ResultsStore handles persisting transaction results
func NewResultsStore ¶
func NewResultsStore( inMemoryResults *unsynchronized.LightTransactionResults, persistedResults storage.LightTransactionResults, blockID flow.Identifier, ) *ResultsStore
func (*ResultsStore) Persist ¶
func (r *ResultsStore) Persist(lctx lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds results to the batch. No errors are expected during normal operations
type TransactionsStore ¶
type TransactionsStore struct {
// contains filtered or unexported fields
}
TransactionsStore handles persisting transactions
func NewTransactionsStore ¶
func NewTransactionsStore( inMemoryTransactions *unsynchronized.Transactions, persistedTransactions storage.Transactions, ) *TransactionsStore
func (*TransactionsStore) Persist ¶
func (t *TransactionsStore) Persist(lctx lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds transactions to the batch. No errors are expected during normal operations
type TxResultErrMsgStore ¶
type TxResultErrMsgStore struct {
// contains filtered or unexported fields
}
TxResultErrMsgStore handles persisting transaction result error messages
func NewTxResultErrMsgStore ¶
func NewTxResultErrMsgStore( inMemoryTxResultErrMsg *unsynchronized.TransactionResultErrorMessages, persistedTxResultErrMsg storage.TransactionResultErrorMessages, blockID flow.Identifier, ) *TxResultErrMsgStore
func (*TxResultErrMsgStore) Persist ¶
func (t *TxResultErrMsgStore) Persist(lctx lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds transaction result error messages to the batch. No errors are expected during normal operations
Source Files