sse

Documentation

Index

• func NewSSEHandler(clientManager *ClientManager) http.HandlerFunc
• type Client
  • func NewClient(id uint32) *Client
  • func (c *Client) Close()
  • func (c *Client) SendMessage(message string) (err error)
  • func (c *Client) WriteSSE(w http.ResponseWriter)
• type ClientManager
  • func NewClientManager() *ClientManager
  • func (cm *ClientManager) AddClient(client *Client)
  • func (cm *ClientManager) Close()
  • func (cm *ClientManager) GetClient(id uint32) (*Client, bool)
  • func (cm *ClientManager) RemoveClient(id uint32)

Functions

func NewSSEHandler

func NewSSEHandler(clientManager *ClientManager) http.HandlerFunc

NewSSEHandler handles the SSE connection

Types

type Client

type Client struct {
	ID   uint32
	Send chan []byte
}

Client is a client of the SSE server

func NewClient

func NewClient(id uint32) *Client

NewClient creates a new client

func (*Client) Close

func (c *Client) Close()

Close closes the client

func (*Client) SendMessage

func (c *Client) SendMessage(message string) (err error)

SendMessage sends a message to the client

func (*Client) WriteSSE

func (c *Client) WriteSSE(w http.ResponseWriter)

WriteSSE writes data to the client

type ClientManager

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

ClientManager is a manager of the S

func NewClientManager

func NewClientManager() *ClientManager

NewClientManager creates a new client manager

func (*ClientManager) AddClient

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

AddClient adds a client to the manager

func (*ClientManager) Close

func (cm *ClientManager) Close()

Close closes the client

func (*ClientManager) GetClient

func (cm *ClientManager) GetClient(id uint32) (*Client, bool)

GetClient returns a client by id

func (*ClientManager) RemoveClient

func (cm *ClientManager) RemoveClient(id uint32)

RemoveClient removes a client from the manager