sources

Documentation

Overview

Credit: @oleksandrmarkelov https://github.com/NibiruChain/pricefeeder/pull/27

Index

• Constants
• Variables
• func BinancePriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)
• func BinanceSymbolCsv(symbols set.Set[types.Symbol]) string
• func BitfinexPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)
• func BitfinexSymbolCsv(symbols set.Set[types.Symbol]) string
• func BybitPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)
• func CoingeckoPriceUpdate(sourceConfig json.RawMessage) types.FetchPricesFunc
• func CoinmarketcapPriceUpdate(coinmarketcapConfig json.RawMessage) types.FetchPricesFunc
• func GateIoPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)
• func OkexPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)
• type BinanceTicker
• type BybitResponse
• type CmcQuote
• type CmcQuotePrice
• type CmcResponse
• type CmcTicker
• type CoingeckoConfig
• type CoingeckoTicker
• type CoinmarketcapConfig
• type OkexResponse
• type OkexTicker
• type TickSource
  • func NewTickSource(symbols set.Set[types.Symbol], fetchPricesFunc types.FetchPricesFunc, ...) *TickSource
  • func (s *TickSource) Close()
  • func (s *TickSource) PriceUpdates() <-chan map[types.Symbol]types.RawPrice

Constants

const (
	Coingecko   = "coingecko"
	FreeLink    = "https://api.coingecko.com/api/v3/"
	PaidLink    = "https://pro-api.coingecko.com/api/v3/"
	ApiKeyParam = "x_cg_pro_api_key"
)

const (
	Binance = "binance"
)

const (
	Bitfinex = "bitfinex"
)

const (
	Bybit = "bybit"
)

const (
	CoinMarketCap = "coinmarketcap"
)

const (
	GateIo = "gateio"
)

const (
	Okex = "okex"
)

Variables

var UpdateTick = 8 * time.Second

UpdateTick defines the wait time between price updates.

Functions

func BinancePriceUpdate

func BinancePriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)

BinancePriceUpdate returns the prices given the symbols or an error. Uses the Binance API at https://docs.binance.us/#price-data.

func BinanceSymbolCsv

func BinanceSymbolCsv(symbols set.Set[types.Symbol]) string

func BitfinexPriceUpdate

func BitfinexPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)

BitfinexPriceUpdate returns the prices given the symbols or an error.

func BitfinexSymbolCsv

func BitfinexSymbolCsv(symbols set.Set[types.Symbol]) string

func BybitPriceUpdate

func BybitPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)

BybitPriceUpdate returns the prices for given symbols or an error. Uses BYBIT API at https://bybit-exchange.github.io/docs/v5/market/tickers.

func CoingeckoPriceUpdate

func CoingeckoPriceUpdate(sourceConfig json.RawMessage) types.FetchPricesFunc

func CoinmarketcapPriceUpdate

func CoinmarketcapPriceUpdate(coinmarketcapConfig json.RawMessage) types.FetchPricesFunc

func GateIoPriceUpdate

func GateIoPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)

GateIoPriceUpdate returns the prices given the symbols or an error. Uses the GateIo API at https://www.gate.io/docs/developers/apiv4/en/#get-details-of-a-specifc-currency-pair.

func OkexPriceUpdate

func OkexPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawPrices map[types.Symbol]float64, err error)

OkexPriceUpdate returns the prices for given symbols or an error. Uses OKEX API at https://www.okx.com/docs-v5/en/#rest-api-market-data.

Types

type BinanceTicker

type BinanceTicker struct {
	Symbol string  `json:"symbol"`
	Price  float64 `json:"price,string"`
}

type BybitResponse

type BybitResponse struct {
	Data struct {
		List []struct {
			Symbol string `json:"symbol"`
			Price  string `json:"lastPrice"`
		} `json:"list"`
	} `json:"result"`
}

type CmcQuote

type CmcQuote struct {
	USD CmcQuotePrice
}

type CmcQuotePrice

type CmcQuotePrice struct {
	Price float64
}

type CmcResponse

type CmcResponse struct {
	Data map[string]CmcTicker
}

type CmcTicker

type CmcTicker struct {
	Slug  string
	Quote CmcQuote
}

type CoingeckoConfig

type CoingeckoConfig struct {
	ApiKey string `json:"api_key"`
}

type CoingeckoTicker

type CoingeckoTicker struct {
	Price float64 `json:"usd"`
}

type CoinmarketcapConfig

type CoinmarketcapConfig struct {
	ApiKey string `json:"api_key"`
}

type OkexResponse

type OkexResponse struct {
	Data []OkexTicker `json:"data"`
}

type OkexTicker

type OkexTicker struct {
	Symbol string `json:"instId"`
	Price  string `json:"last"`
}

type TickSource

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

TickSource is a Source which updates prices every x time.Duration.

func NewTickSource

func NewTickSource(symbols set.Set[types.Symbol], fetchPricesFunc types.FetchPricesFunc, logger zerolog.Logger) *TickSource

NewTickSource instantiates a new TickSource instance, given the symbols and a price updater function which returns the latest prices for the provided symbols.

func (*TickSource) Close

func (s *TickSource) Close()

func (*TickSource) PriceUpdates

func (s *TickSource) PriceUpdates() <-chan map[types.Symbol]types.RawPrice