sse

Documentation

Index

• func HandleSSE(ctx context.Context, e *_event.Events, w http.ResponseWriter, l *log.Entry, ...)
• func WriteEvent(w io.Writer, e *_event.Event) error
• type SSEReader
  • func NewSSEReader(r io.Reader) *SSEReader
  • func (s *SSEReader) Read() (*_event.Event, error)

Functions

func HandleSSE

func HandleSSE(ctx context.Context, e *_event.Events, w http.ResponseWriter, l *log.Entry, lei int)

func WriteEvent

func WriteEvent(w io.Writer, e *_event.Event) error

Types

type SSEReader

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

func NewSSEReader

func NewSSEReader(r io.Reader) *SSEReader

func (*SSEReader) Read

func (s *SSEReader) Read() (*_event.Event, error)