csm-rs 0.102.0

A library for Shasta
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

use manta_backend_dispatcher::{
  error::Error,
  interfaces::pcs::PCSTrait,
  types::pcs::{
    power_status::types::PowerStatusAll as FrontEndPowerStatusAll,
    transitions::types::TransitionResponse,
  },
};

use crate::pcs;

use super::Csm;

impl PCSTrait for Csm {
  async fn power_on_sync(
    &self,
    auth_token: &str,
    nodes: &[String],
  ) -> Result<TransitionResponse, Error> {
    let operation = "on";

    pcs::transitions::http_client::post_block(
      &self.base_url,
      auth_token,
      &self.root_cert,
      operation,
      &nodes.to_vec(),
    )
    .await
    .map(|transition| transition.into())
    .map_err(|e: crate::error::Error| Error::Message(e.to_string()))
  }

  async fn power_off_sync(
    &self,
    auth_token: &str,
    nodes: &[String],
    force: bool,
  ) -> Result<TransitionResponse, Error> {
    let operation = if force { "force-off" } else { "soft-off" };

    pcs::transitions::http_client::post_block(
      &self.base_url,
      auth_token,
      &self.root_cert,
      operation,
      &nodes.to_vec(),
    )
    .await
    .map(|transition| transition.into())
    .map_err(|e: crate::error::Error| Error::Message(e.to_string()))
  }

  async fn power_reset_sync(
    &self,
    auth_token: &str,
    nodes: &[String],
    force: bool,
  ) -> Result<TransitionResponse, Error> {
    let operation = if force {
      "hard-restart"
    } else {
      "soft-restart"
    };

    pcs::transitions::http_client::post_block(
      &self.base_url,
      auth_token,
      &self.root_cert,
      operation,
      &nodes.to_vec(),
    )
    .await
    .map(|transition| transition.into())
    .map_err(|e: crate::error::Error| Error::Message(e.to_string()))
  }

  async fn power_status(
    &self,
    auth_token: &str,
    nodes: &[String],
    power_state_filter: Option<&str>,
    management_state_filter: Option<&str>,
  ) -> Result<FrontEndPowerStatusAll, Error> {
    // Convert &[String] to Vec<&str> and wrap in Some
    let nodes_str: Vec<&str> = nodes.iter().map(|s| s.as_str()).collect();
    let nodes_opt = Some(nodes_str.as_slice());

    pcs::power_status::http_client::post(
      &self.base_url,
      auth_token,
      &self.root_cert,
      nodes_opt,
      power_state_filter,
      management_state_filter,
    )
    .await
    .map(|status| {
      println!("return value from async fn power_status : {:?}", status);
      status.into()
    })
    .map_err(|e| Error::Message(e.to_string()))
  }
}