Versions in this module Expand all Collapse all v0 v0.26.0 Oct 11, 2024 Changes in this version + var ErrMaximumRetries = errors.New("Exceeded maximum retries") + type Backoff interface + NextDelay func(retries int) time.Duration + type Decoder struct + func NewDecoder(r io.Reader) *Decoder + func (d *Decoder) Next() (Event, error) + type Event struct + Data string + ID string + Type string + type Streamer struct + func NewStreamer(c *http.Client, url string, maxRetries int, backoff Backoff) *Streamer + func (s *Streamer) Close() error + func (s *Streamer) NextEvent(ctx context.Context) (*Event, error)
Go to main page