eventsource

Nov 20, 2025

Changes in this version

type Server

+ func NewServerWithJitter(jitter time.Duration) *Server

Jul 1, 2025

Changes in this version

type DecoderOption

+ func DecoderOptionHeaders(headers http.Header) DecoderOption

+ type EventWithHeaders interface

+ Headers func() http.Header

Apr 21, 2025

Changes in this version

type SubscriptionError

+ Header http.Header

Dec 19, 2024

Changes in this version

type StreamOption

+ func StreamOptionDynamicQueryParams(f func(existing url.Values) url.Values) StreamOption

Jan 5, 2022

Changes in this version

type DecoderOption

+ func DecoderOptionLastEventID(lastEventID string) DecoderOption

+ type EventWithLastID interface

+ LastEventID func() string

Jul 23, 2020

Changes in this version

type Server

+ func (srv *Server) PublishWithAcknowledgment(channels []string, ev Event) <-chan struct{}

+ func (srv *Server) Unregister(channel string, forceDisconnect bool)

Jul 16, 2020

Changes in this version

type Server

+ MaxConnTime time.Duration

Mar 25, 2020

Changes in this version

+ const DefaultInitialRetry

+ const DefaultRetryResetInterval

+ var ErrReadTimeout = errors.New("Read timeout on stream")

+ type Decoder struct

+ func NewDecoder(r io.Reader) *Decoder

+ func NewDecoderWithOptions(r io.Reader, options ...DecoderOption) *Decoder

+ func (dec *Decoder) Decode() (Event, error)

+ type DecoderOption interface

+ func DecoderOptionReadTimeout(timeout time.Duration) DecoderOption

+ type Encoder struct

+ func NewEncoder(w io.Writer, compressed bool) *Encoder

+ func (enc *Encoder) Encode(ec eventOrComment) error

+ type Event interface

+ Data func() string

+ Event func() string

+ Id func() string

+ type Logger interface

+ Printf func(string, ...interface{})

+ Println func(...interface{})

+ type Repository interface

+ Replay func(channel, id string) chan Event

+ type Server struct

+ AllowCORS bool

+ BufferSize int

+ Gzip bool

+ Logger Logger

+ ReplayAll bool

+ func NewServer() *Server

+ func (srv *Server) Close()

+ func (srv *Server) Handler(channel string) http.HandlerFunc

+ func (srv *Server) Publish(channels []string, ev Event)

+ func (srv *Server) PublishComment(channels []string, text string)

+ func (srv *Server) Register(channel string, repo Repository)

+ type SliceRepository struct

+ func NewSliceRepository() *SliceRepository

+ func (repo *SliceRepository) Add(channel string, event Event)

+ func (repo SliceRepository) Replay(channel, id string) (out chan Event)

+ type Stream struct

+ Errors chan error

+ Events chan Event

+ Logger Logger

+ func Subscribe(url, lastEventID string) (*Stream, error)

+ func SubscribeWith(lastEventID string, client *http.Client, request *http.Request) (*Stream, error)

+ func SubscribeWithRequest(lastEventID string, request *http.Request) (*Stream, error)

+ func SubscribeWithRequestAndOptions(request *http.Request, options ...StreamOption) (*Stream, error)

+ func SubscribeWithURL(url string, options ...StreamOption) (*Stream, error)

+ func (stream *Stream) Close()

+ func (stream *Stream) Restart()

+ func (stream *Stream) SetLogger(logger Logger)

+ type StreamErrorHandler func(error) StreamErrorHandlerResult

+ type StreamErrorHandlerResult struct

+ CloseNow bool

+ type StreamOption interface

+ func StreamOptionCanRetryFirstConnection(initialRetryTimeout time.Duration) StreamOption

+ func StreamOptionErrorHandler(handler StreamErrorHandler) StreamOption

+ func StreamOptionHTTPClient(client *http.Client) StreamOption

+ func StreamOptionInitialRetry(retry time.Duration) StreamOption

+ func StreamOptionLastEventID(lastEventID string) StreamOption

+ func StreamOptionLogger(logger Logger) StreamOption

+ func StreamOptionReadTimeout(timeout time.Duration) StreamOption

+ func StreamOptionRetryResetInterval(retryResetInterval time.Duration) StreamOption

+ func StreamOptionUseBackoff(maxDelay time.Duration) StreamOption

+ func StreamOptionUseJitter(jitterRatio float64) StreamOption

+ type SubscriptionError struct

+ Code int

+ Message string

+ func (e SubscriptionError) Error() string