market

Documentation

Index

• Variables
• type Listener
• type Market
  • func NewMarket() (m *Market, err error)
  • func (m *Market) Close() error
  • func (m *Market) Loop()
  • func (m *Market) ReConnect() (err 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)
• type SafeWebSocket
  • func NewSafeWebSocket(endpoint string) (*SafeWebSocket, error)
  • func (s *SafeWebSocket) Destroy() (err 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
• type SafeWebSocketMessageListener

Variables

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

/ Websocket未连接错误

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

/ 行情的Websocket入口

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

Types

type Listener

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

/ 订阅事件监听器

type Market

type Market struct {

	// 主动发送心跳的时间间隔，默认5秒
	HeartbeatInterval time.Duration
	// 接收消息超时时间，默认10秒
	ReceiveTimeout time.Duration
	// contains filtered or unexported fields
}

func NewMarket

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

/ 创建Market实例

func (*Market) Close

func (m *Market) Close() error

/ 关闭连接

func (*Market) Loop

func (m *Market) Loop()

/ 进入循环

func (*Market) ReConnect

func (m *Market) ReConnect() (err error)

/ 重新连接

func (*Market) Request

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

/ 请求行情信息

func (*Market) Subscribe

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

/ 订阅

func (*Market) Unsubscribe

func (m *Market) Unsubscribe(topic string)

/ 取消订阅

type SafeWebSocket

type SafeWebSocket struct {
	// contains filtered or unexported fields
}

func NewSafeWebSocket

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

func (*SafeWebSocket) Destroy

func (s *SafeWebSocket) Destroy() (err error)

func (*SafeWebSocket) KeepAlive

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

func (*SafeWebSocket) Listen

func (s *SafeWebSocket) Listen(h SafeWebSocketMessageListener)

func (*SafeWebSocket) Loop

func (s *SafeWebSocket) Loop() error

func (*SafeWebSocket) Send

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

type SafeWebSocketAliveHandler

type SafeWebSocketAliveHandler = func()

type SafeWebSocketMessageListener

type SafeWebSocketMessageListener = func(b []byte)