market

Jan 26, 2018

Changes in this version

+ var SafeWebSocketDestroyError = fmt.Errorf("connection destroy by user")

+ type SafeWebSocket struct

+ func NewSafeWebSocket(endpoint string) (*SafeWebSocket, error)

+ func (s *SafeWebSocket) Destroy() error

+ func (s *SafeWebSocket) KeepAlive(v time.Duration, h SafeWebSocketAliveHandler)

+ func (s *SafeWebSocket) Listen(h SafeWebSocketMessageListener)

+ func (s *SafeWebSocket) Loop() error

+ func (s *SafeWebSocket) Send(b []byte)

+ type SafeWebSocketAliveHandler = func()

+ type SafeWebSocketMessageListener = func(b []byte)

Jan 26, 2018

Changes in this version

+ var ConnectionClosedError = fmt.Errorf("websocket connection closed")

+ var PollingDelay time.Duration = time.Millisecond * 100

type Market

+ HeartbeatInterval time.Duration

+ ReceiveTimeout time.Duration

+ func (m *Market) Destroy() (err error)

Jan 25, 2018

Changes in this version

+ var Endpoint = "wss://api.huobi.pro/ws"

+ type Listener = func(topic string, json *simplejson.Json)

+ type Market struct

+ func NewMarket() (m *Market, err error)

+ func (m *Market) Close() error

+ func (m *Market) Loop()

+ func (m *Market) ReConnect() error

+ func (m *Market) Request(req string) (*simplejson.Json, error)

+ func (m *Market) Subscribe(topic string, listener Listener) error

+ func (m *Market) Unsubscribe(topic string)