Versions in this module Expand all Collapse all v1 v1.0.2 Mar 13, 2026 v1.0.1 Mar 13, 2026 Changes in this version + type SSEBroker struct + func NewSSEBroker() *SSEBroker + func (b *SSEBroker) Broadcast(message []byte) + func (b *SSEBroker) ClientCount() int + func (b *SSEBroker) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (b *SSEBroker) Start(ctx context.Context) + type SSEClient struct + ID string + Messages chan []byte + type Server struct + func NewServer(k8sClient client.Client, namespace string, bindAddress string, ...) *Server + func (s *Server) GetSSEBroker() *SSEBroker + func (s *Server) Start(ctx context.Context) error
Go to main page