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 OutputPortsBulletinsApi.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait OutputPortsBulletinsApi {
/// Clears bulletins for an output port
///
/// Calls `POST /nifi-api/output-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 - /output-ports/{uuid}`.
///
/// *Supported in NiFi: 2.7.2, 2.8.0*
async fn clear_bulletins_3(
&self,
body: &types::ClearBulletinsRequestEntity,
) -> Result<types::ClearBulletinsResultEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "clear_bulletins_3".to_string(),
version: "unknown".to_string(),
})
}
}
/// Sub-resource trait for OutputPortsRunStatusApi.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait OutputPortsRunStatusApi {
/// Updates run status of an output-port
///
/// Calls `PUT /nifi-api/output-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 - /output-ports/{uuid} or /operation/output-ports/{uuid}`.
async fn update_run_status_3(
&self,
body: &types::PortRunStatusEntity,
) -> Result<types::ProcessorEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "update_run_status_3".to_string(),
version: "unknown".to_string(),
})
}
}
/// The OutputPorts API.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait OutputPortsApi {
/// Returns a sub-resource accessor for config operations.
///
/// # Parameters
/// - `id`: The output port id.
fn bulletins<'b>(&'b self, id: &'b str) -> impl OutputPortsBulletinsApi + 'b;
/// Returns a sub-resource accessor for config operations.
///
/// # Parameters
/// - `id`: The port id.
fn run_status<'b>(&'b self, id: &'b str) -> impl OutputPortsRunStatusApi + 'b;
/// Gets an output port
///
/// Calls `GET /nifi-api/output-ports/{id}`.
///
/// # Parameters
/// - `id`: The output 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 - /output-ports/{uuid}`.
async fn get_output_port(&self, id: &str) -> Result<types::PortEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "get_output_port".to_string(),
version: "unknown".to_string(),
})
}
/// Deletes an output port
///
/// Calls `DELETE /nifi-api/output-ports/{id}`.
///
/// # Parameters
/// - `id`: The output 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 - /output-ports/{uuid}`.
/// Requires `Write - Parent Process Group - /process-groups/{uuid}`.
async fn remove_output_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_output_port".to_string(),
version: "unknown".to_string(),
})
}
/// Updates an output port
///
/// Calls `PUT /nifi-api/output-ports/{id}`.
///
/// # Parameters
/// - `id`: The output 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 - /output-ports/{uuid}`.
async fn update_output_port(
&self,
id: &str,
body: &types::PortEntity,
) -> Result<types::PortEntity, NifiError> {
Err(NifiError::UnsupportedEndpoint {
endpoint: "update_output_port".to_string(),
version: "unknown".to_string(),
})
}
}