sse

Jul 16, 2026

Changes in this version

+ type Publisher struct — darwin/amd64, linux/amd64, windows/amd64

+ Server *SSEServer

+ func (p Publisher) Publish(e events.Event)

Jul 12, 2026

Changes in this version

+ var SSEMessageModel = model.Definition

+ type ChannelProvider interface — js/wasm

+ ResolveChannels func(ctx router.Context) (channels []string, err error)

type SSEMessage

+ Id string

+ func (m *SSEMessage) Validate(action byte) error

+ type SSEPublisher interface — js/wasm

+ Publish func(data []byte, channels ...string)

+ PublishEvent func(event string, data []byte, channels ...string)

type SSEServer — darwin/amd64, linux/amd64, windows/amd64

+ func (s *SSEServer) StreamHandler() router.StreamFunc

+ type ServerConfig struct — js/wasm

+ ChannelProvider ChannelProvider

+ ClientChannelBuffer int

+ HistoryReplayBuffer int

+ ReplayAllOnConnect bool

Jul 6, 2026

Changes in this version

type SSEMessage

+ func (m *SSEMessage) DecodeFields(r model.FieldReader)

+ func (m *SSEMessage) EncodeFields(w model.FieldWriter)

+ func (m *SSEMessage) IsNil() bool

+ func (m *SSEMessage) ModelName() string

+ func (m *SSEMessage) Pointers() []any

+ func (m *SSEMessage) Schema() []model.Field

+ type SSEMessageList []*SSEMessage

+ func (s *SSEMessageList) Append() model.Fielder

+ func (s *SSEMessageList) At(i int) model.Fielder

+ func (s *SSEMessageList) DecodeFields(_ model.FieldReader)

+ func (s *SSEMessageList) EncodeFields(_ model.FieldWriter)

+ func (s *SSEMessageList) IsNil() bool

+ func (s *SSEMessageList) Len() int

+ func (s *SSEMessageList) Pointers() []any

+ func (s *SSEMessageList) Schema() []model.Field

Feb 27, 2026

Changes in this version

type ServerConfig — darwin/amd64, linux/amd64, windows/amd64

+ ReplayAllOnConnect bool

Dec 11, 2025

Changes in this version

+ func New(c *Config) *tinySSE

+ type ChannelProvider interface — darwin/amd64, linux/amd64, windows/amd64

+ ResolveChannels func(r *http.Request) (channels []string, err error)

+ type ClientConfig struct — js/wasm

+ Endpoint string

+ MaxReconnectAttempts int

+ MaxRetryDelay int

+ RetryInterval int

+ type Config struct

+ Log func(args ...any)

+ type SSEClient struct — js/wasm

+ func (c *SSEClient) Close()

+ func (c *SSEClient) Connect()

+ func (c *SSEClient) OnError(handler func(err error))

+ func (c *SSEClient) OnMessage(handler func(msg *SSEMessage))

+ type SSEMessage struct

+ Data []byte

+ Event string

+ ID string

+ type SSEPublisher interface — darwin/amd64, linux/amd64, windows/amd64

+ Publish func(data []byte, channels ...string)

+ PublishEvent func(event string, data []byte, channels ...string)

+ type SSEServer struct — darwin/amd64, linux/amd64, windows/amd64

+ func (s *SSEServer) Publish(data []byte, channels ...string)

+ func (s *SSEServer) PublishEvent(event string, data []byte, channels ...string)

+ func (s *SSEServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type ServerConfig struct — darwin/amd64, linux/amd64, windows/amd64

+ ChannelProvider ChannelProvider

+ ClientChannelBuffer int

+ HistoryReplayBuffer int