sse

package

v0.4.1 Latest Latest Go to latest Published: Apr 16, 2026 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var ErrClientGone = errors.New("sse: client disconnected")

func Handler(heartbeatInterval time.Duration, fn StreamFunc) http.HandlerFunc

func ResumeFrom(r *http.Request) int64

func Write[T any](sw *Writer, event Event[T]) error

Write emits a typed SSE event and assigns its sequence ID centrally.

type Event[T any] = tailkit.Event[T]

Event is the shared typed SSE event envelope.

type StreamFunc func(ctx context.Context, sw *Writer) error

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

Writer emits server-sent events on a single HTTP response stream.

func NewWriter(w http.ResponseWriter, r *http.Request) (*Writer, error)

func (sw *Writer) Error(msg string)

func (sw *Writer) Heartbeat() error

func (sw *Writer) Send(name string, data any) error

func (sw *Writer) SetSequence(seq int64)