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-ContainerPipeline {
    [CmdletBinding()]
    param(
        [Parameter(Mandatory=$true)]
        [string]$ImageName,
        [string]$DockerfilePath = './Dockerfile'
    )

    $report = [PSCustomObject]@{
        Timestamp = Get-Date -Format 'yyyy-MM-dd HH:mm:ss'
        BuildLog = @()
        DeploymentStatus = @()
    }

    # 构建Docker镜像
    $buildOutput = docker build -t $ImageName -f $DockerfilePath . 2>&1
    $report.BuildLog += $buildOutput

    # 推送镜像到仓库
    if ($LASTEXITCODE -eq 0) {
        $pushOutput = docker push $ImageName 2>&1
        $report.BuildLog += $pushOutput
    }

    # 部署到Kubernetes
    if ($LASTEXITCODE -eq 0) {
        $k8sOutput = kubectl apply -f deployment.yaml 2>&1
        $report.DeploymentStatus += [PSCustomObject]@{
            Cluster = (kubectl config current-context)
            Status = if($LASTEXITCODE -eq 0){'Success'}else{'Failed'}
            Output = $k8sOutput
        }
    }

    # 生成HTML报告
    $htmlReport = $report | ConvertTo-Html -Fragment
    $htmlReport | Out-File "$env:TEMP/ContainerReport_$(Get-Date -Format yyyyMMdd).html"
    return $report
}

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 "部署失败：$_"
    }
}