price_encoder

Documentation

Index

• Constants
• type PriceEncoder
• type PriceEncoderImpl
  • func NewPriceEncoder(mutableExchangeConfig *types.MutableExchangeMarketConfig, ...) (*PriceEncoderImpl, error)
  • func (p *PriceEncoderImpl) GetExchangeId() types.ExchangeId
  • func (p *PriceEncoderImpl) ProcessPriceFetcherResponse(response *price_fetcher.PriceFetcherSubtaskResponse)
  • func (p *PriceEncoderImpl) UpdateMutableExchangeConfig(newConfig *types.MutableExchangeMarketConfig, ...) error
  • func (p *PriceEncoderImpl) UpdatePrice(marketPriceTimestamp *types.MarketPriceTimestamp)

Constants

const (
	FailedToUpdateExchangePrice = "Failed to update exchange price in price daemon priceEncoder"
)

Types

type PriceEncoder

type PriceEncoder interface {
	types.ExchangeConfigUpdater
	ProcessPriceFetcherResponse(response *price_fetcher.PriceFetcherSubtaskResponse)
}

type PriceEncoderImpl

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

func NewPriceEncoder

func NewPriceEncoder(
	mutableExchangeConfig *types.MutableExchangeMarketConfig,
	mutableMarketConfigs []*types.MutableMarketConfig,
	exchangeToMarketPrices types.ExchangeToMarketPrices,
	logger log.Logger,
	bCh <-chan *price_fetcher.PriceFetcherSubtaskResponse,
) (*PriceEncoderImpl, error)

NewPriceEncoder creates a new, initialized PriceEncoderImpl struct. It manages decoding and converting of raw prices returned from the price fetcher into the shared exchangeToMarketPrices cache. All prices stored in the cache are converted to the market price in a quote currency of USD, even if the API request was made for a different market and/or used a different quote currency.

func (*PriceEncoderImpl) GetExchangeId

func (p *PriceEncoderImpl) GetExchangeId() types.ExchangeId

GetExchangeId returns the exchange id for this PriceEncoder.

func (*PriceEncoderImpl) ProcessPriceFetcherResponse

func (p *PriceEncoderImpl) ProcessPriceFetcherResponse(response *price_fetcher.PriceFetcherSubtaskResponse)

ProcessPriceFetcherResponse consumes the (price, error) response from the price fetcher and either updates the exchangeToMarketPrices cache with a valid price, or appropriately logs and reports metrics for errors.

func (*PriceEncoderImpl) UpdateMutableExchangeConfig

func (p *PriceEncoderImpl) UpdateMutableExchangeConfig(
	newConfig *types.MutableExchangeMarketConfig,
	newMarketConfigs []*types.MutableMarketConfig,
) error

UpdateMutableExchangeConfig updates the price encoder with the most current copy of the exchange config, as well as all markets supported by the exchange. This method is added to support the ExchangeConfigUpdater interface.

func (*PriceEncoderImpl) UpdatePrice

func (p *PriceEncoderImpl) UpdatePrice(marketPriceTimestamp *types.MarketPriceTimestamp)

UpdatePrice updates the price cache shared by the price updater with the converted market price.