streamable

package

v0.6.0 Latest Latest Go to latest Published: Nov 10, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Package streamable provides a streamable HTTP proxy for MCP servers.

View Source

const (
	// StreamableHTTPEndpoint is the endpoint for streamable HTTP.
	StreamableHTTPEndpoint = "/mcp"
)

This section is empty.

This section is empty.

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

HTTPProxy implements a proxy for streamable HTTP transport.

func NewHTTPProxy(
	host string,
	port int,
	prometheusHandler http.Handler,
	middlewares ...types.NamedMiddleware,
) *HTTPProxy

NewHTTPProxy creates a new HTTPProxy for streamable HTTP transport.

func (p *HTTPProxy) ForwardResponseToClients(_ context.Context, msg jsonrpc2.Message) error

ForwardResponseToClients forwards a response from the container to the client.

func (p *HTTPProxy) GetMessageChannel() chan jsonrpc2.Message

GetMessageChannel returns the message channel for sending JSON-RPC to the container.

func (p *HTTPProxy) GetResponseChannel() <-chan jsonrpc2.Message

GetResponseChannel returns the response channel for receiving JSON-RPC from the container.

func (p *HTTPProxy) SendMessageToDestination(msg jsonrpc2.Message) error

SendMessageToDestination sends a message to the container.

func (p *HTTPProxy) SendResponseMessage(msg jsonrpc2.Message) error

SendResponseMessage is for compatibility with the Proxy interface.

func (p *HTTPProxy) Start(_ context.Context) error

Start starts the HTTPProxy server.

func (p *HTTPProxy) Stop(ctx context.Context) error

Stop gracefully shuts down the HTTPProxy server.