kubemgr 0.3.0

The fastest way to merge Kubernetes configuration files 🏎.
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

use crate::utils::errors::KubeMergeError;
use kube::config::Kubeconfig;

#[derive(Debug)]
pub struct KubeconfigContent {
    pub content: String,
}

/// Core merging logic that works with raw YAML content
pub fn merge_kubeconfig_contents(configs: &[KubeconfigContent]) -> Result<String, KubeMergeError> {
    if configs.is_empty() {
        return Err(KubeMergeError::NoContent(
            "No kubeconfig content provided".to_string(),
        ));
    }

    let mut merged_config: Option<Kubeconfig> = None;

    for config in configs {
        let current_config: Kubeconfig = serde_yaml::from_str(&config.content)
            .map_err(|e| KubeMergeError::ParseError(e.to_string()))?;

        match merged_config {
            None => merged_config = Some(current_config),
            Some(ref mut merged) => {
                merged.clusters.extend(current_config.clusters);
                merged.auth_infos.extend(current_config.auth_infos);
                merged.contexts.extend(current_config.contexts);
                if merged.current_context.is_none() {
                    merged.current_context = current_config.current_context;
                }
            }
        }
    }

    let merged = merged_config.ok_or_else(|| {
        KubeMergeError::NoContent("No valid kubeconfig content found".to_string())
    })?;

    serde_yaml::to_string(&merged).map_err(|e| {
        KubeMergeError::ParseError(format!("Failed to serialize merged config: {}", e))
    })
}