Skip to main content

DynamicClient

Struct DynamicClient 

Source
pub struct DynamicClient { /* private fields */ }
Expand description

A dynamic NiFi client that detects the server version at connect time and dispatches API calls to the correct version’s generated code.

Implementations§

Source§

impl DynamicClient

Source

pub async fn from_client(client: NifiClient) -> Result<Self, NifiError>

Wrap an existing NifiClient and detect the NiFi server version via GET /flow/about.

Source

pub fn detected_version(&self) -> DetectedVersion

Returns the detected NiFi server version.

Source

pub fn inner(&self) -> &NifiClient

Returns a reference to the underlying NifiClient.

Source

pub fn inner_mut(&mut self) -> &mut NifiClient

Returns a mutable reference to the underlying NifiClient.

Source

pub async fn login( &mut self, username: &str, password: &str, ) -> Result<(), NifiError>

Authenticate with the NiFi instance.

Source

pub async fn logout(&mut self) -> Result<(), NifiError>

Log out from the NiFi instance.

Source

pub fn access_api(&self) -> DynamicAccessApi<'_>

Access the Access API with dynamic dispatch.

Source

pub fn authentication_api(&self) -> DynamicAuthenticationApi<'_>

Access the Authentication API with dynamic dispatch.

Source

pub fn connections_api(&self) -> DynamicConnectionsApi<'_>

Access the Connections API with dynamic dispatch.

Source

pub fn controller_api(&self) -> DynamicControllerApi<'_>

Access the Controller API with dynamic dispatch.

Source

pub fn controller_services_api(&self) -> DynamicControllerServicesApi<'_>

Access the Controller Services API with dynamic dispatch.

Source

pub fn counters_api(&self) -> DynamicCountersApi<'_>

Access the Counters API with dynamic dispatch.

Source

pub fn datatransfer_api(&self) -> DynamicDataTransferApi<'_>

Access the DataTransfer API with dynamic dispatch.

Source

pub fn flow_api(&self) -> DynamicFlowApi<'_>

Access the Flow API with dynamic dispatch.

Source

pub fn flowfilequeues_api(&self) -> DynamicFlowFileQueuesApi<'_>

Access the FlowFileQueues API with dynamic dispatch.

Source

pub fn funnels_api(&self) -> DynamicFunnelsApi<'_>

Access the Funnels API with dynamic dispatch.

Source

pub fn inputports_api(&self) -> DynamicInputPortsApi<'_>

Access the InputPorts API with dynamic dispatch.

Source

pub fn labels_api(&self) -> DynamicLabelsApi<'_>

Access the Labels API with dynamic dispatch.

Source

pub fn outputports_api(&self) -> DynamicOutputPortsApi<'_>

Access the OutputPorts API with dynamic dispatch.

Source

pub fn parametercontexts_api(&self) -> DynamicParameterContextsApi<'_>

Access the ParameterContexts API with dynamic dispatch.

Source

pub fn parameterproviders_api(&self) -> DynamicParameterProvidersApi<'_>

Access the ParameterProviders API with dynamic dispatch.

Source

pub fn policies_api(&self) -> DynamicPoliciesApi<'_>

Access the Policies API with dynamic dispatch.

Source

pub fn processgroups_api(&self) -> DynamicProcessGroupsApi<'_>

Access the ProcessGroups API with dynamic dispatch.

Source

pub fn processors_api(&self) -> DynamicProcessorsApi<'_>

Access the Processors API with dynamic dispatch.

Source

pub fn provenance_api(&self) -> DynamicProvenanceApi<'_>

Access the Provenance API with dynamic dispatch.

Source

pub fn provenanceevents_api(&self) -> DynamicProvenanceEventsApi<'_>

Access the ProvenanceEvents API with dynamic dispatch.

Source

pub fn remoteprocessgroups_api(&self) -> DynamicRemoteProcessGroupsApi<'_>

Access the RemoteProcessGroups API with dynamic dispatch.

Source

pub fn reportingtasks_api(&self) -> DynamicReportingTasksApi<'_>

Access the ReportingTasks API with dynamic dispatch.

Source

pub fn resources_api(&self) -> DynamicResourcesApi<'_>

Access the Resources API with dynamic dispatch.

Source

pub fn sitetosite_api(&self) -> DynamicSiteToSiteApi<'_>

Access the SiteToSite API with dynamic dispatch.

Source

pub fn snippets_api(&self) -> DynamicSnippetsApi<'_>

Access the Snippets API with dynamic dispatch.

Source

pub fn systemdiagnostics_api(&self) -> DynamicSystemDiagnosticsApi<'_>

Access the SystemDiagnostics API with dynamic dispatch.

Source

pub fn tenants_api(&self) -> DynamicTenantsApi<'_>

Access the Tenants API with dynamic dispatch.

Source

pub fn versions_api(&self) -> DynamicVersionsApi<'_>

Access the Versions API with dynamic dispatch.

Trait Implementations§

Source§

impl Debug for DynamicClient

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more