Versions in this module Expand all Collapse all v0 v0.1.0 Aug 29, 2021 Changes in this version + func CheckDisconnections(c *websocket.Conn, logger zerolog.Logger) (context.Context, context.CancelFunc, error) + func GetExchange(name string) (common.Exchange, bool) + func GetExchanges(enabledExchanges ...string) []common.Exchange + func RegisterExchange(exchange common.Exchange) + type Exchange struct + Lock sync.Mutex + Logger zerolog.Logger + OrderBooks map[string]*orderbook.OrderBook + Ws map[string]*websocket.Conn + func NewExchange(name string, availablePairs []common.Pair) *Exchange + func (e *Exchange) AvailablePairs() []common.Pair + func (e *Exchange) CheckDisconnections(c *websocket.Conn, logger zerolog.Logger) (context.Context, context.CancelFunc, error) + func (e *Exchange) CheckResponse(resp *http.Response) error + func (e *Exchange) Close() error + func (e *Exchange) GetOrderBook(pair common.Pair) *orderbook.OrderBook + func (e *Exchange) GetSnapshot(pair common.Pair) (common.Snapshot, error) + func (e *Exchange) Name() string + func (e *Exchange) NewOrderBook(pair common.Pair, pairLogger zerolog.Logger) *orderbook.OrderBook + func (e *Exchange) OnOrderBookUpdate(initial bool, pair common.Pair) + func (e *Exchange) PairAvailable(pair common.Pair) bool + func (e *Exchange) SetMaxSnapshotSize(val int) + func (e *Exchange) SubscribeUpdates(pair common.Pair, chanSize int) chan uint64 + func (e *Exchange) UnsubscribeUpdates(pair common.Pair) bool
Go to main page