wsclient

Documentation

Index

• Constants
• type ConnectedHandler
• type MessageHandler
• type PrivateWebsocketClient
  • func (p *PrivateWebsocketClient) Init(host string, tokenProducer TokenProducer, reconnectWaitSecond int64) *PrivateWebsocketClient
  • func (p *PrivateWebsocketClient) SetHandler(connectedHandler ConnectedHandler, responseHandler ResponseHandler)
  • func (p *PrivateWebsocketClient) Subscribe(paramMap map[string]interface{})
  • func (p *PrivateWebsocketClient) UnSubscribe(paramMap map[string]interface{})
• type PublicWebsocketClient
  • func (p *PublicWebsocketClient) Init(host string, reconnectWaitSecond int64) *PublicWebsocketClient
  • func (p *PublicWebsocketClient) SetHandler(connectedHandler ConnectedHandler, responseHandler ResponseHandler)
  • func (p *PublicWebsocketClient) Subscribe(paramMap map[string]interface{})
  • func (p *PublicWebsocketClient) UnSubscribe(paramMap map[string]interface{})
• type ResponseHandler
• type TokenProducer
• type WebSocketClientBase
  • func (wsc *WebSocketClientBase) BuildRequestBody(paramMap map[string]interface{}) (string, error)
  • func (wsc *WebSocketClientBase) Close()
  • func (wsc *WebSocketClientBase) Connect(autoConnect bool)
  • func (wsc *WebSocketClientBase) Init(host string, tokenProducer TokenProducer, reconnectWaitSecond int64) *WebSocketClientBase
  • func (wsc *WebSocketClientBase) Send(data string)
  • func (wsc *WebSocketClientBase) SetHandler(connHandler ConnectedHandler, repHandler ResponseHandler)

Constants

const (
	TimerIntervalSecond = 5
)

Types

type ConnectedHandler

type ConnectedHandler func()

type MessageHandler

type MessageHandler func(message string) (interface{}, error)

type PrivateWebsocketClient

type PrivateWebsocketClient struct {
	WebSocketClientBase
}

func (*PrivateWebsocketClient) Init

func (p *PrivateWebsocketClient) Init(host string, tokenProducer TokenProducer, reconnectWaitSecond int64) *PrivateWebsocketClient

func (*PrivateWebsocketClient) SetHandler

func (p *PrivateWebsocketClient) SetHandler(
	connectedHandler ConnectedHandler,
	responseHandler ResponseHandler)

func (*PrivateWebsocketClient) Subscribe

func (p *PrivateWebsocketClient) Subscribe(paramMap map[string]interface{})

func (*PrivateWebsocketClient) UnSubscribe

func (p *PrivateWebsocketClient) UnSubscribe(paramMap map[string]interface{})

type PublicWebsocketClient

type PublicWebsocketClient struct {
	WebSocketClientBase
}

func (*PublicWebsocketClient) Init

func (p *PublicWebsocketClient) Init(host string, reconnectWaitSecond int64) *PublicWebsocketClient

func (*PublicWebsocketClient) SetHandler

func (p *PublicWebsocketClient) SetHandler(
	connectedHandler ConnectedHandler,
	responseHandler ResponseHandler)

func (*PublicWebsocketClient) Subscribe

func (p *PublicWebsocketClient) Subscribe(paramMap map[string]interface{})

func (*PublicWebsocketClient) UnSubscribe

func (p *PublicWebsocketClient) UnSubscribe(paramMap map[string]interface{})

type ResponseHandler

type ResponseHandler func(response interface{})

type TokenProducer

type TokenProducer func() string

When called, returns a new websocket token

type WebSocketClientBase

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

func (*WebSocketClientBase) BuildRequestBody

func (wsc *WebSocketClientBase) BuildRequestBody(paramMap map[string]interface{}) (string, error)

func (*WebSocketClientBase) Close

func (wsc *WebSocketClientBase) Close()

func (*WebSocketClientBase) Connect

func (wsc *WebSocketClientBase) Connect(autoConnect bool)

func (*WebSocketClientBase) Init

func (wsc *WebSocketClientBase) Init(host string, tokenProducer TokenProducer, reconnectWaitSecond int64) *WebSocketClientBase

func (*WebSocketClientBase) Send

func (wsc *WebSocketClientBase) Send(data string)

func (*WebSocketClientBase) SetHandler

func (wsc *WebSocketClientBase) SetHandler(connHandler ConnectedHandler, repHandler ResponseHandler)