streamable_http

package

v0.0.12 Latest Latest Go to latest Published: Jun 22, 2025 License: MIT Imports: 17 Imported by: 0

Details

View Source

const (
	// SessionCookieName is the name of the cookie used to store the session ID
	SessionCookieName = "mcp_session_id"
)

This section is empty.

This section is empty.

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

StreamClient represents a connected streaming client

type StreamableHTTPHandlers struct {
	StreamHandler  http.HandlerFunc
	MessageHandler http.HandlerFunc
}

StreamableHTTPHandlers contains the HTTP handlers for streamable HTTP endpoints

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

StreamableHTTPTransport implements bidirectional streaming over HTTP using WebSockets

func NewStreamableHTTPTransport(opts ...transport.TransportOption) (*StreamableHTTPTransport, error)

func (s *StreamableHTTPTransport) Close(ctx context.Context) error

func (s *StreamableHTTPTransport) GetHandlers() *StreamableHTTPHandlers

GetHandlers returns the HTTP handlers for streamable HTTP endpoints

func (s *StreamableHTTPTransport) Info() transport.TransportInfo

func (s *StreamableHTTPTransport) Listen(ctx context.Context, handler transport.RequestHandler) error

func (s *StreamableHTTPTransport) RegisterHandlers(r *mux.Router)

RegisterHandlers registers the streamable HTTP handlers with the provided router

func (s *StreamableHTTPTransport) Send(ctx context.Context, response *protocol.Response) error

func (s *StreamableHTTPTransport) SetSessionStore(store session.SessionStore)