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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
// @generated — do not edit; run `cargo run -p nifi-openapi-gen`
#[allow(unused_imports)]
use crate::NifiError;
#[allow(unused_imports)]
use crate::dynamic::types;
/// Sub-resource trait for InputPortsBulletinsApi.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait InputPortsBulletinsApi {
/// Clears bulletins for an input port
///
/// Calls `POST /nifi-api/input-ports/{id}/bulletins/clear-requests`.
///
/// # 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 `Write - /input-ports/{uuid}`.
///
/// *Supported in NiFi: 2.7.2, 2.8.0*
async fn clear_bulletins_2(
&self,
body: &types::ClearBulletinsRequestEntity,
) -> Result<types::ClearBulletinsResultEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "clear_bulletins_2".to_string(),
version: "unknown".to_string(),
})
}
}
/// Sub-resource trait for InputPortsRunStatusApi.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait InputPortsRunStatusApi {
/// Updates run status of an input-port
///
/// Calls `PUT /nifi-api/input-ports/{id}/run-status`.
///
/// # 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 `Write - /input-ports/{uuid} or /operation/input-ports/{uuid}`.
async fn update_run_status_2(
&self,
body: &types::PortRunStatusEntity,
) -> Result<types::ProcessorEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "update_run_status_2".to_string(),
version: "unknown".to_string(),
})
}
}
/// The InputPorts API.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait InputPortsApi {
/// Returns a sub-resource accessor for config operations.
///
/// # Parameters
/// - `id`: The input port id.
fn bulletins<'b>(&'b self, id: &'b str) -> impl InputPortsBulletinsApi + 'b;
/// Returns a sub-resource accessor for config operations.
///
/// # Parameters
/// - `id`: The port id.
fn run_status<'b>(&'b self, id: &'b str) -> impl InputPortsRunStatusApi + 'b;
/// Gets an input port
///
/// Calls `GET /nifi-api/input-ports/{id}`.
///
/// # Parameters
/// - `id`: The input port id.
///
/// # 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 - /input-ports/{uuid}`.
async fn get_input_port(&self, id: &str) -> Result<types::PortEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "get_input_port".to_string(),
version: "unknown".to_string(),
})
}
/// Deletes an input port
///
/// Calls `DELETE /nifi-api/input-ports/{id}`.
///
/// # Parameters
/// - `id`: The input port id.
/// - `version`: The revision is used to verify the client is working with the latest version of the flow.
/// - `client_id`: If the client id is not specified, new one will be generated. This value (whether specified or generated) is included in the response.
/// - `disconnected_node_acknowledged`: Acknowledges that this node is disconnected to allow for mutable requests to proceed.
///
/// # 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 `Write - /input-ports/{uuid}`.
/// Requires `Write - Parent Process Group - /process-groups/{uuid}`.
async fn remove_input_port(
&self,
id: &str,
version: Option<&str>,
client_id: Option<&str>,
disconnected_node_acknowledged: Option<bool>,
) -> Result<types::PortEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "remove_input_port".to_string(),
version: "unknown".to_string(),
})
}
/// Updates an input port
///
/// Calls `PUT /nifi-api/input-ports/{id}`.
///
/// # Parameters
/// - `id`: The input port id.
///
/// # 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 `Write - /input-ports/{uuid}`.
async fn update_input_port(
&self,
id: &str,
body: &types::PortEntity,
) -> Result<types::PortEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "update_input_port".to_string(),
version: "unknown".to_string(),
})
}
}