Struct DynamicFlowFileQueuesApi 

pub struct DynamicFlowFileQueuesApi<'a> { /* private fields */ }

Dynamic dispatch wrapper for the FlowFileQueues API.

Implementations

impl<'a> DynamicFlowFileQueuesApi<'a>

pub async fn create_drop_request( &self, id: &str, ) -> Result<DropRequestDto, NifiError>

Creates a request to drop the contents of the queue in this connection.

pub async fn create_flow_file_listing( &self, id: &str, ) -> Result<ListingRequestDto, NifiError>

Lists the contents of the queue in this connection.

pub async fn delete_listing_request( &self, id: &str, listing_request_id: &str, ) -> Result<ListingRequestDto, NifiError>

Cancels and/or removes a request to list the contents of this connection.

pub async fn download_flow_file_content( &self, id: &str, flowfile_uuid: &str, client_id: Option<&str>, cluster_node_id: Option<&str>, ) -> Result<(), NifiError>

Gets the content for a FlowFile in a Connection.

pub async fn get_drop_request( &self, id: &str, drop_request_id: &str, ) -> Result<DropRequestDto, NifiError>

Gets the current status of a drop request for the specified connection.

pub async fn get_flow_file( &self, id: &str, flowfile_uuid: &str, cluster_node_id: Option<&str>, ) -> Result<FlowFileDto, NifiError>

Gets a FlowFile from a Connection.

pub async fn get_listing_request( &self, id: &str, listing_request_id: &str, ) -> Result<ListingRequestDto, NifiError>

Gets the current status of a listing request for the specified connection.

pub async fn remove_drop_request( &self, id: &str, drop_request_id: &str, ) -> Result<DropRequestDto, NifiError>

Cancels and/or removes a request to drop the contents of this connection.