client

Documentation

Index

• type Client
  • func Connect(wsurl string, callback func(*msg.Message), authMsg *msg.AuthReq, ...) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) Publish(message *msg.Message) bool
  • func (c *Client) Run()

Types

type Client

type Client struct {
	URL *url.URL

	CallbackFunc func(*msg.Message)
	// contains filtered or unexported fields
}

Client websocket client

func Connect

func Connect(wsurl string, callback func(*msg.Message), authMsg *msg.AuthReq, topics []string, receiverBufferSize, pingWait, readWait, writeWait int) (*Client, error)

Connect create a new websocket client and connect to server

func (*Client) Close

func (c *Client) Close()

Close client

func (*Client) Publish

func (c *Client) Publish(message *msg.Message) bool

Publish one message

func (*Client) Run

func (c *Client) Run()

Run client