Enum ProcessorsApiDispatch 

#[non_exhaustive]
pub enum ProcessorsApiDispatch<'a> {
    V2_6_0(V2_6_0ProcessorsApi<'a>),
    V2_7_2(V2_7_2ProcessorsApi<'a>),
    V2_8_0(V2_8_0ProcessorsApi<'a>),
}

Dynamic dispatch enum for the Processors API. Use via the ProcessorsApi trait.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

V2_6_0(V2_6_0ProcessorsApi<'a>)

V2_7_2(V2_7_2ProcessorsApi<'a>)

V2_8_0(V2_8_0ProcessorsApi<'a>)

Trait Implementations

impl ProcessorsApi for ProcessorsApiDispatch<'_>

fn bulletins<'b>(&'b self, id: &'b str) -> impl ProcessorsBulletinsApi + 'b

Returns a sub-resource accessor for config operations.

fn config<'b>(&'b self, id: &'b str) -> impl ProcessorsConfigApi + 'b

Returns a sub-resource accessor for config operations.

fn descriptors<'b>(&'b self, id: &'b str) -> impl ProcessorsDescriptorsApi + 'b

Returns a sub-resource accessor for config operations.

fn diagnostics<'b>(&'b self, id: &'b str) -> impl ProcessorsDiagnosticsApi + 'b

Returns a sub-resource accessor for config operations.

fn run_status<'b>(&'b self, id: &'b str) -> impl ProcessorsRunStatusApi + 'b

Returns a sub-resource accessor for config operations.

fn state<'b>(&'b self, id: &'b str) -> impl ProcessorsStateApi + 'b

Returns a sub-resource accessor for config operations.

fn threads<'b>(&'b self, id: &'b str) -> impl ProcessorsThreadsApi + 'b

Returns a sub-resource accessor for config operations.

async fn delete_processor( &self, id: &str, version: Option<&str>, client_id: Option<&str>, disconnected_node_acknowledged: Option<bool>, ) -> Result<ProcessorEntity, NifiError>

Deletes a processor

async fn get_processor(&self, id: &str) -> Result<ProcessorEntity, NifiError>

Gets a processor

async fn get_processor_run_status_details( &self, body: &RunStatusDetailsRequestEntity, ) -> Result<ProcessorsRunStatusDetailsEntity, NifiError>

Submits a query to retrieve the run status details of all processors that are in the given list of Processor IDs

async fn update_processor( &self, id: &str, body: &ProcessorEntity, ) -> Result<ProcessorEntity, NifiError>

Updates a processor