linera-service 0.11.1

Executable for clients (aka CLI wallets), proxy (aka validator frontend) and servers of the Linera protocol.
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

// Copyright (c) Zefchain Labs, Inc.
// SPDX-License-Identifier: Apache-2.0

use anyhow::Result;
use linera_base::command::CommandExt;
use rand::Rng;
use tokio::process::Command;

#[derive(Clone)]
pub struct KindCluster {
    id: u32,
}

impl KindCluster {
    fn get_random_cluster_id() -> u32 {
        rand::thread_rng().gen_range(0..99999)
    }

    pub async fn create() -> Result<Self> {
        let cluster = Self {
            id: Self::get_random_cluster_id(),
        };

        Command::new("kind")
            .args(["create", "cluster"])
            .args(["--name", cluster.id().to_string().as_str()])
            .spawn_and_wait()
            .await?;

        Ok(cluster)
    }

    pub fn id(&self) -> u32 {
        self.id
    }

    pub async fn delete(&self) -> Result<()> {
        Command::new("kind")
            .args(["delete", "cluster"])
            .args(["--name", &self.id.to_string()])
            .spawn_and_wait()
            .await
    }

    pub async fn load_docker_image(&self, docker_image: &String) -> Result<()> {
        Command::new("kind")
            .args(["load", "docker-image", docker_image])
            .args(["--name", self.id.to_string().as_str()])
            .spawn_and_wait()
            .await
    }
}