adapters

adapters

import "github.com/agentstation/starmap/internal/server/events/adapters"

Package adapters provides transport-specific implementations of the Subscriber interface.

Index

• type SSESubscriber
  • func NewSSESubscriber(broadcaster *sse.Broadcaster) *SSESubscriber
  • func (s *SSESubscriber) Close() error
  • func (s *SSESubscriber) Send(event events.Event) error
• type WebSocketSubscriber
  • func NewWebSocketSubscriber(hub *ws.Hub) *WebSocketSubscriber
  • func (w *WebSocketSubscriber) Close() error
  • func (w *WebSocketSubscriber) Send(event events.Event) error

type SSESubscriber

SSESubscriber adapts the SSE broadcaster to the Subscriber interface.

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

func NewSSESubscriber

func NewSSESubscriber(broadcaster *sse.Broadcaster) *SSESubscriber

NewSSESubscriber creates a new SSE subscriber.

func (*SSESubscriber) Close

func (s *SSESubscriber) Close() error

Close is a no-op for SSE (broadcaster manages its own lifecycle).

func (*SSESubscriber) Send

func (s *SSESubscriber) Send(event events.Event) error

Send delivers an event to all SSE clients.

type WebSocketSubscriber

WebSocketSubscriber adapts the WebSocket hub to the Subscriber interface.

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

func NewWebSocketSubscriber

func NewWebSocketSubscriber(hub *ws.Hub) *WebSocketSubscriber

NewWebSocketSubscriber creates a new WebSocket subscriber.

func (*WebSocketSubscriber) Close

func (w *WebSocketSubscriber) Close() error

Close is a no-op for WebSocket (hub manages its own lifecycle).

func (*WebSocketSubscriber) Send

func (w *WebSocketSubscriber) Send(event events.Event) error

Send delivers an event to all WebSocket clients.

Generated by gomarkdoc