wash_cli/common/
scale_cmd.rs

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
use anyhow::Result;

use wash_lib::cli::{
    scale::{handle_scale_component, ScaleCommand},
    CommandOutput, OutputKind,
};

use crate::appearance::spinner::Spinner;

pub async fn handle_command(
    command: ScaleCommand,
    output_kind: OutputKind,
) -> Result<CommandOutput> {
    let sp: Spinner = Spinner::new(&output_kind)?;
    let out = match command {
        ScaleCommand::Component(cmd) => {
            let scale_msg = if cmd.max_instances == u32::MAX {
                "unbounded concurrency".to_string()
            } else {
                format!("{} max concurrent instances", cmd.max_instances)
            };
            sp.update_spinner_message(format!(
                " Sending request to scale component {} to {scale_msg} ... ",
                cmd.component_ref
            ));
            handle_scale_component(cmd.clone()).await?
        }
    };

    sp.finish_and_clear();

    Ok(out)
}