streaming

Jan 7, 2026

Changes in this version

+ type InMemoryStreamManager struct

+ func NewInMemoryStreamManager(opts ...StreamManagerOption) *InMemoryStreamManager

+ func (m *InMemoryStreamManager) Close()

+ func (m *InMemoryStreamManager) Open(ctx context.Context, streamID string) (StreamInput, error)

+ func (m *InMemoryStreamManager) Subscribe(ctx context.Context, streamID string) (<-chan StreamEvent, func(), error)

+ type StreamEvent struct

+ Chunk json.RawMessage

+ Err error

+ Output json.RawMessage

+ Type StreamEventType

+ type StreamEventType int

+ const StreamEventChunk

+ const StreamEventDone

+ const StreamEventError

+ type StreamInput interface

+ Close func() error

+ Done func(ctx context.Context, output json.RawMessage) error

+ Error func(ctx context.Context, err error) error

+ Write func(ctx context.Context, chunk json.RawMessage) error

+ type StreamManager interface

+ Open func(ctx context.Context, streamID string) (StreamInput, error)

+ Subscribe func(ctx context.Context, streamID string) (<-chan StreamEvent, func(), error)

+ type StreamManagerOption interface

+ func WithTTL(ttl time.Duration) StreamManagerOption