sse

Aug 22, 2023

Changes in this version

type Stats

+ func (s Stats) Empty() bool

Aug 7, 2023

Changes in this version

type EventServer

+ func (e *EventServer) Stats() Stats

+ type Stats struct

+ ByTopic map[string]TopicStats

+ Topics int

+ type SubscriberStats struct

+ Capacity int

+ Pending int

+ type TopicStats struct

+ BySubscriber map[string]SubscriberStats

+ Capacity int

+ Pending int

+ Subscribers int

type Topics

+ func (t *Topics) Stats() Stats

Aug 3, 2023

Changes in this version

+ type Event interface

+ Data func() []byte

+ Type func() string

+ func JSONEvent(kind string, data any) (Event, error)

+ func NewEvent(kind string, data []byte) Event

+ type EventServer struct

+ func NewEventServer() *EventServer

+ func (e *EventServer) Broadcast(name string, event Event) error

+ func (e *EventServer) Create(name string)

+ func (e *EventServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Subscriber struct

+ func NewSubscriber() Subscriber

+ func (s Subscriber) Close()

+ func (s Subscriber) Push(event Event) error

+ func (s Subscriber) WriteEvents(w http.ResponseWriter) error

+ type Topic struct

+ func NewTopic(backlog int) *Topic

+ func (t *Topic) Broadcast(event Event) error

+ func (t *Topic) Subscribe(sub Subscriber)

+ func (t *Topic) Unsubscribe(ctx context.Context, sub Subscriber)

+ type Topics struct

+ func NewTopics() *Topics

+ func (t *Topics) Create(name string) *Topic