Versions in this module Expand all Collapse all v0 v0.2.0 May 11, 2026 Changes in this version + const BlockSourceFile + const BlockSourceLightbringer + const BlockSourceRpc + type BlockSource struct + func NewBlockSource(opts *BlockSourceOpts) *BlockSource + func (bs *BlockSource) BufferDepth() int + func (bs *BlockSource) Completed() bool + func (bs *BlockSource) DownloadInitialBlocks() + func (bs *BlockSource) GetFetchStats() FetchStatsSnapshot + func (bs *BlockSource) NextBlock() *b.Block + func (bs *BlockSource) NotifyBlockStart(slot uint64) + func (bs *BlockSource) RefreshTipsForSummary() + func (bs *BlockSource) ResetStats() + func (bs *BlockSource) SetLastExecutedSlot(slot uint64) + func (bs *BlockSource) StallTimeout() time.Duration + func (bs *BlockSource) Stalled() bool + func (bs *BlockSource) Start() + func (bs *BlockSource) StopReason() string + type BlockSourceOpts struct + BackupRpcEndpoints []string + BlockDir string + CatchupThreshold int + CatchupTipGateThreshold int + ConsensusManagedLightbringer bool + EndSlot uint64 + LightbringerEndpoint string + MaxInflight int + MaxRPS int + NearTipLookahead int + NearTipPollMs int + NearTipThreshold int + RpcClient *rpcclient.RpcClient + SourceType BlockSourceType + StartSlot uint64 + TipPollMs int + TipSafetyMargin uint64 + type BlockSourceStats struct + ErrBeyondTip atomic.Uint64 + ErrOther atomic.Uint64 + ErrRateLimited atomic.Uint64 + ErrSlotNotAvail atomic.Uint64 + ErrTransient atomic.Uint64 + FetchAttempts atomic.Uint64 + FetchLatencyCount atomic.Uint64 + FetchRetries atomic.Uint64 + FetchSkipped atomic.Uint64 + FetchSuccesses atomic.Uint64 + MaxBufferedSlot atomic.Uint64 + SpeculativeRetries atomic.Uint64 + TotalFetchLatencyNs atomic.Uint64 + type BlockSourceType int + type FetchStatsSnapshot struct + Attempts uint64 + AvgLatencyMs float64 + BufferDepth int + ConfirmedTip uint64 + CurrentSource string + ErrBeyondTip uint64 + ErrNotAvail uint64 + ErrOther uint64 + ErrRateLimit uint64 + ErrTransient uint64 + GetBlockRPS float64 + HandoffSlot uint64 + InflightCount int + IsNearTip bool + LeadSlots int64 + MaxBuffered uint64 + NextSlot uint64 + ProcessedTip uint64 + ReorderBufLen int + Retries uint64 + RetryQueueLen int + Skipped uint64 + SourceStatus string + SpeculativeRetries uint64 + SuccessRate float64 + Successes uint64 + TipAtSlot uint64 + TipPollFailures uint64 + TipStaleSecs int64 + TotalTipPollFails uint64 + WaitingSlotRetries int + WaitingSlotState string + WindowSecs float64 + WorkQueueLen int + type StallDiagnostics struct + ActiveRpcIdx int32 + ActiveRpcURL string + ConfirmedTip uint64 + ErrBeyondTip uint64 + ErrHardConn uint64 + ErrOther uint64 + ErrRateLimited uint64 + ErrSlotNotAvail uint64 + ErrTransient uint64 + FailoverCount uint64 + Gap uint64 + InflightCount int + IsOnPrimary bool + LastExecutedSlot uint64 + LastFailoverTime time.Time + LastProgressTs time.Time + MaxBufferedSlot uint64 + Mode string + RateLimitRPS float64 + ReorderBufLen int + RetryQueueLen int + SkippedSlotsLen int + StallElapsed time.Duration + WaitingSlot uint64 + WaitingSlotErrors *slotErrorInfo + WaitingSlotState string + WorkQueueLen int + WorkersTotal int v0.1.0-alpha.1 Jan 15, 2026
Go to main page