Struct K8sManager 

pub struct K8sManager { /* private fields */ }

Kubernetes self-deployment manager.

Implementations

impl K8sManager

pub async fn new() -> Self

Attempt to initialize from in-cluster configuration. Returns a manager even if not running in K8s (with client = None).

pub fn is_available(&self) -> bool

Whether K8s integration is available.

pub async fn status(&self) -> K8sStatus

Get current status.

pub async fn scale(&self, replicas: i32) -> Result<DeployAction>

Scale the agent’s own deployment.

pub async fn rolling_restart(&self) -> Result<DeployAction>

Perform a rolling restart of the agent’s deployment.

pub async fn list_pods(&self) -> Result<Vec<PodInfo>>

List pods belonging to our deployment.

pub async fn spawn_subagent_pod( &self, subagent_id: &str, image: Option<&str>, env_vars: HashMap<String, String>, ) -> Result<DeployAction>

Spawn a new pod for a swarm sub-agent.

pub async fn delete_subagent_pod( &self, subagent_id: &str, ) -> Result<DeployAction>

Delete a sub-agent pod.

pub async fn recent_actions(&self, limit: usize) -> Vec<DeployAction>

Get recent deployment actions.

Trait Implementations

impl Clone for K8sManager

fn clone(&self) -> K8sManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for K8sManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.