hot

Documentation

Index

• type Event
  • func (e *Event) Format() *bytes.Buffer
• type Server
  • func New(ps pubsub.Subscriber) *Server
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

Types

type Event

type Event struct {
	ID    string // id (optional)
	Type  string // event type (optional)
	Data  []byte // data
	Retry int    // retry (optional)
}

https://html.spec.whatwg.org/multipage/server-sent-events.html#event-stream-interpretation

func (*Event) Format

func (e *Event) Format() *bytes.Buffer

type Server

type Server struct {
	Now func() time.Time // Used for testing
	// contains filtered or unexported fields
}

func New

func New(ps pubsub.Subscriber) *Server

New server-sent event (SSE) server

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)