Add MaxStopBlock variable to blockpoller

Introduce a MaxStopBlock variable to be used in the BlockPoller. This change helps manage the upper limit for block polling, allowing more flexibility and control over the polling process.
streamingfast · Nov 21, 2024 · 0f91a00 · 0f91a00
1 parent cf7a94a
commit 0f91a00
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/blockpoller/poller.go b/blockpoller/poller.go
@@ -73,6 +73,8 @@ func New[C any](
 	return b
 }
 
+var MaxStopBlock *uint64 = nil
+
 func (p *BlockPoller[C]) Run(firstStreamableBlockNum uint64, stopBlock *uint64, blockFetchBatchSize int) error {
 	p.startBlockNumGate = firstStreamableBlockNum
 	p.logger.Info("starting poller",