Struct ProcessGroupsInputPortsApi 

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

Implementations

impl<'a> ProcessGroupsInputPortsApi<'a>

pub async fn get_input_ports(&self) -> Result<InputPortsEntity, NifiError>

Gets all input ports

Calls GET /nifi-api/process-groups/{id}/input-ports.

Errors

• 400: NiFi was unable to complete the request because it was invalid. The request should not be retried without modification.
• 401: Client could not be authenticated.
• 403: Client is not authorized to make this request.
• 404: The specified resource could not be found.
• 409: The request was valid but NiFi was not in the appropriate state to process it.

Permissions

Requires Read - /process-groups/{uuid}.

pub async fn create_input_port( &self, body: &PortEntity, ) -> Result<PortEntity, NifiError>

Creates an input port

Calls POST /nifi-api/process-groups/{id}/input-ports.

Parameters

• body: The input port configuration details.

Errors

• 400: NiFi was unable to complete the request because it was invalid. The request should not be retried without modification.
• 401: Client could not be authenticated.
• 403: Client is not authorized to make this request.
• 404: The specified resource could not be found.
• 409: The request was valid but NiFi was not in the appropriate state to process it.

Permissions

Requires Write - /process-groups/{uuid}.

Trait Implementations

impl ProcessGroupsInputPortsApi for ProcessGroupsInputPortsApi<'_>

async fn get_input_ports(&self) -> Result<InputPortsEntity, NifiError>

Gets all input ports

async fn create_input_port( &self, body: &PortEntity, ) -> Result<PortEntity, NifiError>

Creates an input port