sse

type BadResponseError ¶

type BadResponseError struct {
	Response *http.Response
}

func (err BadResponseError) Error() string

type Config ¶

type Config struct {
	Client         *http.Client
	RetryParams    RetryParams
	RequestCreator func() *http.Request
}

func (c *Config) Connect() (*EventSource, error)

type Event ¶

type Event struct {
	ID    string
	Name  string
	Data  []byte
	Retry time.Duration
}

func (event Event) Encode() string

func (event Event) Write(destination io.Writer) error

type EventSource ¶

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

EventSource behaves like the EventSource interface from the Server-Sent Events spec implemented in many browsers. See http://www.w3.org/TR/eventsource/#the-eventsource-interface for details.

To use, optionally call Connect(), and then call Next(). If Next() is called prior to Connect(), it will connect for you.

Alternatively, create a Config struct instance and call Connect() and then call Next().

Next() is often called asynchronously in a loop so that the event source can be closed. Next() will block on reading from the server.

If Close() is called while reading an event, Next() will return early, and subsequent calls to Next() will return early. To read new events, Connect() must be called.

If an EOF is received, Next() returns io.EOF, and subsequent calls to Next() will return early. To read new events, Connect() must be called.

func Connect(client *http.Client, defaultRetryInterval time.Duration, requestCreator func() *http.Request) (*EventSource, error)

func NewEventSource(client *http.Client, defaultRetryInterval time.Duration, requestCreator func() *http.Request) *EventSource

func (source *EventSource) Close() error

func (source *EventSource) Next() (Event, error)

type ReadCloser ¶

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

func NewReadCloser(source io.ReadCloser) *ReadCloser

func (rc *ReadCloser) Close() error

func (rc *ReadCloser) Next() (Event, error)

type RetryParams ¶

type RetryParams struct {
	RetryInterval time.Duration
	MaxRetries    uint16
}