Struct DataTransferTransactionsApiDispatch 

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

Sub-resource dispatch struct for DataTransferTransactionsApi.

Trait Implementations

impl DataTransferTransactionsApi for DataTransferTransactionsApiDispatch<'_>

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

Commit or cancel the specified transaction

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

Commit or cancel the specified transaction

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

Create a transaction to the specified output port or input port

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

Extend transaction TTL

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

Extend transaction TTL

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

Transfer flow files to the input port

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

Transfer flow files from the output port