function Invoke-K8sNodeOrchestration {
    [CmdletBinding()]
    param(
        [ValidateSet('ScaleUp','ScaleDown','Maintenance')]
        [string]$Operation,
        [int]$NodeCount = 1
    )

    $nodePool = Get-AzAksNodePool -ClusterName 'prod-cluster'
    $metrics = Invoke-RestMethod -Uri 'http://k8s-metrics:8080/api/v1/nodes'

    switch ($Operation) {
        'ScaleUp' {
            $newCount = $nodePool.Count + $NodeCount
            Update-AzAksNodePool -Name $nodePool.Name -Count $newCount
            Write-Host "节点池已扩容至$newCount个节点"
        }
        'ScaleDown' {
            $nodesToRemove = $metrics.Nodes | 
                Where-Object { $_.CpuUsage -lt 20 } | 
                Select-Object -First $NodeCount
            $nodesToRemove | ForEach-Object {
                Set-AzAksNode -Name $_.Name -State Draining
            }
        }
        'Maintenance' {
            $metrics.Nodes | Where-Object { $_.HealthStatus -ne 'Healthy' } |
                ForEach-Object {
                    Add-K8sNodeLabel -Node $_.Name -Label @{
                        'maintenance' = (Get-Date).ToString('yyyyMMdd')
                    }
                }
        }
    }
}

function Invoke-K8sDeployment {
    param(
        [ValidateSet('AzureAKS','AWS-EKS')]
        [string]$ClusterType,
        [string]$Namespace,
        [string]$DeploymentFile
    )

    try {
        # 认证集群
        $kubeconfig = switch ($ClusterType) {
            'AzureAKS' { Get-AzAksCredential -Admin }
            'AWS-EKS' { Get-EksClusterCredential }
        }

        # 执行部署
        kubectl apply -f $DeploymentFile --namespace $Namespace --kubeconfig $kubeconfig

        # 实时监控
        $watchJob = Start-Job -ScriptBlock {
            kubectl get pods --namespace $using:Namespace --watch
        }
        Receive-Job $watchJob -Wait
    }
    catch {
        Write-Error "部署失败：$_"
    }
    finally {
        Remove-Job $watchJob -Force
    }
}

# 创建Kubernetes部署模块
function New-KubeCluster {
    param(
        [ValidateSet('minikube','k3s','microk8s')]
        [string]$ClusterType = 'minikube',
        [int]$WorkerNodes = 2
    )

    try {
        # 环境预检
        if (-not (Get-Command docker -ErrorAction SilentlyContinue)) {
            throw "Docker引擎未安装"
        }

        # 根据不同集群类型执行部署
        switch ($ClusterType) {
            'minikube' {
                minikube start --nodes=$WorkerNodes --driver=docker
                minikube addons enable ingress
            }
            'k3s' {
                Invoke-WebRequest -Uri https://get.k3s.io | bash -s -- --worker $WorkerNodes
            }
            'microk8s' {
                snap install microk8s --classic
                microk8s enable dns dashboard ingress
            }
        }

        # 验证集群状态
        $status = kubectl cluster-info
        Write-Host "集群部署完成：$status"
    }
    catch {
        Write-Error "部署失败：$_"
    }
}