sse

Documentation

Index

• func Reader(body io.ReadCloser, ch MessageChan) error
• func WriteMessages(w http.ResponseWriter, messageChan chan Message) error
• type Broker
  • func NewBroker() (broker *Broker)
  • func (broker *Broker) CloseClient(ch MessageChan)
• type Message
• type MessageChan
  • func StartConnection(broker *Broker) (MessageChan, error)

Functions

func Reader

func Reader(body io.ReadCloser, ch MessageChan) error

Reader returns a channel that contains parsed SSE messages.

func WriteMessages

func WriteMessages(w http.ResponseWriter, messageChan chan Message) error

WriteMessages writes SSE formatted messages to the writer

Types

type Broker

type Broker struct {
	// Events are pushed to this channel by the main UDP daemon
	Notifier chan Message
	// contains filtered or unexported fields
}

Broker holds open client connections, listens for incoming events on its Notifier channel and broadcast event data to all registered connections

func NewBroker

func NewBroker() (broker *Broker)

NewBroker creates a Broker.

func (*Broker) CloseClient

func (broker *Broker) CloseClient(ch MessageChan)

CloseClient closes the client channel

type Message

type Message struct {
	Event  string
	Data   string
	Object interface{}
}

Message is a message.

type MessageChan

type MessageChan chan Message

A MessageChan is a channel of channels Each connection sends a channel of bytes to a global MessageChan The main broker listen() loop listens on new connections on MessageChan New event messages are broadcast to all registered connection channels

func StartConnection

func StartConnection(broker *Broker) (MessageChan, error)

StartConnection starts a SSE connection, based on an existing HTTP connection.