sse

Documentation

Overview

Package sse provides shared server-sent event decoding helpers.

Index

• Constants
• Variables
• func Decode(ctx context.Context, body io.ReadCloser, handler Handler) error
• func ScrubMemoryContextBytes(raw []byte) []byte
• func ScrubMemoryContextString(value string) string
• type Event
• type Handler

Constants

const MemoryContextRedaction = "[memory-context redacted]"

MemoryContextRedaction is emitted when prompt-only memory fences are removed.

Variables

var ErrStop = errors.New("sse: stop stream")

ErrStop stops SSE decoding without surfacing an error.

Functions

func Decode

func Decode(ctx context.Context, body io.ReadCloser, handler Handler) error

Decode reads one SSE stream from body until EOF, context cancellation, or a handler error. Decode closes body only when ctx is canceled so a blocked Read can unblock and observe the cancellation.

func ScrubMemoryContextBytes

func ScrubMemoryContextBytes(raw []byte) []byte

ScrubMemoryContextBytes removes prompt-only memory fences from raw SSE bytes.

func ScrubMemoryContextString

func ScrubMemoryContextString(value string) string

ScrubMemoryContextString removes literal and JSON-escaped memory context fences.

Types

type Event

type Event struct {
	ID    string
	Event string
	Data  json.RawMessage
}

Event is one parsed server-sent event frame.

type Handler

type Handler func(Event) error

Handler consumes parsed SSE frames.