Refactored parameter to global

This commit is contained in:
David Zhou 2025-05-23 14:22:26 -04:00
parent f97c6ad585
commit cccc2d80d9

View file

@ -258,12 +258,12 @@ func NewFirehose(config *FirehoseConfig) *Firehose {
tracerID: "global",
applyBackwardCompatibility: config.ApplyBackwardCompatibility,
concurrentBlockFlushing: config.ConcurrentBlockFlushing,
concurrentFlushBufferSize: 100,
// Block state
blockOrdinal: &Ordinal{},
blockFinality: &FinalityStatus{},
blockReorderOrdinal: false,
concurrentFlushBufferSize: 100,
blockOrdinal: &Ordinal{},
blockFinality: &FinalityStatus{},
blockReorderOrdinal: false,
// Transaction state
transactionLogIndex: 0,