binance_ws

Documentation

Index

• type Event
• type WsBookTickerEvent
• type WsClient
  • func NewWsClient(cfg *config.Config, log *zap.Logger, ctx context.Context, ...) *WsClient
  • func (w *WsClient) ConnectAndSubscribe() error
  • func (w *WsClient) ReadLoop()
  • func (w *WsClient) Serve() error

Types

type Event

type Event struct {
	Stream string            `json:"stream"`
	Data   WsBookTickerEvent `json:"data"`
}

type WsBookTickerEvent

type WsBookTickerEvent struct {
	UpdateID     int64           `json:"u"`
	Symbol       string          `json:"s"`
	BestBidPrice decimal.Decimal `json:"b"`
	BestBidQty   decimal.Decimal `json:"B"`
	BestAskPrice decimal.Decimal `json:"a"`
	BestAskQty   decimal.Decimal `json:"A"`
	ReceiveTime  int64           `json:"rt"`
}

type WsClient

type WsClient struct {
	Conn *websocket.Conn
	// contains filtered or unexported fields
}

func NewWsClient

func NewWsClient(cfg *config.Config, log *zap.Logger, ctx context.Context, handler func(event *WsBookTickerEvent)) *WsClient

func (*WsClient) ConnectAndSubscribe

func (w *WsClient) ConnectAndSubscribe() error

func (*WsClient) ReadLoop

func (w *WsClient) ReadLoop()

func (*WsClient) Serve

func (w *WsClient) Serve() error