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

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

use crate::NifiError;
/// Sub-resource trait for the `drop_requests` sub-group.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait FlowFileQueuesDropRequestsApi {
    /// Creates a request to drop the contents of the queue in this connection.
    async fn create_drop_request(&self) -> Result<crate::v2_7_2::types::DropRequestDto, NifiError>;
    /// Cancels and/or removes a request to drop the contents of this connection.
    async fn remove_drop_request(
        &self,
        drop_request_id: &str,
    ) -> Result<crate::v2_7_2::types::DropRequestDto, NifiError>;
    /// Gets the current status of a drop request for the specified connection.
    async fn get_drop_request(
        &self,
        drop_request_id: &str,
    ) -> Result<crate::v2_7_2::types::DropRequestDto, NifiError>;
}
/// Sub-resource trait for the `flowfiles` sub-group.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait FlowFileQueuesFlowfilesApi {
    /// Gets a FlowFile from a Connection.
    async fn get_flow_file(
        &self,
        flowfile_uuid: &str,
        cluster_node_id: Option<&str>,
    ) -> Result<crate::v2_7_2::types::FlowFileDto, NifiError>;
    /// Gets the content for a FlowFile in a Connection.
    async fn download_flow_file_content(
        &self,
        flowfile_uuid: &str,
        client_id: Option<&str>,
        cluster_node_id: Option<&str>,
    ) -> Result<(), NifiError>;
}
/// Sub-resource trait for the `listing_requests` sub-group.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait FlowFileQueuesListingRequestsApi {
    /// Lists the contents of the queue in this connection.
    async fn create_flow_file_listing(
        &self,
    ) -> Result<crate::v2_7_2::types::ListingRequestDto, NifiError>;
    /// Cancels and/or removes a request to list the contents of this connection.
    async fn delete_listing_request(
        &self,
        listing_request_id: &str,
    ) -> Result<crate::v2_7_2::types::ListingRequestDto, NifiError>;
    /// Gets the current status of a listing request for the specified connection.
    async fn get_listing_request(
        &self,
        listing_request_id: &str,
    ) -> Result<crate::v2_7_2::types::ListingRequestDto, NifiError>;
}
/// The FlowFileQueues API.
#[allow(unused_variables, async_fn_in_trait, clippy::too_many_arguments)]
pub trait FlowFileQueuesApi {
    fn drop_requests<'b>(&'b self, id: &'b str) -> impl FlowFileQueuesDropRequestsApi + 'b;
    fn flowfiles<'b>(&'b self, id: &'b str) -> impl FlowFileQueuesFlowfilesApi + 'b;
    fn listing_requests<'b>(&'b self, id: &'b str) -> impl FlowFileQueuesListingRequestsApi + 'b;
}