sse

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

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

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

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

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

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