Documentation
¶
Index ¶
Constants ¶
const DefaultMaxMessageSize = 1024 * 1024
DefaultMaxMessageSize is the default maximum size of a single JSON message (1MB).
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageHandler ¶
type MessageHandler = transport.MessageHandler
MessageHandler is an alias for the transport.MessageHandler type.
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader handles reading newline-delimited JSON messages from stdin.
func NewReaderWithMaxSize ¶
NewReaderWithMaxSize creates a new Reader with a custom max message size.
func (*Reader) ReadMessage ¶
ReadMessage reads the next JSON message from the input. Returns io.EOF when there are no more messages.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server implements the stdio transport for MCP. It reads JSON-RPC messages from stdin and writes responses to stdout.
func NewServer ¶
func NewServer(agentCfg config.AgentConfig, sessionMgr *session.Manager) *Server
NewServer creates a new stdio transport server.
func NewServerWithIO ¶
func NewServerWithIO(agentCfg config.AgentConfig, sessionMgr *session.Manager, stdin io.Reader, stdout io.Writer) *Server
NewServerWithIO creates a new stdio transport server with custom I/O streams. This is primarily useful for testing.
func (*Server) SetMessageHandler ¶
func (s *Server) SetMessageHandler(h MessageHandler)
SetMessageHandler sets the callback for processing incoming messages.
Source Files