wsclient

Documentation

Index

• type WebSocketClient
  • func NewWebSocketClient(conf *WebSocketConfig) *WebSocketClient
  • func (wsc *WebSocketClient) Init() error
  • func (wsc *WebSocketClient) Notify(authInfo map[string]string)
  • func (wsc *WebSocketClient) Receive() (model.Message, error)
  • func (wsc *WebSocketClient) Send(message model.Message) error
  • func (wsc *WebSocketClient) UnInit()
• type WebSocketConfig

Types

type WebSocketClient

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

WebSocketClient a websocket client

func NewWebSocketClient

func NewWebSocketClient(conf *WebSocketConfig) *WebSocketClient

NewWebSocketClient initializes a new websocket client instance

func (*WebSocketClient) Init

func (wsc *WebSocketClient) Init() error

Init initializes websocket client

func (*WebSocketClient) Notify

func (wsc *WebSocketClient) Notify(authInfo map[string]string)

Notify logs info

func (*WebSocketClient) Receive

func (wsc *WebSocketClient) Receive() (model.Message, error)

Receive reads the binary message through the connection

func (*WebSocketClient) Send

func (wsc *WebSocketClient) Send(message model.Message) error

Send sends the message as JSON object through the connection

func (*WebSocketClient) UnInit

func (wsc *WebSocketClient) UnInit()

UnInit closes the websocket connection

type WebSocketConfig

type WebSocketConfig struct {
	URL              string
	CertFilePath     string
	KeyFilePath      string
	HandshakeTimeout time.Duration
	ReadDeadline     time.Duration
	WriteDeadline    time.Duration
	NodeID           string
	ProjectID        string
}

WebSocketConfig config for websocket