sse

package

v0.7.39 Latest Latest Go to latest Published: Jun 14, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Package sse implements Server-Sent Events (SSE) transport for MCP, enabling real-time, bidirectional communication for agentic flows over HTTP.

This section is empty.

This section is empty.

This section is empty.

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

SSEServerTransport implements a server-side SSE transport

func NewSSEServerTransport(endpoint string, w http.ResponseWriter) (*SSEServerTransport, error)

NewSSEServerTransport creates a new SSE server transport

func (s *SSEServerTransport) Close() error

Close closes the SSE connection

func (s *SSEServerTransport) HandlePostMessage(r *http.Request) error

HandlePostMessage processes an incoming POST request containing a JSON-RPC message

func (s *SSEServerTransport) Send(msg *transport.BaseJsonRpcMessage) error

Send sends a message over the SSE connection

func (s *SSEServerTransport) SessionID() string

SessionID returns the unique session identifier for this transport

func (s *SSEServerTransport) SetCloseHandler(handler func())

SetCloseHandler sets the callback for when the connection is closed

func (s *SSEServerTransport) SetErrorHandler(handler func(error))

SetErrorHandler sets the callback for when an error occurs

func (s *SSEServerTransport) SetMessageHandler(handler func(*transport.BaseJsonRpcMessage))

SetMessageHandler sets the callback for when a message is received

func (s *SSEServerTransport) Start(ctx context.Context) error

Start initializes the SSE connection

Path	Synopsis
internal
sse Package sse provides the low-level implementation of Server-Sent Events (SSE) transport for MCP, handling connection management, message streaming, and protocol details.	Package sse provides the low-level implementation of Server-Sent Events (SSE) transport for MCP, handling connection management, message streaming, and protocol details.