Struct Manager 

pub struct Manager { /* private fields */ }

Implements the mirror reloader.

Implementations

impl Manager

pub fn prepare_copies( &self, targets: &[Target], copy_image: &str, ) -> Result<Vec<CopyInfo>, CopyError>

Scales down original deployments and creates -caproni copies for the given targets. Skips unsupported resource types.

Callers are responsible for passing a deduplicated, pre-merged target list; in practice, callers should use collect_and_validate_targets to produce it. Returns a list of CopyInfo for cleanup operations.

Errors

Returns CopyError if scaling down, fetching, modifying, or applying a copy fails for any target.

pub fn cleanup_copy(&self, deployment: &CopyInfo) -> Result<(), CopyError>

Deletes a -caproni deployment copy and scales the original back up.

Errors

Returns CopyError if deleting, scaling, or waiting fails.

impl Manager

pub fn new(kubectl_backend: Box<dyn KubectlBackend + Send + Sync>) -> Self

Creates a new mirror reloader manager.

pub fn reloader_type(&self) -> &'static str

Returns the reloader type identifier ("mirror").

pub fn check_preconditions( &self, executor: &dyn CommandRunner, reloader_config: &ReloaderConfig, _caproni_config: &CaproniConfig, get_tool_version: &dyn Fn(&str) -> Option<String>, ) -> Result<(), MirrorError>

Verifies mirrord version meets minimum requirements and that no stale -caproni copy exists for this reloader’s target.

executor is threaded explicitly rather than read off an ambient context, unlike the Go original’s executor.FromContext: xianyun_executor::exec::context::{from_context, with_context} are themselves unimplemented stubs in a sibling crate outside this task’s scope, so this port takes the CommandRunner directly as a parameter instead of threading it through a context object. See PORT_NOTES.md.

Errors

Returns MirrorError::MirrordVersionTooOld if the installed mirrord version is below the configured minimum, or MirrorError::CaproniDeploymentsExist if a stale -caproni copy of the target already exists.

pub fn run( &self, executor: &dyn CommandRunner, reloader_config: &ReloaderConfig, caproni_config: &CaproniConfig, kubeconfig_path: &str, ) -> Result<(), MirrorError>

Runs the mirror reloader, blocking until the context is cancelled. Deployment copies must be prepared by the caller before run is invoked (see Manager::cleanup_copy_deployments).

This method:

• Generates a mirrord configuration file
• Starts caproni edit-mode-process-supervisor wrapped in mirrord
• Runs processes tagged context: local outside mirrord

kubeconfig_path is the path to a temporary kubeconfig for the caproni-selected cluster (created and owned by the caller). Implementations that launch external tooling pin KUBECONFIG to it rather than relying on the user’s global current-context. It may be empty.

Errors

Returns MirrorError if the config is invalid, no repository is configured, the mirrord config cannot be generated, or the underlying process supervision fails.

pub fn prepare_from_reloader_configs( &self, reloaders: &HashMap<String, ReloaderConfig>, copy_sleep_image: &str, ) -> Result<Vec<CopyInfo>, MirrorError>

Collects and validates mirror targets from the given reloader configs, then prepares a coordinated set of deployment copies. Returns an empty list if there are no mirror targets.

Errors

Returns MirrorError::ValidatingTargets if the targets conflict, or MirrorError::Copy if preparing a copy fails.

pub fn cleanup_copy_deployments(&self, deployments: &[CopyInfo])

Deletes all -caproni deployment copies and scales the originals back up. Cleanup failures are logged, not returned: the caller is typically shutting down and cannot act on them.

pub fn status( &self, reloader_config: &ReloaderConfig, _caproni_config: &CaproniConfig, ) -> Result<Status, MirrorError>

Returns the current status of the reloader.

Errors

Returns MirrorError if the config is not a mirror reloader or has no target configured.

pub fn cleanup_stale_mirrord_agents(&self, namespace: &str)

Removes leftover mirrord agent pods that may cause “Detected dirty iptables” errors on subsequent runs. This must be called once before any reloaders are started, not per-reloader, to avoid killing a live agent belonging to a concurrently running reloader. Failures are logged, not returned: this cleanup is best-effort.

pub fn validate( &self, reloader_config: &ReloaderConfig, caproni_config: &CaproniConfig, ) -> Result<(), MirrorError>

Validates the mirror reloader configuration. Mirror reloaders don’t have file path dependencies, so this primarily validates the configuration structure.

Errors

Returns MirrorError if the config is not a mirror reloader, has no target or referenced repository configured, or any edit-mode process has an empty command.