websocket

Documentation

Index

• func KeysString(m map[string]struct{}) string
• type Client
  • func NewClient(endpoint, apiKey, secretKey string, topics []string, handler MessageHandler, ...) *Client
  • func (c *Client) Close()
  • func (c *Client) Connect() error
  • func (c *Client) Connected() bool
  • func (c *Client) Subscribe(topics []string) error
  • func (c *Client) Unsubscribe()
• type MessageHandler

Functions

func KeysString

func KeysString(m map[string]struct{}) string

Types

type Client

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

func NewClient

func NewClient(endpoint, apiKey, secretKey string, topics []string, handler MessageHandler, jsonData bool) *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) Connect

func (c *Client) Connect() error

func (*Client) Connected

func (c *Client) Connected() bool

func (*Client) Subscribe

func (c *Client) Subscribe(topics []string) error

func (*Client) Unsubscribe

func (c *Client) Unsubscribe()

type MessageHandler

type MessageHandler func(message *types.Message)