eventsource

Aug 12, 2026

Changes in this version

+ const MaxServerDirectedRetryDelay

+ var DefaultProfile = &RetryProfile

+ type RetryProfile struct

+ func NewRetryProfile(options ...RetryProfileOption) *RetryProfile

+ type RetryProfileOption interface

+ func RetryProfileBaseDelay(base time.Duration) RetryProfileOption

+ func RetryProfileJitter(ratio float64) RetryProfileOption

+ func RetryProfileMaxDelay(maxDelay time.Duration) RetryProfileOption

type Stream

+ func (stream *Stream) ActivateProfile(profile *RetryProfile)

type StreamErrorHandlerResult

+ ActivateProfile *RetryProfile

type StreamOption

+ func StreamOptionDefaultRetryProfile(profile *RetryProfile) StreamOption

+ func StreamOptionRegisterRetryProfile(profile *RetryProfile) StreamOption

Aug 7, 2026

Changes in this version

+ type CommentSentInfo struct

+ Channel string

+ WriteDuration time.Duration

+ type EventDiscardedInfo struct

+ Channel string

+ Reason EventDiscardedReason

+ type EventDiscardedReason string

+ const DiscardReasonConnectionEnded

+ const DiscardReasonJitterCoalesce

+ type EventSentInfo struct

+ Channel string

+ DataSize int

+ EventType string

+ WriteDuration time.Duration

+ type ReplayFinishedInfo struct

+ Aborted bool

+ Channel string

+ DrainDuration time.Duration

+ EventCount int

+ TotalDataSize int64

+ type ReplayInfo struct

+ Channel string

type Server

+ Trace *ServerTrace

+ type ServerTrace struct

+ CommentSent func(context.Context, CommentSentInfo)

+ EventDiscarded func(context.Context, EventDiscardedInfo)

+ EventSent func(context.Context, EventSentInfo)

+ ReplayFinished func(context.Context, ReplayFinishedInfo)

+ ReplayStarted func(context.Context, ReplayInfo)

+ SubscriberAdded func(context.Context, SubscriberAddedInfo)

+ SubscriberDropped func(SubscriberDroppedInfo)

+ SubscriberRemoved func(context.Context, SubscriberRemovedInfo)

+ WriteError func(context.Context, WriteErrorInfo)

+ type SubscriberAddedInfo struct

+ Channel string

+ HasLastEventID bool

+ SubscriberID uint64

+ type SubscriberDroppedInfo struct

+ BufferSize int

+ Channel string

+ SubscriberID uint64

+ type SubscriberRemovedInfo struct

+ Channel string

+ ConnDuration time.Duration

+ Reason SubscriberRemovedReason

+ SubscriberID uint64

+ type SubscriberRemovedReason string

+ const ReasonBufferOverflow

+ const ReasonClientClosed

+ const ReasonMaxConnTime

+ const ReasonServerClosed

+ const ReasonUnregistered

+ const ReasonWriteError

+ type WriteErrorInfo struct

+ Channel string

+ Err error

Jul 29, 2026

Changes in this version

+ type RepositoryWithContext interface

+ ReplayWithContext func(ctx context.Context, channel, id string) <-chan Event

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