get_deployment_targets
Retrieve available Kubernetes and Connect clusters for deployment in a specified environment to identify where to deploy Kafka data operations.
Instructions
Returns deployment information including available Kubernetes clusters and Connect clusters.
Args: environment: The environment name.
Returns: Dictionary containing available deployment targets (Kubernetes clusters and Connect clusters).
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes |
Implementation Reference
- The handler function for the 'get_deployment_targets' tool. It is decorated with @mcp.tool() for automatic registration and makes an API call to fetch deployment targets.@mcp.tool() async def get_deployment_targets(environment: str) -> Dict[str, Any]: """ Returns deployment information including available Kubernetes clusters and Connect clusters. Args: environment: The environment name. Returns: Dictionary containing available deployment targets (Kubernetes clusters and Connect clusters). """ endpoint = f"/api/v1/environments/{environment}/proxy/api/v1/deployment/targets" return await api_client._make_request("GET", endpoint)
- src/lenses_mcp/server.py:32-32 (registration)Top-level registration call to register_sql_processors(mcp), which includes the registration of the get_deployment_targets tool via its decorator.register_sql_processors(mcp)
- src/lenses_mcp/server.py:16-16 (registration)Import of the register_sql_processors function used to register the tools.from tools.sql_processors import register_sql_processors