service

Documentation

Index

• func New(writeListeners map[storetypes.StoreKey][]storetypes.WriteListener, ...) baseapp.StreamingService
• func NewNodeStatusChecker(address string) domain.NodeStatusChecker
• func NewPoolTracker() domain.BlockPoolUpdateTracker

Functions

func New

func New(writeListeners map[storetypes.StoreKey][]storetypes.WriteListener, sqsIngester domain.Ingester, poolTracker domain.BlockPoolUpdateTracker, nodeStatusChecker domain.NodeStatusChecker) 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.

func NewNodeStatusChecker

func NewNodeStatusChecker(address string) domain.NodeStatusChecker

func NewPoolTracker

func NewPoolTracker() domain.BlockPoolUpdateTracker

NewPoolTracker creates a new poolBlockUpdateTracker.