hot

Documentation

Index

• type Event
  • func (e *Event) Format() *bytes.Buffer
• type Server
  • func New(log log.Interface, ps pubsub.Subscriber) *Server
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Stream
  • func Dial(log log.Interface, url string) (*Stream, error)
  • func DialWith(client *http.Client, log log.Interface, url string) (*Stream, error)
  • func (s *Stream) Close() error
  • func (s *Stream) Next(ctx context.Context) (*Event, error)

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(log log.Interface, ps pubsub.Subscriber) *Server

New server-sent event (SSE) server

func (*Server) ServeHTTP

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

type Stream

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

func Dial

func Dial(log log.Interface, url string) (*Stream, error)

Dial creates a server-sent event (SSE) stream. This stream has been adapted from the following minimal eventsource stream: - https://github.com/neelance/eventsource/blob/master/client/client.go Thanks Richard!

func DialWith

func DialWith(client *http.Client, log log.Interface, url string) (*Stream, error)

DialWith creates a server-sent event (SSE) stream with a custom HTTP client.

func (*Stream) Close

func (s *Stream) Close() error

func (*Stream) Next

func (s *Stream) Next(ctx context.Context) (*Event, error)