[DA-1204] Tool to get list of services status of them (#64)

Co-authored-by: Nithish Raghunandanan <12782505+nithishr@users.noreply.github.com>

Author: AayushTyagi1

README.md

@@ -22,6 +22,7 @@ An [MCP](https://modelcontextprotocol.io/) server implementation of Couchbase th
   - There is an option in the MCP server, `CB_MCP_READ_ONLY_QUERY_MODE` that is set to true by default to disable running SQL++ queries that change the data or the underlying collection structure. Note that the documents can still be updated by ID.
 - Get the status of the MCP server
 - Check the cluster credentials by connecting to the cluster
+- Get cluster health status and list of all running services
 
 ## Prerequisites
 

src/tools/__init__.py

@@ -23,6 +23,7 @@
 # Server tools
 from .server import (
     get_buckets_in_cluster,
+    get_cluster_health_and_services,
     get_collections_in_scope,
     get_scopes_and_collections_in_bucket,
     get_scopes_in_bucket,
@@ -44,6 +45,7 @@
     get_schema_for_collection,
     run_sql_plus_plus_query,
     get_index_advisor_recommendations,
+    get_cluster_health_and_services,
 ]
 
 __all__ = [
@@ -60,6 +62,7 @@
     "get_schema_for_collection",
     "run_sql_plus_plus_query",
     "get_index_advisor_recommendations",
+    "get_cluster_health_and_services",
     # Convenience
     "ALL_TOOLS",
 ]

src/tools/server.py

@@ -4,6 +4,7 @@
 This module contains tools for getting the server status, testing the connection, and getting the buckets in the cluster, the scopes and collections in the bucket.
 """
 
+import json
 import logging
 from typing import Any
 
@@ -137,3 +138,43 @@ def get_collections_in_scope(
         ctx, query, bucket_name=bucket_name, scope_name=scope_name
     )
     return [result["collection_name"] for result in results]
+
+
+def get_cluster_health_and_services(
+    ctx: Context, bucket_name: str | None = None
+) -> dict[str, Any]:
+    """Get cluster health status and list of all running services.
+
+    This tool provides health monitoring by:
+    - Getting health status of all running services with latency information (via ping)
+    - Listing all services running on the cluster with their endpoints
+    - Showing connection status and node information for each service
+
+    If bucket_name is provided, it actively pings services from the perspective of the bucket.
+    Otherwise, it uses cluster-level ping to get the health status of the cluster.
+
+    Returns:
+    - Cluster health status with service-level connection details and latency measurements
+    """
+    try:
+        cluster = get_cluster_connection(ctx)
+
+        if bucket_name:
+            # Ping services from the perspective of the bucket
+            bucket = connect_to_bucket(cluster, bucket_name)
+            result = bucket.ping().as_json()
+        else:
+            # Ping services from the perspective of the cluster
+            result = cluster.ping().as_json()
+
+        return {
+            "status": "success",
+            "data": json.loads(result),
+        }
+    except Exception as e:
+        logger.error(f"Error getting cluster health: {e}")
+        return {
+            "status": "error",
+            "error": str(e),
+            "message": "Failed to get cluster health and services information",
+        }