sse

package

v0.2.21 Latest Latest Go to latest Published: Aug 13, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

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

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

func NewBroker() *Broker

func (br *Broker) Start()

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

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

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

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

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

func NewSSE() *SSE

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

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