wsclient

Documentation

Index

• type ChannelSub
• type Client
  • func NewClient(addr okapi.BaseURL, argFunc func(map[string]string) string, ...) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) Connect() error
  • func (c *Client) HandleOpRes(res *types.Response) error
  • func (c *Client) Subscribe(cs types.ChannelSub) error

Types

type ChannelSub

type ChannelSub interface {
	GetArg() map[string]string
	ReceiveData([]byte)
}

type Client

type Client struct {
	Addr okapi.BaseURL

	Channels map[string]ChannelSub

	ArgToID func(map[string]string) string
	// contains filtered or unexported fields
}

func NewClient

func NewClient(addr okapi.BaseURL, argFunc func(map[string]string) string, apiKeys ...*rest.APIKey) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) Connect

func (c *Client) Connect() error

func (*Client) HandleOpRes

func (c *Client) HandleOpRes(res *types.Response) error

func (*Client) Subscribe

func (c *Client) Subscribe(cs types.ChannelSub) error