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
// @generated — do not edit; run `cargo run -p nifi-openapi-gen`
use crate::NifiClient;
use crate::NifiError;
pub struct SystemDiagnosticsApi<'a> {
pub(crate) client: &'a NifiClient,
}
#[allow(
private_interfaces,
clippy::too_many_arguments,
clippy::vec_init_then_push
)]
impl<'a> SystemDiagnosticsApi<'a> {
/// Gets the diagnostics for the system NiFi is running on
///
/// Calls `GET /nifi-api/system-diagnostics`.
///
/// # Parameters
/// - `nodewise`: Whether or not to include the breakdown per node. Optional, defaults to false
/// - `diagnostic_level`: Whether or not to include verbose details. Optional, defaults to false
/// - `cluster_node_id`: The id of the node where to get the status.
///
/// # Errors
/// - `401`: Client could not be authenticated.
/// - `403`: Client is not authorized to make this request.
///
/// # Permissions
/// Requires `Read - /system`.
pub async fn get_system_diagnostics(
&self,
nodewise: Option<bool>,
diagnostic_level: Option<crate::v2_8_0::types::DiagnosticLevel>,
cluster_node_id: Option<&str>,
) -> Result<crate::v2_8_0::types::SystemDiagnosticsDto, NifiError> {
let mut query: Vec<(&str, String)> = vec![];
if let Some(v) = nodewise {
query.push(("nodewise", v.to_string()));
}
if let Some(v) = diagnostic_level {
query.push(("diagnosticLevel", v.to_string()));
}
if let Some(v) = cluster_node_id {
query.push(("clusterNodeId", v.to_string()));
}
let e: crate::v2_8_0::types::SystemDiagnosticsEntity = self
.client
.get_with_query("/system-diagnostics", &query)
.await?;
Ok(e.system_diagnostics.unwrap_or_default())
}
/// Retrieve available JMX metrics
///
/// Note: This endpoint is subject to change as NiFi and it's REST API evolve.
///
/// Calls `GET /nifi-api/system-diagnostics/jmx-metrics`.
///
/// # Parameters
/// - `bean_name_filter`: Regular Expression Pattern to be applied against the ObjectName
///
/// # Errors
/// - `400`: NiFi was unable to complete the request because it was invalid. The request should not be retried without modification.
/// - `401`: Client could not be authenticated.
/// - `403`: Client is not authorized to make this request.
/// - `404`: The specified resource could not be found.
/// - `409`: The request was valid but NiFi was not in the appropriate state to process it.
///
/// # Permissions
/// Requires `Read - /system`.
pub async fn get_jmx_metrics(
&self,
bean_name_filter: Option<&str>,
) -> Result<crate::v2_8_0::types::JmxMetricsResultsEntity, NifiError> {
let mut query: Vec<(&str, String)> = vec![];
if let Some(v) = bean_name_filter {
query.push(("beanNameFilter", v.to_string()));
}
self.client
.get_with_query("/system-diagnostics/jmx-metrics", &query)
.await
}
}
#[allow(clippy::too_many_arguments)]
impl crate::v2_8_0::traits::SystemDiagnosticsApi for SystemDiagnosticsApi<'_> {
async fn get_system_diagnostics(
&self,
nodewise: Option<bool>,
diagnostic_level: Option<crate::v2_8_0::types::DiagnosticLevel>,
cluster_node_id: Option<&str>,
) -> Result<crate::v2_8_0::types::SystemDiagnosticsDto, NifiError> {
self.get_system_diagnostics(nodewise, diagnostic_level, cluster_node_id)
.await
}
async fn get_jmx_metrics(
&self,
bean_name_filter: Option<&str>,
) -> Result<crate::v2_8_0::types::JmxMetricsResultsEntity, NifiError> {
self.get_jmx_metrics(bean_name_filter).await
}
}