client

type BayeuxHandler ¶

type BayeuxHandler interface {
	HandleMessage(message []byte) error
	ReaderDisconnect()
}

A BayeuxHandler is responsible for parsing bayeux messages

type Client ¶

type Client struct {
	Host        string
	MessageChan chan Message // Messages recv'd by the client will be sent to this message channel
	// contains filtered or unexported fields
}

A Client is a connection and a set of subscriptions TODO: remap MessageChan to a set of subscription message channels one per active subscription

func NewClient(host string) *Client

func (f *Client) Disconnect()

func (f *Client) HandleMessage(message []byte) error

func (f *Client) Publish(channel string, data map[string]interface{}) error

func (f *Client) ReaderDisconnect()

func (f *Client) SetKeepAliveIntervalSeconds(secs int)

func (f *Client) Start(ready chan bool) error

func (f *Client) Subscribe(channel string) error

func (f *Client) Unsubscribe(channel string) error

func (f *Client) Write(msg string) error

type Connection ¶

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

A Connection is a websocket connnection and state

func NewConnection(ws *websocket.Conn) *Connection

func (c *Connection) Connected() bool

type Message ¶

type Message struct {
	Channel string
	Data    map[string]interface{}
	Ext     map[string]interface{}
}

A Message is a piece of data sent to a channel from the bayeux server

type Subscription ¶

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

A Subscription is represents a subscription to a channel by the client Each sub has...

• a messageChan which is recieve any messages sent to it