Struct DynamicDataTransferApi 

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

Dynamic dispatch wrapper for the DataTransfer API.

Implementations

impl<'a> DynamicDataTransferApi<'a>

pub async fn commit_input_port_transaction( &self, port_id: &str, transaction_id: &str, response_code: i32, ) -> Result<TransactionResultEntity, NifiError>

Commit or cancel the specified transaction

pub async fn commit_output_port_transaction( &self, port_id: &str, transaction_id: &str, response_code: i32, checksum: &str, ) -> Result<TransactionResultEntity, NifiError>

Commit or cancel the specified transaction

pub async fn create_port_transaction( &self, port_id: &str, port_type: &str, ) -> Result<TransactionResultEntity, NifiError>

Create a transaction to the specified output port or input port

pub async fn extend_input_port_transaction_t_t_l( &self, port_id: &str, transaction_id: &str, ) -> Result<TransactionResultEntity, NifiError>

Extend transaction TTL

pub async fn extend_output_port_transaction_t_t_l( &self, port_id: &str, transaction_id: &str, ) -> Result<TransactionResultEntity, NifiError>

Extend transaction TTL

pub async fn receive_flow_files( &self, port_id: &str, transaction_id: &str, filename: Option<&str>, data: Vec<u8>, ) -> Result<(), NifiError>

Transfer flow files to the input port

pub async fn transfer_flow_files( &self, port_id: &str, transaction_id: &str, ) -> Result<(), NifiError>

Transfer flow files from the output port