atlas-local 0.7.1

A library for managing MongoDB Atlas local environments.
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81

use anyhow::{Context, Result};
use atlas_local::{
    Client,
    models::{CreateDeploymentOptions, Deployment},
};

#[tokio::main]
async fn main() -> Result<()> {
    let client = Client::connect_with_socket_defaults().context("connecting to docker")?;

    // Create a deployment for demonstration
    let deployment_name = "lifecycle-demo";
    println!("Creating deployment '{}'...", deployment_name);
    client
        .create_deployment(CreateDeploymentOptions {
            name: Some(deployment_name.to_string()),
            wait_until_healthy: Some(true),
            ..Default::default()
        })
        .await?;

    print_deployment_state(&client, deployment_name).await?;

    // Stop the deployment
    println!("Stopping deployment '{}'...", deployment_name);
    client
        .stop_deployment(deployment_name)
        .await
        .context("stopping deployment")?;

    print_deployment_state(&client, deployment_name).await?;

    // Start the deployment
    println!("Starting deployment '{}'...", deployment_name);
    client
        .start_deployment(deployment_name)
        .await
        .context("starting deployment")?;

    print_deployment_state(&client, deployment_name).await?;

    // Pause the deployment
    println!("Pausing deployment '{}'...", deployment_name);
    client
        .pause_deployment(deployment_name)
        .await
        .context("pausing deployment")?;

    print_deployment_state(&client, deployment_name).await?;

    // Unpause the deployment
    println!("Unpausing deployment '{}'...", deployment_name);
    client
        .unpause_deployment(deployment_name)
        .await
        .context("unpausing deployment")?;

    print_deployment_state(&client, deployment_name).await?;

    // Remove the deployment
    println!("Removing deployment '{}'...", deployment_name);
    client
        .delete_deployment(deployment_name)
        .await
        .context("removing deployment")?;

    println!("Deployment '{}' removed successfully", deployment_name);

    Ok(())
}

async fn print_deployment_state(client: &Client, deployment_name: &str) -> Result<()> {
    let Deployment { state, .. } = client
        .get_deployment(deployment_name)
        .await
        .context("getting deployment")?;

    println!("State: {state}");

    Ok(())
}