blockprocessor

Documentation

Index

• func NewBlockProcessor(blockProcessStrategyManager commondomain.BlockProcessStrategyManager, ...) commondomain.BlockProcessor
• func NewPairPublisher(client domain.Publisher, poolManagerKeeper domain.PoolManagerKeeperI) domain.PairPublisher
• type PairPublisher
  • func (p PairPublisher) PublishPoolPairs(ctx sdk.Context, pools []poolmanagertypes.PoolI) error

Functions

func NewBlockProcessor

func NewBlockProcessor(blockProcessStrategyManager commondomain.BlockProcessStrategyManager, client domain.Publisher, poolExtractor commondomain.PoolExtractor, keepers domain.Keepers) commondomain.BlockProcessor

NewBlockProcessor creates a new block process strategy.

func NewPairPublisher

func NewPairPublisher(client domain.Publisher, poolManagerKeeper domain.PoolManagerKeeperI) domain.PairPublisher

NewPairPublisher creates a new pair publisher.

Types

type PairPublisher

type PairPublisher struct {
	// contains filtered or unexported fields
}

func (PairPublisher) PublishPoolPairs

func (p PairPublisher) PublishPoolPairs(ctx sdk.Context, pools []poolmanagertypes.PoolI) error

PublishPoolPairs publishes the denom pairs contained in the pools. Each pool pair is published with the taker fee and spread factor. Invalid denoms are skipped as per domain.ShouldFilterDenom function. Returns error if at least one of the pairs failed to be published. Nil otherwise. TODO: unit test