sk-core 2.3.0

SimKube core libraries
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
44
45
46
47
48
49

use tracing::*;

use super::*;
use crate::prelude::*;

// StartEndTimeable provides helper functions for computing the start and end times of a container
// from its corresponding ContainerState object.  Note that as per the Kubernetes spec, it is an
// error for the ContainerState to have more than one of `running`, `terminated`, or `waiting` set,
// so we don't have to worry about handling these cases.
impl StartEndTimeable for corev1::ContainerState {
    fn start_ts(&self) -> anyhow::Result<Option<i64>> {
        match self {
            corev1::ContainerState { running: Some(r), terminated: None, waiting: None } => {
                match r.started_at.as_ref() {
                    Some(time) => Ok(Some(time.0.timestamp())),
                    None => Err(KubernetesError::field_not_found("started_at")),
                }
            },
            corev1::ContainerState { running: None, terminated: Some(t), waiting: None } => {
                match t.started_at.as_ref() {
                    Some(time) => Ok(Some(time.0.timestamp())),
                    None => {
                        warn!("{:?}", t.message);
                        Err(KubernetesError::field_not_found("started_at"))
                    },
                }
            },
            corev1::ContainerState { running: None, terminated: None, waiting: Some(_) } => Ok(None),
            _ => Err(KubernetesError::malformed_container_state(self)),
        }
    }

    fn end_ts(&self) -> anyhow::Result<Option<i64>> {
        match self {
            corev1::ContainerState { running: Some(_), terminated: None, waiting: None } => Ok(None),
            corev1::ContainerState { running: None, terminated: Some(t), waiting: None } => {
                match t.finished_at.as_ref() {
                    Some(time) => Ok(Some(time.0.timestamp())),
                    None => {
                        warn!("{:?}", t.message);
                        Err(KubernetesError::field_not_found("finished_at"))
                    },
                }
            },
            corev1::ContainerState { running: None, terminated: None, waiting: Some(_) } => Ok(None),
            _ => Err(KubernetesError::malformed_container_state(self)),
        }
    }
}