Avoid build on linera net up --kubernetes (#2986)

## Motivation

When testing kubernetes related config changes locally with `linera net up --kubernetes`, there's no way to just use an existing docker image (if you're not testing something on the linera binaries, there's no need to rebuild the docker image every time)

## Proposal

Add options to skip building the image and just use an existing one. The name of the image to use also became a configurable option

## Test Plan

Ran `linera net up --kubernetes` locally with these new arguments

## Release Plan

- Nothing to do / These changes follow the usual release cycle.

Author: ndr-ds

linera-client/src/client_options.rs

@@ -1004,6 +1004,16 @@ pub enum NetCommand {
         #[arg(long, num_args=0..=1)]
         binaries: Option<Option<PathBuf>>,
 
+        /// Don't build docker image. This assumes that the image is already built.
+        #[cfg(feature = "kubernetes")]
+        #[arg(long, default_value = "false")]
+        no_build: bool,
+
+        /// The name of the docker image to use.
+        #[cfg(feature = "kubernetes")]
+        #[arg(long, default_value = "linera:latest")]
+        docker_image_name: String,
+
         /// Run with a specific path where the wallet and validator input files are.
         /// If none, then a temporary directory is created.
         #[arg(long)]

linera-service/src/cli_wrappers/docker.rs

@@ -17,7 +17,7 @@ impl DockerImage {
         &self.name
     }
 
-    pub async fn build(name: String, binaries: &BuildArg, github_root: &PathBuf) -> Result<Self> {
+    pub async fn build(name: &String, binaries: &BuildArg, github_root: &PathBuf) -> Result<Self> {
         let build_arg = match binaries {
             BuildArg::Directory(bin_path) => {
                 // Get the binaries from the specified path
@@ -73,12 +73,7 @@ impl DockerImage {
                 ),
             ]);
 
-        command
-            .arg(".")
-            .args(["-t", &name])
-            .spawn_and_wait()
-            .await?;
-
+        command.arg(".").args(["-t", name]).spawn_and_wait().await?;
         Ok(docker_image)
     }
 }

linera-service/src/cli_wrappers/local_kubernetes_net.rs

@@ -46,6 +46,8 @@ pub struct LocalKubernetesNetConfig {
     pub num_initial_validators: usize,
     pub num_shards: usize,
     pub binaries: BuildArg,
+    pub no_build: bool,
+    pub docker_image_name: String,
     pub policy: ResourceControlPolicy,
 }
 
@@ -62,6 +64,8 @@ pub struct LocalKubernetesNet {
     next_client_id: usize,
     tmp_dir: Arc<TempDir>,
     binaries: BuildArg,
+    no_build: bool,
+    docker_image_name: String,
     kubectl_instance: Arc<Mutex<KubectlInstance>>,
     kind_clusters: Vec<KindCluster>,
     num_initial_validators: usize,
@@ -96,6 +100,8 @@ impl SharedLocalKubernetesNetTestingConfig {
             num_initial_validators: 4,
             num_shards: 4,
             binaries,
+            no_build: false,
+            docker_image_name: String::from("linera:latest"),
             policy: ResourceControlPolicy::devnet(),
         })
     }
@@ -122,6 +128,8 @@ impl LineraNetConfig for LocalKubernetesNetConfig {
             self.network,
             self.testing_prng_seed,
             self.binaries,
+            self.no_build,
+            self.docker_image_name,
             KubectlInstance::new(Vec::new()),
             clusters,
             self.num_initial_validators,
@@ -300,10 +308,13 @@ impl LineraNet for LocalKubernetesNet {
 }
 
 impl LocalKubernetesNet {
+    #[allow(clippy::too_many_arguments)]
     fn new(
         network: Network,
         testing_prng_seed: Option<u64>,
         binaries: BuildArg,
+        no_build: bool,
+        docker_image_name: String,
         kubectl_instance: KubectlInstance,
         kind_clusters: Vec<KindCluster>,
         num_initial_validators: usize,
@@ -315,6 +326,8 @@ impl LocalKubernetesNet {
             next_client_id: 0,
             tmp_dir: Arc::new(tempdir()?),
             binaries,
+            no_build,
+            docker_image_name,
             kubectl_instance: Arc::new(Mutex::new(kubectl_instance)),
             kind_clusters,
             num_initial_validators,
@@ -394,8 +407,12 @@ impl LocalKubernetesNet {
     async fn run(&mut self) -> Result<()> {
         let github_root = get_github_root().await?;
         // Build Docker image
-        let docker_image =
-            DockerImage::build(String::from("linera:latest"), &self.binaries, &github_root).await?;
+        let docker_image_name = if self.no_build {
+            self.docker_image_name.clone()
+        } else {
+            DockerImage::build(&self.docker_image_name, &self.binaries, &github_root).await?;
+            self.docker_image_name.clone()
+        };
 
         let base_dir = github_root
             .join("kubernetes")
@@ -412,13 +429,13 @@ impl LocalKubernetesNet {
 
         let mut validators_initialization_futures = Vec::new();
         for (i, kind_cluster) in self.kind_clusters.iter().cloned().enumerate() {
-            let docker_image_name = docker_image.name().to_string();
             let base_dir = base_dir.clone();
             let github_root = github_root.clone();
 
             let kubectl_instance = kubectl_instance_clone.clone();
             let tmp_dir_path = tmp_dir_path_clone.clone();
 
+            let docker_image_name = docker_image_name.clone();
             let future = async move {
                 let cluster_id = kind_cluster.id();
                 kind_cluster.load_docker_image(&docker_image_name).await?;

linera-service/src/linera/main.rs

@@ -1592,6 +1592,8 @@ async fn run(options: &ClientOptions) -> Result<i32, anyhow::Error> {
                 policy_config,
                 kubernetes: true,
                 binaries,
+                no_build,
+                docker_image_name,
                 path: _,
                 storage: _,
                 external_protocol: _,
@@ -1604,6 +1606,8 @@ async fn run(options: &ClientOptions) -> Result<i32, anyhow::Error> {
                     *shards,
                     *testing_prng_seed,
                     binaries,
+                    *no_build,
+                    docker_image_name.clone(),
                     policy_config.into_policy(),
                 )
                 .boxed()

linera-service/src/linera/net_up_utils.rs

@@ -110,6 +110,8 @@ pub async fn handle_net_up_kubernetes(
     num_shards: usize,
     testing_prng_seed: Option<u64>,
     binaries: &Option<Option<PathBuf>>,
+    no_build: bool,
+    docker_image_name: String,
     policy: ResourceControlPolicy,
 ) -> anyhow::Result<()> {
     if num_initial_validators < 1 {
@@ -130,6 +132,8 @@ pub async fn handle_net_up_kubernetes(
         num_initial_validators,
         num_shards,
         binaries: binaries.clone().into(),
+        no_build,
+        docker_image_name,
         policy,
     };
     let (mut net, client1) = config.instantiate().await?;