Pull request #8: Feature/mcp flexcache k8s

Merge in SIE-BB/netapp-dataops-toolkit from feature/mcp-flexcache-k8s to release-v2.7.0

* commit 'a675aa583879d194078a0f50be4e0714d2fe255f':
  removed extra line
  adding 'create flexcache' to list of tools in mcp_servers.md
  updating docs
  returning str as output for mcp tool
  correction
  updating create_flexcache_volume_tool @K8s mcp server
  addded 'create_flexcache_tool' to mcp server K8s

Author: mboglesby

mcp_servers.md

@@ -41,3 +41,4 @@ This MCP Server provides the following tools for managing JupyterLab workspaces
 - **ListVolumes**: List all volumes.
 - **CreateVolumeSnapshot**: Create a snapshot of a volume.
 - **ListVolumeSnapshots**: List all snapshots of volumes.
+- **CreateFlexCache**: Create a FlexCache volume.

netapp_dataops_k8s/docs/mcp_server_k8s.md

@@ -26,6 +26,7 @@ The MCP server provides the following tools for managing JupyterLab workspaces a
 - **ListVolumes**: List all volumes.
 - **CreateVolumeSnapshot**: Create a snapshot of a volume.
 - **ListVolumeSnapshots**: List all snapshots of volumes.
+- **CreateFlexCache**: Create a new FlexCache volume.
 
 ## Quick Start
 

netapp_dataops_k8s/netapp_dataops/netapp_dataops_k8s_mcp.py

@@ -17,7 +17,8 @@
     clone_volume,
     list_volumes,
     create_volume_snapshot,
-    list_volume_snapshots
+    list_volume_snapshots,
+    create_flexcache
 )
 
 # Creates the FastMCP server instance
@@ -453,6 +454,62 @@ def list_volume_snapshots_tool(
         print(f"Error listing volume snapshots: {e}")
         raise
 
+@mcp.tool(name="CreateFlexCache")
+def create_flexcache_tool(
+    source_vol: str,
+    source_svm: str,
+    flexcache_vol: str,
+    flexcache_size: str,
+    backend_name: str,
+    junction: Optional[str] = None,
+    namespace: str = "default",
+    trident_namespace: str = "trident",
+    print_output: bool = False
+) -> str:
+    """
+    Create a FlexCache volume in ONTAP and a corresponding PersistentVolume (PV) and PersistentVolumeClaim (PVC) in Kubernetes.
+
+    This function creates a FlexCache volume in ONTAP and then creates a PV and PVC representing the FlexCache in a specified Kubernetes namespace.
+
+    Parameters:
+    - source_vol (str): The name of the source volume in the source SVM that will be cached by the FlexCache volume.
+    - source_svm (str): The name of the source Storage Virtual Machine (SVM) that contains the origin volume to be cached.
+    - flexcache_vol (str): The name of the FlexCache volume to be created.
+    - flexcache_size (str): The size of the FlexCache volume to be created. The size must be specified in a format such as '1024Mi', '100Gi', '10Ti', etc. Note: The size must be at least 50Gi.
+    - backend_name (str): The name of the tridentbackendconfig.
+    - junction (str, optional): The junction path for the FlexCache volume. Default is None.
+    - namespace (str, optional): Kubernetes namespace to create the new PersistentVolumeClaim (PVC) in. Default is "default".
+    - trident_namespace (str, optional): Kubernetes namespace where Trident is installed. Default is "trident".
+    - print_output (bool, optional): Whether to print output messages. Default is False.
+
+    Returns:
+    - str: A message indicating the successful creation of the FlexCache volume and the associated PVC.
+
+    Raises:
+    - InvalidConfigError: If the Kubernetes configuration is invalid.
+    - APIConnectionError: If there is an error connecting to the Kubernetes API.
+    - InvalidVolumeParameterError: If the volume parameters are invalid.
+    - NetAppRestError: If there is an error with the NetApp REST API.
+    - ConnectionTypeError: If the connection type is invalid.
+    """
+    try:
+        result = create_flexcache(
+            source_vol=source_vol,
+            source_svm=source_svm,
+            flexcache_vol=flexcache_vol,
+            flexcache_size=flexcache_size,
+            backend_name=backend_name,
+            junction=junction,
+            namespace=namespace,
+            trident_namespace=trident_namespace,
+            print_output=print_output
+        )
+
+        return f"FlexCache volume '{result['ontap_flexcache']}' and PVC '{result['k8s_pvc']}' created successfully."
+    except Exception as e:
+        print(f"Error creating FlexCache volume: {e}")
+        raise
+
 def main():
     try:
         # Sets up basic logging to capture server events and errors