pricefeed

Documentation

Index

• func GetTestMarketPriceUpdates(n int) (indexPrices []*pricefeedapi.MarketPriceUpdate)
• func UpdateIndexPrice(t *testing.T, ctx sdk.Context, tApp *app.App, marketId uint32, price uint64, ...)
• type ExchangeServer
  • func NewExchangeServer() *ExchangeServer
  • func (p *ExchangeServer) CleanUp() error
  • func (p *ExchangeServer) GetPrice(marketId pricefeed.MarketId) float64
  • func (p *ExchangeServer) SetPrice(marketId pricefeed.MarketId, price float64)

Functions

func GetTestMarketPriceUpdates

func GetTestMarketPriceUpdates(n int) (indexPrices []*pricefeedapi.MarketPriceUpdate)

func UpdateIndexPrice

func UpdateIndexPrice(
	t *testing.T,
	ctx sdk.Context,
	tApp *app.App,
	marketId uint32,
	price uint64,
	lastUpdatedTime time.Time,
)

Types

type ExchangeServer

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

func NewExchangeServer

func NewExchangeServer() *ExchangeServer

NewExchangeServer creates a new ExchangeServer that can be used to fake price data from exchanges. This server responds queries for the test exchange built into the pricefeed daemon and for bitfinex. It is appropriate to run locally or on containers.

func (*ExchangeServer) CleanUp

func (p *ExchangeServer) CleanUp() error

CleanUp shuts down the server and validates that it shut down correctly.

func (*ExchangeServer) GetPrice

func (p *ExchangeServer) GetPrice(marketId pricefeed.MarketId) float64

func (*ExchangeServer) SetPrice

func (p *ExchangeServer) SetPrice(marketId pricefeed.MarketId, price float64)