Struct CanaryDeploymentEngine 

pub struct CanaryDeploymentEngine { /* private fields */ }

Canary deployment engine

Implementations

impl CanaryDeploymentEngine

pub fn new(default_config: CanaryConfig) -> Self

Create a new canary deployment engine

pub fn with_health_monitor( default_config: CanaryConfig, health_monitor: Arc<dyn HealthMonitor>, ) -> Self

Create with custom health monitor

pub async fn update_metrics( &self, deployment_id: &str, is_canary: bool, latency_ms: f64, success: bool, cost: Option<f64>, ) -> ActuatorResult<()>

Update deployment metrics

pub async fn pause(&self, deployment_id: &str) -> ActuatorResult<()>

Pause a deployment (manual control)

pub async fn resume(&self, deployment_id: &str) -> ActuatorResult<()>

Resume a paused deployment

pub async fn is_paused(&self, deployment_id: &str) -> ActuatorResult<bool>

Check if deployment is paused

pub async fn get_config( &self, deployment_id: &str, ) -> ActuatorResult<CanaryConfig>

Get deployment configuration

pub async fn update_health( &self, deployment_id: &str, health: HealthStatus, ) -> ActuatorResult<()>

Update health status

Trait Implementations

impl CanaryDeployment for CanaryDeploymentEngine

fn start_canary<'life0, 'async_trait>( &'life0 mut self, request: DeploymentRequest, ) -> Pin<Box<dyn Future<Output = ActuatorResult<DeploymentStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start a canary deployment

fn promote<'life0, 'life1, 'async_trait>( &'life0 mut self, deployment_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActuatorResult<DeploymentStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Promote to next canary phase

fn complete<'life0, 'life1, 'async_trait>( &'life0 mut self, deployment_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActuatorResult<DeploymentStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Complete canary deployment (promote to 100%)

fn abort<'life0, 'life1, 'async_trait>( &'life0 mut self, deployment_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActuatorResult<RollbackResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Abort canary deployment

fn get_status<'life0, 'life1, 'async_trait>( &'life0 self, deployment_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActuatorResult<DeploymentStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get current canary status

fn can_promote<'life0, 'life1, 'async_trait>( &'life0 self, deployment_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActuatorResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if phase can be promoted

impl Clone for CanaryDeploymentEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CanaryDeploymentEngine

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

Formats the value using the given formatter.

impl TrafficSplitter for CanaryDeploymentEngine

fn route_request<'life0, 'life1, 'async_trait>( &'life0 self, request_id: &'life1 str, canary_percent: f64, ) -> Pin<Box<dyn Future<Output = ActuatorResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Route request to canary or control

fn get_routing_stats(&self) -> HashMap<String, u64>

Get current routing statistics