Enum ControllerApiDispatch 

#[non_exhaustive]
pub enum ControllerApiDispatch<'a> {
    V2_6_0(V2_6_0ControllerApi<'a>),
    V2_7_2(V2_7_2ControllerApi<'a>),
    V2_8_0(V2_8_0ControllerApi<'a>),
}

Dynamic dispatch enum for the Controller API. Use via the ControllerApi 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_0ControllerApi<'a>)

V2_7_2(V2_7_2ControllerApi<'a>)

V2_8_0(V2_8_0ControllerApi<'a>)

Trait Implementations

impl ControllerApi for ControllerApiDispatch<'_>

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

Returns a sub-resource accessor for config operations.

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

Returns a sub-resource accessor for config operations.

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

Returns a sub-resource accessor for config operations.

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

Returns a sub-resource accessor for config operations.

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

Returns a sub-resource accessor for config operations.

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

Returns a sub-resource accessor for config operations.

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

Returns a sub-resource accessor for config operations.

async fn create_bulletin( &self, body: &BulletinEntity, ) -> Result<BulletinEntity, NifiError>

Creates a new bulletin

async fn create_controller_service( &self, body: &ControllerServiceEntity, ) -> Result<ControllerServiceEntity, NifiError>

Creates a new controller service

async fn create_flow_analysis_rule( &self, body: &FlowAnalysisRuleEntity, ) -> Result<FlowAnalysisRuleEntity, NifiError>

Creates a new flow analysis rule

async fn create_flow_registry_client( &self, body: &FlowRegistryClientEntity, ) -> Result<FlowRegistryClientEntity, NifiError>

Creates a new flow registry client

async fn create_parameter_provider( &self, body: &ParameterProviderEntity, ) -> Result<ParameterProviderEntity, NifiError>

Creates a new parameter provider

async fn create_reporting_task( &self, body: &ReportingTaskEntity, ) -> Result<ReportingTaskEntity, NifiError>

Creates a new reporting task

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

Deletes a flow registry client

async fn delete_history(&self, end_date: &str) -> Result<HistoryDto, NifiError>

Purges history

async fn delete_nar( &self, id: &str, disconnected_node_acknowledged: Option<bool>, force: Option<bool>, ) -> Result<NarSummaryDto, NifiError>

Deletes an installed NAR

async fn delete_node(&self, id: &str) -> Result<NodeDto, NifiError>

Removes a node from the cluster

async fn get_cluster(&self) -> Result<ClusterDto, NifiError>

Gets the contents of the cluster

async fn get_controller_config( &self, ) -> Result<ControllerConfigurationEntity, NifiError>

Retrieves the configuration for this NiFi Controller

async fn get_flow_analysis_rule( &self, id: &str, ) -> Result<FlowAnalysisRuleEntity, NifiError>

Gets a flow analysis rule

async fn get_flow_analysis_rules( &self, ) -> Result<FlowAnalysisRulesEntity, NifiError>

Gets all flow analysis rules

async fn get_flow_registry_client( &self, id: &str, ) -> Result<FlowRegistryClientEntity, NifiError>

Gets a flow registry client

async fn get_flow_registry_clients( &self, ) -> Result<FlowRegistryClientsEntity, NifiError>

Gets the listing of available flow registry clients

async fn get_nar_summaries(&self) -> Result<NarSummariesEntity, NifiError>

Retrieves summary information for installed NARs

async fn get_nar_summary(&self, id: &str) -> Result<NarDetailsEntity, NifiError>

Retrieves the summary information for the NAR with the given identifier

async fn get_node(&self, id: &str) -> Result<NodeDto, NifiError>

Gets a node in the cluster

async fn get_node_status_history( &self, ) -> Result<ComponentHistoryDto, NifiError>

Gets status history for the node

async fn get_registry_client_types( &self, ) -> Result<FlowRegistryClientTypesEntity, NifiError>

Retrieves the types of flow that this NiFi supports

async fn import_reporting_task_snapshot( &self, body: &VersionedReportingTaskImportRequestEntity, ) -> Result<VersionedReportingTaskImportResponseEntity, NifiError>

Imports a reporting task snapshot

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

Deletes a flow analysis rule

async fn update_controller_config( &self, body: &ControllerConfigurationEntity, ) -> Result<ControllerConfigurationEntity, NifiError>

Retrieves the configuration for this NiFi

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

Updates a flow analysis rule

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

Updates a flow registry client

async fn update_node( &self, id: &str, body: &NodeEntity, ) -> Result<NodeDto, NifiError>

Updates a node in the cluster

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

Uploads a NAR and requests for it to be installed