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")

ConnectionClosedError Websocket未连接错误

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

Endpoint 行情的Websocket入口

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

Types

type Listener

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

Listener 订阅事件监听器

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)

NewMarket 创建Market实例

func (*Market) Close

func (m *Market) Close() error

Close 关闭连接

func (*Market) Loop

func (m *Market) Loop()

Loop 进入循环

func (*Market) ReConnect

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

ReConnect 重新连接

func (*Market) Request

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

Request 请求行情信息

func (*Market) Subscribe

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

Subscribe 订阅

func (*Market) Unsubscribe

func (m *Market) Unsubscribe(topic string)

Unsubscribe 取消订阅

type SafeWebSocket

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

SafeWebSocket 安全的WebSocket封装 保证读取和发送操作是并发安全的，支持自定义保持alive函数

func NewSafeWebSocket

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

NewSafeWebSocket 创建安全的WebSocket实例并连接

func (*SafeWebSocket) Destroy

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

Destroy 销毁

func (*SafeWebSocket) KeepAlive

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

KeepAlive 设置alive周期及函数

func (*SafeWebSocket) Listen

func (s *SafeWebSocket) Listen(h SafeWebSocketMessageListener)

Listen 监听消息

func (*SafeWebSocket) Loop

func (s *SafeWebSocket) Loop() error

Loop 进入事件循环，直到连接关闭才退出

func (*SafeWebSocket) Send

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

Send 发送消息

type SafeWebSocketAliveHandler

type SafeWebSocketAliveHandler = func()

type SafeWebSocketMessageListener

type SafeWebSocketMessageListener = func(b []byte)