eventstream

Documentation

Index

• func Render(dst io.Writer, src eventstream.EventStream, options RenderOptions) int
• func RenderStream(eventSource *sse.EventSource) (int, error)
• type RenderOptions
• type TimestampedWriter
  • func NewTimestampedWriter(writer io.Writer, showTime bool) *TimestampedWriter
  • func (w *TimestampedWriter) SetTimestamp(time int64)
  • func (w *TimestampedWriter) Write(b []byte) (int, error)

Functions

func Render

func Render(dst io.Writer, src eventstream.EventStream, options RenderOptions) int

func RenderStream

func RenderStream(eventSource *sse.EventSource) (int, error)

Types

type RenderOptions

type RenderOptions struct {
	ShowTimestamp            bool
	IgnoreEventParsingErrors bool
}

type TimestampedWriter

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

func NewTimestampedWriter

func NewTimestampedWriter(writer io.Writer, showTime bool) *TimestampedWriter

func (*TimestampedWriter) SetTimestamp

func (w *TimestampedWriter) SetTimestamp(time int64)

func (*TimestampedWriter) Write

func (w *TimestampedWriter) Write(b []byte) (int, error)