manager

Documentation

Index

• type Client
  • func NewClient(events []string) Client
  • func (c *Client) ReceivePayload() <-chan event.Payload
  • func (c *Client) SetEvents(events []string)
• type ClientManager
  • func NewClientManager() *ClientManager
  • func (cm *ClientManager) AddClient(client Client)
  • func (cm *ClientManager) DeleteEvents(client *Client)
  • func (cm *ClientManager) RemoveClient(client Client)
  • func (cm *ClientManager) SendHeartBeat()
  • func (cm *ClientManager) SendPayload(payload event.Payload)
• type Clients

Types

type Client

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

func NewClient

func NewClient(events []string) Client

func (*Client) ReceivePayload

func (c *Client) ReceivePayload() <-chan event.Payload

func (*Client) SetEvents

func (c *Client) SetEvents(events []string)

type ClientManager

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

func NewClientManager

func NewClientManager() *ClientManager

func (*ClientManager) AddClient

func (cm *ClientManager) AddClient(client Client)

func (*ClientManager) DeleteEvents

func (cm *ClientManager) DeleteEvents(client *Client)

func (*ClientManager) RemoveClient

func (cm *ClientManager) RemoveClient(client Client)

func (*ClientManager) SendHeartBeat

func (cm *ClientManager) SendHeartBeat()

func (*ClientManager) SendPayload

func (cm *ClientManager) SendPayload(payload event.Payload)

type Clients

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