sse

Documentation

Index

• type Hub
  • func NewHub(events provider.EventProvider, logger *slog.Logger) *Hub
  • func (h *Hub) ActiveConnections() int
  • func (h *Hub) Close() error
  • func (h *Hub) Register(ctx context.Context, topics ...provider.Topic) (<-chan provider.Event, error)

Types

type Hub

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

func NewHub

func NewHub(events provider.EventProvider, logger *slog.Logger) *Hub

func (*Hub) ActiveConnections

func (h *Hub) ActiveConnections() int

func (*Hub) Close

func (h *Hub) Close() error

func (*Hub) Register

func (h *Hub) Register(ctx context.Context, topics ...provider.Topic) (<-chan provider.Event, error)