sse

Documentation

Index

• func SubscribeHandler(br *Broker, validator Validator, processor Processor) http.Handler
• type Broker
  • func NewBroker() *Broker
  • func (br *Broker) Start()
• type Connection
  • func NewConnection(response http.ResponseWriter, request *http.Request, namespace string) *Connection
  • func (conn *Connection) BroadcastMessage(receive <-chan int)
• type Processor
• type SSE
  • func NewSSE() *SSE
• type SSEMessage
• type Validator

Functions

func SubscribeHandler

func SubscribeHandler(br *Broker, validator Validator, processor Processor) http.Handler

Types

type Broker

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

func NewBroker

func NewBroker() *Broker

func (*Broker) Start

func (br *Broker) Start()

type Connection

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

func NewConnection

func NewConnection(response http.ResponseWriter, request *http.Request, namespace string) *Connection

func (*Connection) BroadcastMessage

func (conn *Connection) BroadcastMessage(receive <-chan int)

type Processor

type Processor func(r *http.Request, receive <-chan int, send chan<- int)

type SSE

type SSE struct {
	Broker          *Broker
	OutboundChannel chan<- SSEMessage
}

func NewSSE

func NewSSE() *SSE

type SSEMessage

type SSEMessage struct {
	Event     string
	Data      []byte
	Namespace string
}

type Validator

type Validator func(r *http.Request) (string, error)