Documentation
¶
Overview ¶
Package streamable provides a streamable HTTP proxy for MCP servers.
Index ¶
- Constants
- type HTTPProxy
- func (p *HTTPProxy) ForwardResponseToClients(_ context.Context, msg jsonrpc2.Message) error
- func (p *HTTPProxy) GetMessageChannel() chan jsonrpc2.Message
- func (p *HTTPProxy) GetResponseChannel() <-chan jsonrpc2.Message
- func (p *HTTPProxy) IsRunning() (bool, error)
- func (p *HTTPProxy) SendMessageToDestination(msg jsonrpc2.Message) error
- func (p *HTTPProxy) SendResponseMessage(msg jsonrpc2.Message) error
- func (p *HTTPProxy) Start(_ context.Context) error
- func (p *HTTPProxy) Stop(ctx context.Context) error
- type Option
Constants ¶
const (
// StreamableHTTPEndpoint is the endpoint for streamable HTTP.
StreamableHTTPEndpoint = "/mcp"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPProxy ¶
type HTTPProxy struct {
// contains filtered or unexported fields
}
HTTPProxy implements a proxy for streamable HTTP transport.
func NewHTTPProxy ¶
func NewHTTPProxy( host string, port int, prometheusHandler http.Handler, middlewares []types.NamedMiddleware, opts ...Option, ) *HTTPProxy
NewHTTPProxy creates a new HTTPProxy for streamable HTTP transport.
func (*HTTPProxy) ForwardResponseToClients ¶
ForwardResponseToClients forwards a response from the container to the client.
func (*HTTPProxy) GetMessageChannel ¶
GetMessageChannel returns the message channel for sending JSON-RPC to the container.
func (*HTTPProxy) GetResponseChannel ¶
GetResponseChannel returns the response channel for receiving JSON-RPC from the container.
func (*HTTPProxy) SendMessageToDestination ¶
SendMessageToDestination sends a message to the container.
func (*HTTPProxy) SendResponseMessage ¶
SendResponseMessage is for compatibility with the Proxy interface.
type Option ¶ added in v0.13.0
type Option func(*HTTPProxy)
Option configures an HTTPProxy.
func WithSessionStorage ¶ added in v0.13.0
WithSessionStorage injects a custom storage backend into the session manager. When not provided, the proxy uses in-memory LocalStorage (single-replica default).
func WithSessionTTL ¶ added in v0.28.0
WithSessionTTL overrides the session inactivity timeout used by this proxy. Zero or negative values are ignored so the constructor's default is preserved.
Source Files