iterator

Dec 17, 2025

Changes in this version

+ const DefaultBatchSize

type BackfillIterator

+ func (b *BackfillIterator) NextBatch(ctx context.Context) (*BatchRequest, error)

+ type BatchRequest struct

+ BatchSize int

+ CurrentSlot uint64

+ Params url.Values

+ TargetSlot uint64

type ForwardFillIterator

+ func (f *ForwardFillIterator) NextBatch(ctx context.Context) (*BatchRequest, error)

Aug 25, 2025

Changes in this version

+ type BackfillIterator struct

+ func NewBackfillIterator(log logrus.FieldLogger, networkName, clientName string, ...) *BackfillIterator

+ func (b *BackfillIterator) Next(ctx context.Context) (*phase0.Slot, error)

+ func (b *BackfillIterator) UpdateLocation(ctx context.Context, slot phase0.Slot) error

+ type ConsistencyMetrics struct

+ CurrentSlot *prometheus.GaugeVec

+ Lag *prometheus.GaugeVec

+ func NewConsistencyMetrics(namespace string) *ConsistencyMetrics

+ func (m *ConsistencyMetrics) SetCurrentSlot(process, relay, eventType, network string, slot uint64)

+ func (m *ConsistencyMetrics) SetLag(process, relay, eventType, network string, lag int64)

+ type ForwardFillIterator struct

+ func NewForwardFillIterator(log logrus.FieldLogger, networkName, clientName string, ...) *ForwardFillIterator

+ func (f *ForwardFillIterator) Next(ctx context.Context) (*phase0.Slot, error)

+ func (f *ForwardFillIterator) UpdateLocation(ctx context.Context, slot phase0.Slot) error