Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

provider

package

Go to main page

Versions in this module

v2

v2.1.0

Feb 15, 2023

Changes in this version

+ type WebsocketConnection struct

+ func (conn *WebsocketConnection) SendJSON(msg interface{}) error

type WebsocketController

+ func (wsc *WebsocketController) AddWebsocketConnection(msgs []interface{}, messageHandler MessageHandler, pingDuration time.Duration, ...)

+ func (wsc *WebsocketController) StartConnections()

v2.1.0-rc1

Feb 15, 2023

v2.0.4

Jan 31, 2023

v2.0.4-rc1

Jan 31, 2023

v2.0.3

Jan 6, 2023

v2.0.3-rc1

Jan 6, 2023

v2.0.2

Dec 14, 2022

Changes in this version

+ const KrakenRestHost

+ const KrakenRestPath

+ const MessageTypeCandle

+ const MessageTypeTicker

+ const MessageTypeTrade

+ func PastUnixTime(t time.Duration) int64

+ func SecondsToMilli(t int64) int64

+ func TelemetryFailure(n Name, mt MessageType)

+ type AggregatedProviderCandles map[Name]map[string][]types.CandlePrice

+ type AggregatedProviderPrices map[Name]map[string]types.TickerPrice

+ type BinanceCandle struct

+ Metadata BinanceCandleMetadata

+ Symbol string

+ type BinanceCandleMetadata struct

+ Close string

+ TimeStamp int64

+ Volume string

+ type BinancePairSummary struct

+ Symbol string

+ type BinanceProvider struct

+ func NewBinanceProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, binanceUS bool, ...) (*BinanceProvider, error)

+ func (p *BinanceProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *BinanceProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *BinanceProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *BinanceProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type BinanceSubscriptionMsg struct

+ ID uint16

+ Method string

+ Params []string

+ type BinanceSubscriptionResp struct

+ ID uint16

+ Result string

+ type BinanceTicker struct

+ C uint64

+ LastPrice string

+ Symbol string

+ Volume string

+ type BitgetCandle struct

+ Arg BitgetSubscriptionArg

+ Close string

+ TimeStamp int64

+ Volume string

+ type BitgetCandleResponse struct

+ Action string

+ Arg BitgetSubscriptionArg

+ Data [][]string

+ func (bcr BitgetCandleResponse) ToBitgetCandle() (BitgetCandle, error)

+ type BitgetErrResponse struct

+ Code uint64

+ Event string

+ Msg string

+ type BitgetPairData struct

+ Base string

+ Quote string

+ type BitgetPairsSummary struct

+ Data []BitgetPairData

+ RespCode string

+ type BitgetProvider struct

+ func NewBitgetProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*BitgetProvider, error)

+ func (p *BitgetProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *BitgetProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *BitgetProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *BitgetProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type BitgetSubscriptionArg struct

+ Channel string

+ InstID string

+ InstType string

+ type BitgetSubscriptionMsg struct

+ Args []BitgetSubscriptionArg

+ Operation string

+ type BitgetSubscriptionResponse struct

+ Arg BitgetSubscriptionArg

+ Event string

+ type BitgetTicker struct

+ Action string

+ Arg BitgetSubscriptionArg

+ Data []BitgetTickerData

+ type BitgetTickerData struct

+ InstID string

+ Price string

+ Volume string

+ type CoinbaseErrResponse struct

+ Reason string

+ Type string

+ type CoinbasePairSummary struct

+ Base string

+ Quote string

+ type CoinbaseProvider struct

+ func NewCoinbaseProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*CoinbaseProvider, error)

+ func (p *CoinbaseProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *CoinbaseProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *CoinbaseProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *CoinbaseProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type CoinbaseSubscriptionMsg struct

+ Channels []string

+ ProductIDs []string

+ Type string

+ type CoinbaseTicker struct

+ Price string

+ ProductID string

+ Volume string

+ type CoinbaseTrade struct

+ Price string

+ ProductID string

+ Size string

+ Time int64

+ type CoinbaseTradeResponse struct

+ Price string

+ ProductID string

+ Size string

+ Time string

+ Type string

+ type CryptoCandle struct

+ Close string

+ Timestamp int64

+ Volume string

+ type CryptoCandleResponse struct

+ Result CryptoCandleResult

+ type CryptoCandleResult struct

+ Channel string

+ Data []CryptoCandle

+ InstrumentName string

+ type CryptoHeartbeatRequest struct

+ ID int64

+ Method string

+ type CryptoHeartbeatResponse struct

+ ID int64

+ Method string

+ type CryptoInstruments struct

+ Data []CryptoTicker

+ type CryptoPairsSummary struct

+ Result CryptoInstruments

+ type CryptoProvider struct

+ func NewCryptoProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*CryptoProvider, error)

+ func (p *CryptoProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *CryptoProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *CryptoProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *CryptoProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type CryptoSubscriptionMsg struct

+ ID int64

+ Method string

+ Nonce int64

+ Params CryptoSubscriptionParams

+ type CryptoSubscriptionParams struct

+ Channels []string

+ type CryptoTicker struct

+ InstrumentName string

+ LatestTrade string

+ Volume string

+ type CryptoTickerResponse struct

+ Result CryptoTickerResult

+ type CryptoTickerResult struct

+ Channel string

+ Data []CryptoTicker

+ InstrumentName string

+ type Endpoint struct

+ Name Name

+ Rest string

+ Websocket string

+ type GateCandle struct

+ Close string

+ Symbol string

+ TimeStamp int64

+ Volume string

+ func (candle *GateCandle) UnmarshalParams(params [][]interface{}) error

+ type GateCandleResponse struct

+ Method string

+ Params [][]interface{}

+ type GateCandleSubscriptionMsg struct

+ ID uint16

+ Method string

+ Params []interface{}

+ type GateEvent struct

+ ID int

+ Result GateEventResult

+ type GateEventResult struct

+ Status string

+ type GatePairSummary struct

+ Base string

+ Quote string

+ type GateProvider struct

+ func NewGateProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*GateProvider, error)

+ func (p *GateProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *GateProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *GateProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *GateProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type GateTicker struct

+ Last string

+ Symbol string

+ Vol string

+ type GateTickerResponse struct

+ Method string

+ Params []interface{}

+ type GateTickerSubscriptionMsg struct

+ ID uint16

+ Method string

+ Params []string

+ type HuobiCandle struct

+ CH string

+ Tick HuobiCandleTick

+ type HuobiCandleTick struct

+ Close float64

+ TimeStamp int64

+ Volume float64

+ type HuobiPairData struct

+ Symbol string

+ type HuobiPairsSummary struct

+ Data []HuobiPairData

+ type HuobiProvider struct

+ func NewHuobiProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*HuobiProvider, error)

+ func (p *HuobiProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *HuobiProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *HuobiProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *HuobiProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type HuobiSubscriptionMsg struct

+ Sub string

+ type HuobiSubscriptionResp struct

+ Status string

+ type HuobiTick struct

+ LastPrice float64

+ Vol float64

+ type HuobiTicker struct

+ CH string

+ Tick HuobiTick

+ type KrakenCandle struct

+ Close string

+ Symbol string

+ TimeStamp int64

+ Volume string

+ func (candle *KrakenCandle) UnmarshalJSON(buf []byte) error

+ type KrakenEvent struct

+ Event string

+ type KrakenEventSubscriptionStatus struct

+ ErrorMessage string

+ Pair string

+ Status string

+ type KrakenPairData struct

+ WsName string

+ type KrakenPairsSummary struct

+ Result map[string]KrakenPairData

+ type KrakenProvider struct

+ func NewKrakenProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*KrakenProvider, error)

+ func (p *KrakenProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *KrakenProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *KrakenProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *KrakenProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type KrakenSubscriptionChannel struct

+ Name string

+ type KrakenSubscriptionMsg struct

+ Event string

+ Pair []string

+ Subscription KrakenSubscriptionChannel

+ type KrakenTicker struct

+ C []string

+ V []string

+ type MessageHandler func(int, []byte)

+ type MessageType string

+ func (mt MessageType) String() string

+ type MexcCandle struct

+ Close float64

+ TimeStamp int64

+ Volume float64

+ type MexcCandleResponse struct

+ Metadata MexcCandle

+ Symbol string

+ type MexcCandleSubscription struct

+ Interval string

+ OP string

+ Symbol string

+ type MexcPairSummary struct

+ Symbol string

+ type MexcProvider struct

+ func NewMexcProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*MexcProvider, error)

+ func (p *MexcProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *MexcProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *MexcProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *MexcProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type MexcTicker struct

+ LastPrice float64

+ Volume float64

+ type MexcTickerResponse struct

+ Symbol map[string]MexcTicker

+ type MexcTickerSubscription struct

+ OP string

+ type MockProvider struct

+ func NewMockProvider() *MockProvider

+ func (p MockProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p MockProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p MockProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p MockProvider) SubscribeCurrencyPairs(pairs ...types.CurrencyPair) error

+ type Name string

+ const ProviderBinance

+ const ProviderBinanceUS

+ const ProviderBitget

+ const ProviderCoinbase

+ const ProviderCrypto

+ const ProviderGate

+ const ProviderHuobi

+ const ProviderKraken

+ const ProviderMexc

+ const ProviderMock

+ const ProviderOkx

+ const ProviderOsmosis

+ const ProviderOsmosisV2

+ func (n Name) String() string

+ type OkxCandlePair struct

+ Close string

+ InstID string

+ TimeStamp int64

+ Volume string

+ type OkxCandleResponse struct

+ Data [][]string

+ ID OkxID

+ type OkxID struct

+ Channel string

+ type OkxInstID struct

+ InstID string

+ type OkxPairsSummary struct

+ Data []OkxInstID

+ type OkxProvider struct

+ func NewOkxProvider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*OkxProvider, error)

+ func (p *OkxProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *OkxProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *OkxProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *OkxProvider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type OkxSubscriptionMsg struct

+ Args []OkxSubscriptionTopic

+ Op string

+ type OkxSubscriptionTopic struct

+ Channel string

+ InstID string

+ type OkxTickerPair struct

+ Last string

+ Vol24h string

+ type OkxTickerResponse struct

+ Data []OkxTickerPair

+ ID OkxID

+ type OsmosisCandleResponse struct

+ Close float64

+ Time int64

+ Volume float64

+ type OsmosisPairData struct

+ Base string

+ Quote string

+ type OsmosisPairsSummary struct

+ Data []OsmosisPairData

+ type OsmosisProvider struct

+ func NewOsmosisProvider(endpoint Endpoint) *OsmosisProvider

+ func (p OsmosisProvider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p OsmosisProvider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p OsmosisProvider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p OsmosisProvider) SubscribeCurrencyPairs(pairs ...types.CurrencyPair) error

+ type OsmosisTokenResponse struct

+ Price float64

+ Symbol string

+ Volume float64

+ type OsmosisV2Candle struct

+ Close string

+ EndTime int64

+ Volume string

+ type OsmosisV2PairData struct

+ Base string

+ Quote string

+ type OsmosisV2PairsSummary struct

+ Data []OsmosisPairData

+ type OsmosisV2Provider struct

+ func NewOsmosisV2Provider(ctx context.Context, logger zerolog.Logger, endpoints Endpoint, ...) (*OsmosisV2Provider, error)

+ func (p *OsmosisV2Provider) GetAvailablePairs() (map[string]struct{}, error)

+ func (p *OsmosisV2Provider) GetCandlePrices(pairs ...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ func (p *OsmosisV2Provider) GetTickerPrices(pairs ...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ func (p *OsmosisV2Provider) SubscribeCurrencyPairs(cps ...types.CurrencyPair) error

+ type OsmosisV2Ticker struct

+ Price string

+ Volume string

+ type Provider interface

+ GetAvailablePairs func() (map[string]struct{}, error)

+ GetCandlePrices func(...types.CurrencyPair) (map[string][]types.CandlePrice, error)

+ GetTickerPrices func(...types.CurrencyPair) (map[string]types.TickerPrice, error)

+ SubscribeCurrencyPairs func(...types.CurrencyPair) error

+ type WebsocketController struct

+ func NewWebsocketController(ctx context.Context, providerName Name, websocketURL url.URL, ...) *WebsocketController

+ func (wsc *WebsocketController) AddSubscriptionMsgs(msgs []interface{}) error

+ func (wsc *WebsocketController) SendJSON(msg interface{}) error

+ func (wsc *WebsocketController) Start()

Other modules containing this package

github.com/umee-network/umee/price-feeder