dsh_api 0.10.0

DSH resource management API client
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

#[path = "common.rs"]
mod common;

#[cfg(feature = "manage")]
#[tokio::main]
async fn main() -> Result<(), String> {
  use crate::common::{get_client, initialize_logger, print_header};
  use dsh_api::types::{LimitValue, LimitValueSecretCount, LimitValueSecretCountName};
  use std::num::NonZero;

  const MANAGED_TENANT_UNDER_TEST: &str = "ajuc-test";

  initialize_logger();
  let client = get_client().await?;

  print_header("get_tenant_limits");
  let tenant_limits = client.get_tenant_limits(MANAGED_TENANT_UNDER_TEST).await?;
  println!("{:#?}", tenant_limits);
  println!("{}", serde_json::to_string_pretty(&tenant_limits).unwrap());

  print_header("get_tenant_limit");
  for kind in [
    LimitValueSecretCountName::CertificateCount,
    LimitValueSecretCountName::ConsumerRate,
    LimitValueSecretCountName::Cpu,
    LimitValueSecretCountName::KafkaAclGroupCount,
    LimitValueSecretCountName::Mem,
    LimitValueSecretCountName::PartitionCount,
    LimitValueSecretCountName::ProducerRate,
    LimitValueSecretCountName::RequestRate,
    LimitValueSecretCountName::SecretCount,
    LimitValueSecretCountName::TopicCount,
  ] {
    println!("{:?}", client.get_tenant_limit(MANAGED_TENANT_UNDER_TEST, kind.to_string()).await?);
  }

  print_header("patch_tenant_limits");
  let tenant_limits = vec![LimitValue::SecretCount(LimitValueSecretCount { name: LimitValueSecretCountName::SecretCount, value: NonZero::new(10).unwrap() })];
  println!("{}", serde_json::to_string_pretty(&tenant_limits).unwrap());
  match client.patch_tenant_limit(MANAGED_TENANT_UNDER_TEST, &tenant_limits).await {
    Ok(_) => println!("tenant limits patched"),
    Err(error) => println!("{}\n{:#?}", error, error),
  }

  Ok(())
}

#[cfg(not(feature = "manage"))]
fn main() {}