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( data []flow.Event, persistedEvents storage.Events, blockID flow.Identifier, ) *EventsStore
func (*EventsStore) Persist ¶
func (e *EventsStore) Persist(_ lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds events to the batch.
No error returns 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(_ lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds the latest sealed result to the batch.
No error returns are expected during normal operations
type LightCollectionsStore ¶
type LightCollectionsStore struct {
// contains filtered or unexported fields
}
LightCollectionsStore handles persisting light collections
func NewCollectionsStore ¶
func NewCollectionsStore( data []*flow.Collection, persistedCollections storage.Collections, ) *LightCollectionsStore
func (*LightCollectionsStore) Persist ¶
func (c *LightCollectionsStore) Persist(lctx lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds light collections to the batch.
No error returns are expected during normal operations
type PersisterStore ¶
type PersisterStore interface {
// Persist adds data to the batch for later commitment.
//
// No error returns 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( data []flow.LightTransactionResult, persistedResults storage.LightTransactionResults, blockID flow.Identifier, ) *ResultsStore
func (*ResultsStore) Persist ¶
func (r *ResultsStore) Persist(lctx lockctx.Proof, rw storage.ReaderBatchWriter) error
Persist saves and indexes all transaction results (light representation) for our block as part of the provided database batch. The caller must acquire storage.LockInsertLightTransactionResult and hold it until the write batch has been committed. No error returns 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( data []flow.TransactionResultErrorMessage, persistedTxResultErrMsg storage.TransactionResultErrorMessages, blockID flow.Identifier, lockManager storage.LockManager, ) *TxResultErrMsgStore
func (*TxResultErrMsgStore) Persist ¶
func (t *TxResultErrMsgStore) Persist(lctx lockctx.Proof, rw storage.ReaderBatchWriter) error
Persist saves and indexes all transaction result error messages for our block as part of the provided database batch. The caller must acquire storage.LockInsertTransactionResultErrMessage and hold it until the write batch has been committed. No error returns are expected during normal operations
Source Files