mcp.servers.models¶

MCP Server-specific models extending base server management framework.

This module provides MCP-specific server configuration and runtime information models that extend the base server management framework from haive-dataflow.

Key Components:

MCPTransport: Enum for MCP transport types (stdio, http, etc.)
MCPServerConfig: MCP-specific server configuration
MCPServerInfo: MCP runtime information with transport details

Classes¶

`MCPServerConfig`	MCP-specific server configuration.
`MCPServerInfo`	MCP-specific server runtime information.
`MCPTransport`	MCP transport mechanism types.

Module Contents¶

class mcp.servers.models.MCPServerConfig¶

Bases: haive.dataflow.server_management.models.BaseServerConfig

MCP-specific server configuration.

Extends BaseServerConfig with MCP-specific fields like transport type, required environment variables, and protocol version.

transport¶: MCP transport mechanism (stdio, http, etc.)

requires_env¶: List of required environment variable names

protocol_version¶: MCP protocol version (default: “1.0”)

capabilities¶: List of server capabilities/features

endpoints¶: Optional endpoints for HTTP/WebSocket transports

Example

>>> config = MCPServerConfig(
...     name="github",
...     command=["npx", "-y", "@modelcontextprotocol/server-github"],
...     description="GitHub repository access",
...     transport=MCPTransport.STDIO,
...     requires_env=["GITHUB_TOKEN"]
... )

classmethod validate_env_vars(v: List[str]) → List[str]¶: Validate environment variable names.

validate_transport_config() → MCPServerConfig¶: Validate transport-specific configuration.

capabilities: List[str] = None¶

endpoints: Dict[str, str] | None = None¶

protocol_version: str = None¶

requires_env: List[str] = None¶

transport: MCPTransport = None¶

class mcp.servers.models.MCPServerInfo¶

Bases: haive.dataflow.server_management.models.BaseServerInfo

MCP-specific server runtime information.

Extends BaseServerInfo with MCP-specific runtime details like transport info, connection status, and protocol negotiation results.

transport¶: Active transport type

transport_info¶: Transport-specific connection details

protocol_version¶: Negotiated protocol version

capabilities_active¶: Currently active capabilities

last_message_time¶: Timestamp of last message exchange

message_count¶: Total messages exchanged

Example

>>> info = MCPServerInfo(
...     pid=12345,
...     status=ServerStatus.RUNNING,
...     transport=MCPTransport.STDIO,
...     transport_info={"pipes": ["stdin", "stdout", "stderr"]}
... )

get_transport_status() → str¶: Get human-readable transport status.

record_message() → None¶: Record a message exchange.

capabilities_active: List[str] = None¶

last_message_time: datetime.datetime | None = None¶

message_count: int = None¶

protocol_version: str | None = None¶

transport: MCPTransport = None¶

transport_info: Dict[str, Any] = None¶

class mcp.servers.models.MCPTransport¶

Bases: str, enum.Enum

MCP transport mechanism types.

Defines the communication transport used by MCP servers.

HTTP = 'http'¶

IPC = 'ipc'¶

STDIO = 'stdio'¶

UNKNOWN = 'unknown'¶

WEBSOCKET = 'websocket'¶