Documentation
¶
Index ¶
- Variables
- func FindLast(p currency.Pair, a asset.Item) (float64, error)
- func ProcessTicker(p *Price) error
- func SubscribeTicker(exchange string, p currency.Pair, a asset.Item) (dispatch.Pipe, error)
- func SubscribeToExchangeTickers(exchange string) (dispatch.Pipe, error)
- type Price
- type Service
- type Ticker
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrNoTickerFound is when a ticker is not found ErrNoTickerFound = errors.New("no ticker found") // ErrBidEqualsAsk error for locked markets ErrBidEqualsAsk = errors.New("bid equals ask this is a crossed or locked market") // ErrExchangeNameIsEmpty is an error for when an exchange name is empty ErrExchangeNameIsEmpty = errors.New("exchange name is empty") )
Functions ¶
func ProcessTicker ¶
ProcessTicker processes incoming tickers, creating or updating the Tickers list
func SubscribeTicker ¶
SubscribeTicker subscribes to a ticker and returns a communication channel to stream new ticker updates
Types ¶
type Price ¶
type Price struct {
Last float64 `json:"Last"`
High float64 `json:"High"`
Low float64 `json:"Low"`
Bid float64 `json:"Bid"`
Ask float64 `json:"Ask"`
Volume float64 `json:"Volume"`
QuoteVolume float64 `json:"QuoteVolume"`
PriceATH float64 `json:"PriceATH"`
Open float64 `json:"Open"`
Close float64 `json:"Close"`
OpenInterest float64 `json:"OpenInterest"`
MarkPrice float64 `json:"MarkPrice"`
IndexPrice float64 `json:"IndexPrice"`
Pair currency.Pair `json:"Pair"`
ExchangeName string `json:"exchangeName"`
AssetType asset.Item `json:"assetType"`
LastUpdated time.Time
// Funding rate field variables
FlashReturnRate float64
BidPeriod float64
BidSize float64
AskPeriod float64
AskSize float64
FlashReturnRateAmount float64
}
Price struct stores the currency pair and pricing information
func GetExchangeTickers ¶
GetExchangeTickers returns all tickers for a given exchange
Click to show internal directories.
Click to hide internal directories.