oneiriq-surql 0.2.2

Code-first database toolkit for SurrealDB - schema definitions, migrations, query building, and typed CRUD (Rust port of oneiriq-surql). Published as the `oneiriq-surql` crate; imported as `use surql::...`.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

//! Sequential deployment strategy.
//!
//! Deploys the plan's migrations to each environment one after the
//! other, stopping on the first failure. Port of
//! `surql.orchestration.strategy.SequentialStrategy`.

use async_trait::async_trait;
use tracing::{info, warn};

use crate::error::Result;
use crate::orchestration::coordinator::DeploymentPlan;
use crate::orchestration::result::{DeploymentResult, DeploymentStatus};
use crate::orchestration::strategies::{
    deploy_to_environment, resolve_plan_environments, DeploymentStrategy,
};

/// Deploy sequentially, environment-by-environment.
///
/// Stops at the first failed environment to match Python semantics.
#[derive(Debug, Default, Clone, Copy)]
pub struct SequentialStrategy;

impl SequentialStrategy {
    /// Construct a new sequential strategy.
    pub fn new() -> Self {
        Self
    }
}

#[async_trait]
impl DeploymentStrategy for SequentialStrategy {
    async fn deploy(&self, plan: &DeploymentPlan) -> Result<Vec<DeploymentResult>> {
        info!(
            count = plan.environments.len(),
            "sequential_deployment_started"
        );
        let envs = resolve_plan_environments(plan).await?;
        let mut out = Vec::with_capacity(envs.len());
        for env in &envs {
            let result = deploy_to_environment(env, plan).await;
            let status = result.status;
            out.push(result);
            if status == DeploymentStatus::Failed {
                warn!(environment = %env.name, "sequential_deployment_stopped_on_failure");
                break;
            }
        }
        Ok(out)
    }
}