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(_ lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds results to the batch.
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, ) *TxResultErrMsgStore
func (*TxResultErrMsgStore) Persist ¶
func (t *TxResultErrMsgStore) Persist(_ lockctx.Proof, batch storage.ReaderBatchWriter) error
Persist adds transaction result error messages to the batch.
No error returns are expected during normal operations
Source Files