Add workload config implementation

.vscode/settings.json

@@ -11,6 +11,8 @@
         "protobuf",
         "Substate",
         "swdd",
+        "templating",
+        "unrendered",
         "utest",
         "VecDeque"
     ],

agent/src/cli.rs

@@ -19,7 +19,7 @@ use std::path::Path;
 use crate::control_interface::Directory;
 use crate::control_interface::FileSystemError;
 use clap::Parser;
-use common::objects::state::STR_RE_AGENT;
+use common::objects::STR_RE_AGENT;
 use common::DEFAULT_SERVER_ADDRESS;
 
 const DEFAULT_RUN_FOLDER: &str = "/tmp/ankaios/";

agent/src/runtime_manager.rs

@@ -2054,11 +2054,11 @@ mod tests {
                                 dependencies: Some(ank_base::Dependencies {
                                     dependencies: HashMap::from([
                                         (
-                                            "workload A".to_string(),
+                                            "workload_A".to_string(),
                                             AddCondition::AddCondRunning as i32,
                                         ),
                                         (
-                                            "workload C".to_string(),
+                                            "workload_C".to_string(),
                                             AddCondition::AddCondSucceeded as i32,
                                         ),
                                     ]),

ank/src/cli.rs

@@ -63,6 +63,7 @@ fn workload_completer(current: &OsStr) -> Vec<CompletionCandidate> {
 fn completions_object_field_mask(state: Vec<u8>, current: &OsStr) -> Vec<CompletionCandidate> {
     const DESIRED_STATE: &str = "desiredState";
     const WORKLOADS: &str = "workloads";
+    const CONFIGS: &str = "configs";
     const WORKLOAD_STATES: &str = "workloadStates";
 
     let mut result = Vec::new();
@@ -79,6 +80,12 @@ fn completions_object_field_mask(state: Vec<u8>, current: &OsStr) -> Vec<Complet
                 result.push(format!("{}.{}.{}", DESIRED_STATE, WORKLOADS, workload_name));
             }
         }
+        if let Some(configs) = desired_state.configs {
+            result.push(format!("{}.{}", DESIRED_STATE, CONFIGS));
+            for config_name in configs.keys() {
+                result.push(format!("{}.{}.{}", DESIRED_STATE, CONFIGS, config_name));
+            }
+        }
     }
 
     if let Some(workload_states) = state.workload_states {

ank/src/cli_commands.rs

@@ -272,7 +272,7 @@ impl CliCommands {
         changed_workloads.extend(update_state_success.deleted_workloads.iter().cloned());
 
         if changed_workloads.is_empty() {
-            output!("No workloads to update");
+            output!("Apply successful. No workloads updated.");
             return Ok(());
         } else {
             output!("Successfully applied the manifest(s).\nWaiting for workload(s) to reach desired states (press Ctrl+C to interrupt).\n");