service

Documentation

Index

• func New(writeListeners map[storetypes.StoreKey][]storetypes.WriteListener, ...) baseapp.StreamingService

Functions

func New

func New(writeListeners map[storetypes.StoreKey][]storetypes.WriteListener, blockProcessStrategyManager commondomain.BlockProcessStrategyManager, client domain.Publisher, poolExtractor commondomain.PoolExtractor, poolTracker sqsdomain.BlockPoolUpdateTracker, keepers domain.Keepers, txDecoder sdk.TxDecoder, logger log.Logger) baseapp.StreamingService

New creates a new sqsStreamingService. writeListeners is a map of store keys to write listeners. sqsIngester is an ingester that ingests the block data into SQS. poolTracker is a tracker that tracks the pools that were changed in the block. nodeStatusChecker is a checker that checks if the node is syncing.