sse

package

v0.26.0 Latest Latest Go to latest Published: Oct 11, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var ErrMaximumRetries = errors.New("Exceeded maximum retries")

This section is empty.

type Backoff interface {
	NextDelay(retries int) time.Duration
}

Backoff is a copy of replicate.Backoff to avoid import cycles

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

func NewDecoder(r io.Reader) *Decoder

func (d *Decoder) Next() (Event, error)

type Event struct {
	Type string
	ID   string
	Data string
}

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

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)