blockprocessor

Documentation

Index

• func NewBlockProcessor(blockProcessStrategyManager commondomain.BlockProcessStrategyManager, ...) commondomain.BlockProcessor

Functions

func NewBlockProcessor

func NewBlockProcessor(blockProcessStrategyManager commondomain.BlockProcessStrategyManager, client domain.SQSGRPClient, poolExtractor commondomain.PoolExtractor, poolsTransformer domain.PoolsTransformer, nodeStatusChecker domain.NodeStatusChecker, blockUpdateProcessUtils commondomain.BlockUpdateProcessUtilsI) commondomain.BlockProcessor

NewBlockProcessor creates a new block process strategy. If block process strategy manager should push all data, then it will return a full indexer block process strategy. Otherwise, it will return a block updates SQS block process strategy.