collections

Nov 20, 2025

Changes in this version

+ const DefaultCollectionCatchupDBPollInterval

+ const DefaultCollectionCatchupTimeout

+ const DefaultMissingCollectionRequestInterval

+ const DefaultMissingCollectionRequestThreshold

+ type CollectionIndexer interface

+ IndexCollections func(collections []*flow.Collection) error

+ MissingCollectionsAtHeight func(height uint64) ([]*flow.CollectionGuarantee, error)

+ OnCollectionReceived func(collection *flow.Collection)

+ type ExecutionDataSyncer struct

+ func NewExecutionDataSyncer(log zerolog.Logger, executionDataCache execution_data.ExecutionDataCache, ...) *ExecutionDataSyncer

+ func (s *ExecutionDataSyncer) IndexForHeight(ctx context.Context, height uint64) (bool, error)

+ type Indexer struct

+ func NewIndexer(log zerolog.Logger, db storage.DB, metrics module.CollectionExecutedMetric, ...) (*Indexer, error)

+ func (ci *Indexer) IndexCollections(collections []*flow.Collection) error

+ func (ci *Indexer) MissingCollectionsAtHeight(height uint64) ([]*flow.CollectionGuarantee, error)

+ func (ci *Indexer) OnCollectionReceived(collection *flow.Collection)

+ func (ci *Indexer) WorkerLoop(ctx irrecoverable.SignalerContext, ready component.ReadyFunc)

+ type Syncer struct

+ func NewSyncer(log zerolog.Logger, requester module.Requester, state protocol.State, ...) *Syncer

+ func (s *Syncer) OnCollectionDownloaded(_ flow.Identifier, entity flow.Entity)

+ func (s *Syncer) RequestCollectionsForBlock(height uint64, missingCollections []*flow.CollectionGuarantee) error

+ func (s *Syncer) WorkerLoop(ctx irrecoverable.SignalerContext, ready component.ReadyFunc)