ws

Jul 25, 2026

Changes in this version

type Metrics

+ WSHandshakeRejected func(reason string)

Jul 24, 2026

Changes in this version

type Handler

+ func (h *Handler) SetMetrics(m Metrics)

type Hub

+ func (h *Hub) SetMetrics(m Metrics)

+ type Metrics interface

+ SetWSActive func(n int)

+ WSConnected func()

+ WSDisconnected func(reason string)

+ WSDrained func(count int)

+ WSSendFailure func()

Jul 21, 2026

Changes in this version

+ const ReasonPingTimeout

+ const ReasonReplaced

+ const ReasonShuttingDown

+ const StatusReplaced

+ func BuildNotification(msg *identity.Message) []byte

+ func NotificationForMessage(ctx context.Context, store HandlerStore, msg *identity.Message) []byte

+ type Handler struct

+ func NewHandler(hub *Hub, store HandlerStore) *Handler

+ func (h *Handler) ServeWithEmail(w http.ResponseWriter, r *http.Request, rawEmail string)

+ type HandlerStore interface

+ GetAgentByEmail func(ctx context.Context, email string) (*identity.AgentIdentity, error)

+ GetMessagesByAgent func(ctx context.Context, f identity.MessageListFilter) ([]identity.Message, error)

+ GetPrincipalByAPIKey func(ctx context.Context, apiKey string) (*identity.Principal, error)

+ type Hub struct

+ func NewHub() *Hub

+ func (h *Hub) Close()

+ func (h *Hub) IsConnected(agentID string) bool

+ func (h *Hub) Register(agentID string, conn *websocket.Conn) (old *websocket.Conn)

+ func (h *Hub) Send(agentID string, msg []byte) bool

+ func (h *Hub) Unregister(agentID string, conn *websocket.Conn)