service

Documentation

Index

• func New(blockUpdatesProcessUtils commondomain.BlockUpdateProcessUtilsI, ...) *indexerStreamingService

Functions

func New

func New(blockUpdatesProcessUtils commondomain.BlockUpdateProcessUtilsI, blockProcessStrategyManager commondomain.BlockProcessStrategyManager, client domain.Publisher, storeKeyMap map[string]storetypes.StoreKey, poolExtractor commondomain.PoolExtractor, poolTracker sqsdomain.BlockPoolUpdateTracker, keepers domain.Keepers, txDecoder sdk.TxDecoder, nodeStatusChecker commonservice.NodeStatusChecker, logger log.Logger) *indexerStreamingService

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.