k8-obj-core 0.1.0

Core Kubernetes API Objects
Documentation
use serde::Deserialize;
use serde::Serialize;
use std::collections::HashMap;

use k8_obj_metadata::Crd;
use k8_obj_metadata::CrdNames;
use k8_obj_metadata::Spec;
use k8_obj_metadata::Status;



const SERVICE_API: Crd = Crd {
    group: "core",
    version: "v1",
    names: CrdNames {
        kind: "Service",
        plural: "services",
        singular: "service",
    },
};

#[derive(Deserialize, Serialize, Debug, Default, Clone)]
#[serde(rename_all = "camelCase")]
pub struct ServiceSpec {
    #[serde(rename = "clusterIP")]
    pub cluster_ip: String,
    #[serde(rename = "externalIPs")]
    pub external_ips: Option<Vec<String>>,
    #[serde(rename = "loadBalancerIP")]
    pub load_balancer_ip: Option<String>,
    pub r#type: Option<LoadBalancerType>,
    pub external_name: Option<String>,
    pub external_traffic_policy: Option<ExternalTrafficPolicy>,
    pub ports: Vec<ServicePort>,
    pub selector: Option<HashMap<String, String>>,
}

impl Spec for ServiceSpec {

    type Status = ServiceStatus;

    fn metadata() -> &'static Crd {
        &SERVICE_API
    }


    fn make_same(&mut self,other: &Self)  {
        if other.cluster_ip == "" {
            self.cluster_ip = "".to_owned();
        }
    }

}





#[derive(Deserialize, Serialize, Debug, Default, Clone)]
#[serde(rename_all = "camelCase")]
pub struct ServicePort {
    pub name: Option<String>,
    pub node_port: Option<u16>,
    pub port: u16,
    pub target_port: Option<u16>,
}

#[derive(Deserialize, Serialize, Debug, Default, Clone)]
#[serde(rename_all = "camelCase",default)]
pub struct ServiceStatus {
    pub load_balancer: LoadBalancerStatus
}

impl Status for ServiceStatus{}

#[derive(Deserialize, Serialize, Debug, PartialEq, Clone)]
pub enum ExternalTrafficPolicy {
    Local,
    Cluster
}

#[derive(Deserialize, Serialize, Debug, PartialEq, Clone)]
pub enum LoadBalancerType {
    ExternalName,
    ClusterIP,
    NodePort,
    LoadBalancer
}

#[derive(Deserialize, Serialize, Debug, Default, Clone)]
#[serde(rename_all = "camelCase",default)]
pub struct LoadBalancerStatus {
    pub ingress: Vec<LoadBalancerIngress>
}



#[derive(Deserialize, Serialize, Debug, Default, Clone)]
#[serde(rename_all = "camelCase")]
pub struct LoadBalancerIngress {
    pub hostname: Option<String>,
    pub ip: Option<String>
}