testutils

Documentation

Index

• type MedianAggregator
  • func NewMedianAggregator() *MedianAggregator
  • func (m *MedianAggregator) AggregatePrices()
  • func (m *MedianAggregator) GetPrices() types.Prices
  • func (m *MedianAggregator) Reset()
  • func (m *MedianAggregator) SetProviderPrices(provider string, data types.Prices)
  • func (m *MedianAggregator) UpdateMarketMap(_ mmtypes.MarketMap)

Types

type MedianAggregator

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

func NewMedianAggregator

func NewMedianAggregator() *MedianAggregator

NewMedianAggregator returns a new Median aggregator.

func (*MedianAggregator) AggregatePrices

func (m *MedianAggregator) AggregatePrices()

AggregatePrices inputs the aggregated prices from all providers and computes the median price for each asset.

func (*MedianAggregator) GetPrices

func (m *MedianAggregator) GetPrices() types.Prices

GetPrices returns the aggregated data the aggregator has.

func (*MedianAggregator) Reset

func (m *MedianAggregator) Reset()

Reset resets the data aggregator for all providers.

func (*MedianAggregator) SetProviderPrices

func (m *MedianAggregator) SetProviderPrices(provider string, data types.Prices)

SetProviderPrices updates the data aggregator with the given provider and data.

func (*MedianAggregator) UpdateMarketMap

func (m *MedianAggregator) UpdateMarketMap(_ mmtypes.MarketMap)