devops-armory 0.7.4

Library to make DevOps work easier, based on russh and actix.
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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

use std::{
    thread::
    sleep, 
    time
};

use super::usage::{
    cpu_usage_cfgroup2,
    cpu_usage_cfgroup1
};

/// Function to calculate used cpu - based on cpu cycles on cfgroup2 config in nodepool
/// Amount of requested CPU needs to be provided as well as other gke data
pub async fn cpu_calculated_stg_cfgroup2(
    token: String,
    gke_cluster_endpoint: String,
    gke_cluster_namespace: String,
    gke_pod_name: String,
    cpu: f64
) -> Result<f64, std::io::Error> {

    let cpu_use_old = cpu_usage_cfgroup2(
        token.clone(),
        gke_cluster_endpoint.clone(),
        gke_cluster_namespace.clone(),
        gke_pod_name.clone())
        .await.unwrap();

    let cpu_use_new = cpu_usage_cfgroup2(
        token.clone(),
        gke_cluster_endpoint.clone(),
        gke_cluster_namespace.clone(),
        gke_pod_name.clone())
    .await.unwrap();

    loop {
        let cpu_1 = cpu_use_old;

        sleep(time::Duration::from_millis(1000));

        let cpu_2 = cpu_use_new;
        let cpu_actual_usage = (cpu_2 - cpu_1) / 1000000.0 / cpu;

        return Ok(cpu_actual_usage);
    }

}


/// Function to calculate used cpu - based on cpu cycles on cfgroup1 config in nodepool
/// Amount of requested CPU needs to be provided as well as other gke data
pub async fn cpu_calculated_stg_cfgroup1(
    token: String,
    gke_cluster_endpoint: String,
    gke_cluster_namespace: String,
    gke_pod_name: String,
    cpu: f64
) -> Result<f64, std::io::Error> {

    let cpu_use_old = cpu_usage_cfgroup1(
        token.clone(),
        gke_cluster_endpoint.clone(),
        gke_cluster_namespace.clone(),
        gke_pod_name.clone())
    .await.unwrap();

    let cpu_use_new = cpu_usage_cfgroup1(
        token.clone(),
        gke_cluster_endpoint.clone(),
        gke_cluster_namespace.clone(),
        gke_pod_name.clone())
    .await.unwrap();

    loop {
        let cpu_1 = cpu_use_old;

        sleep(time::Duration::from_millis(1000));

        let cpu_2 = cpu_use_new;
        let cpu_actual_usage = (cpu_2 - cpu_1) / 1000000.0 / cpu;

        return Ok(cpu_actual_usage);
    }
}