sse

Sep 14, 2026

Changes in this version

+ const MaxFrameBytes

+ const MaxOffset

+ const Wire

+ var ErrConfig = errors.New("sse: incoherent configuration")

+ var ErrCursor = errors.New("sse: invalid cursor")

+ var ErrFrameTooLarge = errors.New("sse: frame exceeds MaxFrameBytes")

+ var ErrInvalidUTF8 = errors.New("sse: data is not valid UTF-8")

+ type Cursor struct

+ Epoch string

+ Offset uint64

+ func ParseCursor(s string) (Cursor, error)

+ func (c Cursor) String() string

+ type DigestOption func(*digestConfig)

+ func WithDigestMaxBody(n int64) DigestOption

+ func WithDigestMaxSubjects(n int) DigestOption

+ type Event struct

+ Data []byte

+ Name string

+ Topic string

+ type Held struct

+ Version string

+ type Hello struct

+ Epoch string

+ Floor uint64

+ Head uint64

+ KeepaliveEvent string

+ KeepaliveMS int

+ Resumed bool

+ Verdict Verdict

+ Wire int

+ type Hub struct

+ func MustNew(opts ...Option) *Hub

+ func New(opts ...Option) (*Hub, error)

+ func (h *Hub) ClientCount() int

+ func (h *Hub) DigestHandler(resolve Resolver, opts ...DigestOption) http.Handler

+ func (h *Hub) Position() Position

+ func (h *Hub) Publish(ev Event) (uint64, error)

+ func (h *Hub) QueuedFrames() int

+ func (h *Hub) Serve(w http.ResponseWriter, r *http.Request, opts ...ServeOption)

+ func (h *Hub) SetMaxClients(n int)

+ func (h *Hub) Shutdown(ctx context.Context) error

+ func (h *Hub) Snapshot() []ReplayEvent

+ type Option func(*config) error

+ func WithClientBuffer(n int) Option

+ func WithKeepalive(d time.Duration) Option

+ func WithKeepaliveEvent(name string) Option

+ func WithLogger(l *slog.Logger) Option

+ func WithMaxClients(n int) Option

+ func WithPresence(fn func(PresenceEvent)) Option

+ func WithReconnectDelay(d time.Duration) Option

+ func WithReplay(n int) Option

+ func WithReplayMaxBytes(n int) Option

+ func WithReplayTTL(d time.Duration) Option

+ func WithReplyMaxEvents(n int) Option

+ func WithWriteTimeout(d time.Duration) Option

+ type Position struct

+ Epoch string

+ Floor uint64

+ Head uint64

+ type PresenceCause string

+ const PresenceClosed

+ const PresenceDead

+ const PresenceEvicted

+ const PresenceHookFailed

+ const PresenceShutdown

+ type PresenceEvent struct

+ At time.Time

+ Cause PresenceCause

+ ClientID uint64

+ Epoch string

+ Kind PresenceKind

+ Tag string

+ Topic string

+ Verdict Verdict

+ Write string

+ type PresenceKind string

+ const PresenceConnected

+ const PresenceDisconnected

+ type ReplayEvent struct

+ At time.Time

+ Event Event

+ Offset uint64

+ type Resolver func(ctx context.Context, held []Held) ([]State, error)

+ type ServeOption func(*serveConfig)

+ func OnConnect(fn func(w *Writer, h Hello) error) ServeOption

+ func WithClientTag(tag string) ServeOption

+ func WithTopic(topic string) ServeOption

+ type State struct

+ Status Status

+ Version string

+ type Status string

+ const StatusCurrent

+ const StatusForbidden

+ const StatusGone

+ type Subject struct

+ Kind string

+ Ref string

+ type Verdict string

+ const VerdictCursorInvalid

+ const VerdictEpochChanged

+ const VerdictFresh

+ const VerdictGapAhead

+ const VerdictGapBudget

+ const VerdictGapFloor

+ const VerdictResumed

+ type Writer struct

+ func (sw *Writer) Event(name string, data []byte) error