Versions in this module Expand all Collapse all v0 v0.1.0 Jan 20, 2026 Changes in this version + var ErrConnectionClosed = errors.New("connection closed") + type Connection interface + Close func() error + Read func(context.Context) (jsonrpc.Message, error) + SessionID func() string + Write func(context.Context, jsonrpc.Message) error + type MCPHandler struct + PendingSessions map[string]bool + ServerConn *moqtServerConn + SessionID string + SessionIDGenerator func() string + Transport *MOQTServerTransport + func (h *MCPHandler) Handle(rw moqtransport.ResponseWriter, msg *moqtransport.Message) + type MCPSubscribeHandler struct + Transport *MOQTServerTransport + func (h *MCPSubscribeHandler) HandleSubscribe(rw *moqtransport.SubscribeResponseWriter, msg *moqtransport.SubscribeMessage) + type MOQTClientTransport struct + ControlTrackNamespace []string + Namespace []string + Session *moqtransport.Session + SessionID string + func NewMOQTClientTransport(session *moqtransport.Session) *MOQTClientTransport + func (t *MOQTClientTransport) Connect(ctx context.Context) (Connection, error) + type MOQTServerTransport struct + ControlTrackNamespace []string + Namespace []string + Session *moqtransport.Session + SessionConnections map[string]*moqtServerConn + SessionID string + func NewMOQTServerTransport(session *moqtransport.Session) *MOQTServerTransport + func (t *MOQTServerTransport) Connect(ctx context.Context) (Connection, error) + type MOQTTransport struct + ControlTrackNamespace []string + Namespace []string + Session *moqtransport.Session + SessionID string + func (t *MOQTTransport) Connect(ctx context.Context) (Connection, error) + type Transport interface + Connect func(ctx context.Context) (Connection, error)
Go to main page