blockstream

package

Go to main page

Versions in this module

v0

v0.3.0

Jun 11, 2026

Changes in this version

+ const BlockSourceTurbine

type BlockSource

+ func (bs *BlockSource) ForceRPCFallback(reason string)

type BlockSourceOpts

+ LeaderForSlot func(slot uint64) (solana.PublicKey, bool)

+ TurbineAdvertisedIP string

+ TurbineBindAddr string

+ TurbineGossipBindAddr string

+ TurbineGossipEntrypoint string

+ TurbineShredVersion uint16

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL