scclient

Documentation

Index

• type Client
  • func New(url string) Client
  • func (client *Client) Connect()
  • func (client *Client) Emit(eventName string, data interface{})
  • func (client *Client) EmitAck(eventName string, data interface{}, ...)
  • func (client *Client) On(eventName string, ack func(eventName string, data interface{}))
  • func (client *Client) OnAck(eventName string, ack func(eventName string, data interface{}, ...))
  • func (client *Client) OnChannel(eventName string, ack func(eventName string, data interface{}))
  • func (client *Client) Publish(channelName string, data interface{})
  • func (client *Client) PublishAck(channelName string, data interface{}, ...)
  • func (client *Client) SetAuthenticationListener(onSetAuthentication func(client Client, token string), ...)
  • func (client *Client) SetBasicListener(onConnect func(client Client), onConnectError func(client Client, err error), ...)
  • func (client *Client) Subscribe(channelName string)
  • func (client *Client) SubscribeAck(channelName string, ...)
  • func (client *Client) Unsubscribe(channelName string)
  • func (client *Client) UnsubscribeAck(channelName string, ...)
• type Listener
  • func Init() Listener

Types

type Client

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

func New

func New(url string) Client

func (*Client) Connect

func (client *Client) Connect()

func (*Client) Emit

func (client *Client) Emit(eventName string, data interface{})

func (*Client) EmitAck

func (client *Client) EmitAck(eventName string, data interface{}, ack func(eventName string, error interface{}, data interface{}))

func (*Client) On

func (client *Client) On(eventName string, ack func(eventName string, data interface{}))

func (*Client) OnAck

func (client *Client) OnAck(eventName string, ack func(eventName string, data interface{}, ack func(error interface{}, data interface{})))

func (*Client) OnChannel

func (client *Client) OnChannel(eventName string, ack func(eventName string, data interface{}))

func (*Client) Publish

func (client *Client) Publish(channelName string, data interface{})

func (*Client) PublishAck

func (client *Client) PublishAck(channelName string, data interface{}, ack func(eventName string, error interface{}, data interface{}))

func (*Client) SetAuthenticationListener

func (client *Client) SetAuthenticationListener(onSetAuthentication func(client Client, token string), onAuthentication func(client Client, isAuthenticated bool))

func (*Client) SetBasicListener

func (client *Client) SetBasicListener(onConnect func(client Client), onConnectError func(client Client, err error), onDisconnect func(client Client, err error))

func (*Client) Subscribe

func (client *Client) Subscribe(channelName string)

func (*Client) SubscribeAck

func (client *Client) SubscribeAck(channelName string, ack func(eventName string, error interface{}, data interface{}))

func (*Client) Unsubscribe

func (client *Client) Unsubscribe(channelName string)

func (*Client) UnsubscribeAck

func (client *Client) UnsubscribeAck(channelName string, ack func(eventName string, error interface{}, data interface{}))

type Listener

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

func Init

func Init() Listener