Struct Reconciler 

pub struct Reconciler { /* private fields */ }

SzRustApp Reconciler — 实现 reconcile 逻辑

用法

use sz_rust_operator::controller::Reconciler;
use kube::Client;

let client = Client::try_default().await.unwrap();
let reconciler = Reconciler::new(client);

let result = reconciler.reconcile(&sz_rust_app).await.unwrap();

Implementations

impl Reconciler

pub fn new(client: Client) -> Self

创建 Reconciler（连接 K8s 集群）

pub fn new_mock() -> Self

创建 Reconciler（无 K8s 连接，用于测试）

pub async fn reconcile( &self, app: &Arc<SzRustApp>, ) -> Result<ReconcileResult, ControllerError>

Reconcile 一个 SzRustApp 资源

根据资源状态执行对应操作：

• 资源存在且 Deployment 不存在 → 创建
• 资源存在且 Deployment 存在但 spec 不匹配 → 更新
• 资源存在且 Deployment 存在且 spec 匹配 → 无操作
• 资源被删除 → 清理

pub async fn update_status( &self, app: &Arc<SzRustApp>, status: SzRustAppStatus, ) -> Result<(), ControllerError>

更新 SzRustApp status

pub async fn stats(&self) -> ReconcilerStats

获取统计信息