Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewExecutionDataProvider ¶
func NewExecutionDataProvider( cache execution_data.ExecutionDataCache, highestExectuionDataHeight state_synchronization.ExecutionDataIndexedHeight, ) *executionDataProvider
NewExecutionDataProvider creates a new ExecutionDataProvider that reads from the given ExecutionDataCache. The headers storage is used to determine the search range for finding available heights.
Types ¶
type ExecutionDataProcessor ¶
type ExecutionDataProcessor struct {
component.Component
// contains filtered or unexported fields
}
func NewExecutionDataProcessor ¶
func NewExecutionDataProcessor( log zerolog.Logger, provider collection_sync.ExecutionDataProvider, indexer collection_sync.BlockCollectionIndexer, processedHeight *counters.PersistentStrictMonotonicCounter, onIndexedCallback func(uint64), ) *ExecutionDataProcessor
func (*ExecutionDataProcessor) OnNewExectuionData ¶
func (edp *ExecutionDataProcessor) OnNewExectuionData()
func (*ExecutionDataProcessor) ProcessedHeight ¶
func (edp *ExecutionDataProcessor) ProcessedHeight() uint64
ProcessedHeight returns the highest consecutive height for which execution data has been processed, meaning the collections for that height have been indexed.
Source Files
Click to show internal directories.
Click to hide internal directories.