nifi-rust-client 0.4.0

Apache NiFi REST API client library
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
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
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241

// @generated — do not edit; run `cargo run -p nifi-openapi-gen`

#![allow(dead_code, private_interfaces, unused_imports)]
use super::*;
use serde::{Deserialize, Serialize};
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct LatestProvenanceEventsDto {
    #[serde(rename = "componentId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub component_id: Option<String>,
    #[serde(rename = "provenanceEvents")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub provenance_events: Option<Vec<ProvenanceEventDto>>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct LatestProvenanceEventsEntity {
    pub latest_provenance_events: Option<LatestProvenanceEventsDto>,
}
/// The provenance events that matched the search criteria.
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProvenanceEventDto {
    /// The alternate identifier uri for the fileflow for the event.
    #[serde(rename = "alternateIdentifierUri")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub alternate_identifier_uri: Option<String>,
    /// The attributes of the flowfile for the event.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub attributes: Option<Vec<AttributeDto>>,
    /// The child uuids for the event.
    #[serde(rename = "childUuids")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub child_uuids: Option<Vec<String>>,
    /// The label for the node where the event originated.
    #[serde(rename = "clusterNodeAddress")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub cluster_node_address: Option<String>,
    /// The identifier for the node where the event originated.
    #[serde(rename = "clusterNodeId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub cluster_node_id: Option<String>,
    /// The id of the component that generated the event.
    #[serde(rename = "componentId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub component_id: Option<String>,
    /// The name of the component that generated the event.
    #[serde(rename = "componentName")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub component_name: Option<String>,
    /// The type of the component that generated the event.
    #[serde(rename = "componentType")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub component_type: Option<String>,
    /// Whether the input and output content claim is the same.
    #[serde(rename = "contentEqual")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub content_equal: Option<bool>,
    /// The event details.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub details: Option<String>,
    /// The event duration in milliseconds.
    #[serde(rename = "eventDuration")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub event_duration: Option<i64>,
    /// The event id. This is a one up number thats unique per node.
    #[serde(rename = "eventId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub event_id: Option<i64>,
    /// The timestamp of the event.
    #[serde(rename = "eventTime")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub event_time: Option<String>,
    /// Event Timestamp formatted using ISO8601
    #[serde(rename = "eventTimestamp")]
    #[serde(default)]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub event_timestamp: Option<String>,
    /// The type of the event.
    #[serde(rename = "eventType")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub event_type: Option<String>,
    /// The size of the flowfile for the event.
    #[serde(rename = "fileSize")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub file_size: Option<String>,
    /// The size of the flowfile in bytes for the event.
    #[serde(rename = "fileSizeBytes")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub file_size_bytes: Option<i64>,
    /// The uuid of the flowfile for the event.
    #[serde(rename = "flowFileUuid")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub flow_file_uuid: Option<String>,
    /// The id of the group that the component resides in. If the component is no longer in the flow, the group id will not be set.
    #[serde(rename = "groupId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub group_id: Option<String>,
    /// The event uuid.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub id: Option<String>,
    /// Whether the input content is still available.
    #[serde(rename = "inputContentAvailable")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub input_content_available: Option<bool>,
    /// The container in which the input content claim lives.
    #[serde(rename = "inputContentClaimContainer")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub input_content_claim_container: Option<String>,
    /// The file size of the input content claim formatted.
    #[serde(rename = "inputContentClaimFileSize")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub input_content_claim_file_size: Option<String>,
    /// The file size of the intput content claim in bytes.
    #[serde(rename = "inputContentClaimFileSizeBytes")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub input_content_claim_file_size_bytes: Option<i64>,
    /// The identifier of the input content claim.
    #[serde(rename = "inputContentClaimIdentifier")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub input_content_claim_identifier: Option<String>,
    /// The offset into the input content claim where the flowfiles content begins.
    #[serde(rename = "inputContentClaimOffset")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub input_content_claim_offset: Option<i64>,
    /// The section in which the input content claim lives.
    #[serde(rename = "inputContentClaimSection")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub input_content_claim_section: Option<String>,
    /// The duration since the lineage began, in milliseconds.
    #[serde(rename = "lineageDuration")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub lineage_duration: Option<i64>,
    /// Whether the output content is still available.
    #[serde(rename = "outputContentAvailable")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub output_content_available: Option<bool>,
    /// The container in which the output content claim lives.
    #[serde(rename = "outputContentClaimContainer")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub output_content_claim_container: Option<String>,
    /// The file size of the output content claim formatted.
    #[serde(rename = "outputContentClaimFileSize")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub output_content_claim_file_size: Option<String>,
    /// The file size of the output content claim in bytes.
    #[serde(rename = "outputContentClaimFileSizeBytes")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub output_content_claim_file_size_bytes: Option<i64>,
    /// The identifier of the output content claim.
    #[serde(rename = "outputContentClaimIdentifier")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub output_content_claim_identifier: Option<String>,
    /// The offset into the output content claim where the flowfiles content begins.
    #[serde(rename = "outputContentClaimOffset")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub output_content_claim_offset: Option<i64>,
    /// The section in which the output content claim lives.
    #[serde(rename = "outputContentClaimSection")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub output_content_claim_section: Option<String>,
    /// The parent uuids for the event.
    #[serde(rename = "parentUuids")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub parent_uuids: Option<Vec<String>>,
    /// The relationship to which the flowfile was routed if the event is of type ROUTE.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub relationship: Option<String>,
    /// Whether or not replay is available.
    #[serde(rename = "replayAvailable")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub replay_available: Option<bool>,
    /// Explanation as to why replay is unavailable.
    #[serde(rename = "replayExplanation")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub replay_explanation: Option<String>,
    /// The identifier of the queue/connection from which the flowfile was pulled to genereate this event. May be null if the queue/connection is unknown or the flowfile was generated from this event.
    #[serde(rename = "sourceConnectionIdentifier")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub source_connection_identifier: Option<String>,
    /// The source system flowfile id.
    #[serde(rename = "sourceSystemFlowFileId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub source_system_flow_file_id: Option<String>,
    /// The source/destination system uri if the event was a RECEIVE/SEND.
    #[serde(rename = "transitUri")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub transit_uri: Option<String>,
}
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ProvenanceEventEntity {
    pub provenance_event: Option<ProvenanceEventDto>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ReplayLastEventRequestEntity {
    /// The UUID of the component whose last event should be replayed.
    #[serde(rename = "componentId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub component_id: Option<String>,
    /// Which nodes are to replay their last provenance event.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub nodes: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct ReplayLastEventResponseEntity {
    #[serde(rename = "aggregateSnapshot")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub aggregate_snapshot: Option<ReplayLastEventSnapshotDto>,
    /// The UUID of the component whose last event should be replayed.
    #[serde(rename = "componentId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub component_id: Option<String>,
    /// The node-wise results
    #[serde(rename = "nodeSnapshots")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub node_snapshots: Option<Vec<NodeReplayLastEventSnapshotDto>>,
    /// Which nodes were requested to replay their last provenance event.
    #[serde(skip_serializing_if = "Option::is_none")]
    pub nodes: Option<String>,
}
#[non_exhaustive]
#[derive(Debug, Clone, Default, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct SubmitReplayRequestEntity {
    /// The identifier of the node where to submit the replay request.
    #[serde(rename = "clusterNodeId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub cluster_node_id: Option<String>,
    /// The event identifier
    #[serde(rename = "eventId")]
    #[serde(skip_serializing_if = "Option::is_none")]
    pub event_id: Option<i64>,
}