Struct DynamicClient 

pub struct DynamicClient { /* private fields */ }

DynamicClient — the new canonical dispatch path. Reachable only via the #[doc(hidden)] dynamic re-export in Phase 4a.

Implementations

impl DynamicClient

pub fn access(&self) -> Access<'_>

Access the Access API (canonical dynamic).

pub fn authentication(&self) -> Authentication<'_>

Access the Authentication API (canonical dynamic).

pub fn connections(&self) -> Connections<'_>

Access the Connections API (canonical dynamic).

pub fn connectors(&self) -> Connectors<'_>

Access the Connectors API (canonical dynamic).

pub fn controller(&self) -> Controller<'_>

Access the Controller API (canonical dynamic).

pub fn controller_services(&self) -> ControllerServices<'_>

Access the Controller Services API (canonical dynamic).

pub fn counters(&self) -> Counters<'_>

Access the Counters API (canonical dynamic).

pub fn datatransfer(&self) -> DataTransfer<'_>

Access the DataTransfer API (canonical dynamic).

pub fn flow(&self) -> Flow<'_>

Access the Flow API (canonical dynamic).

pub fn flowfilequeues(&self) -> FlowFileQueues<'_>

Access the FlowFileQueues API (canonical dynamic).

pub fn funnels(&self) -> Funnels<'_>

Access the Funnels API (canonical dynamic).

pub fn inputports(&self) -> InputPorts<'_>

Access the InputPorts API (canonical dynamic).

pub fn labels(&self) -> Labels<'_>

Access the Labels API (canonical dynamic).

pub fn outputports(&self) -> OutputPorts<'_>

Access the OutputPorts API (canonical dynamic).

pub fn parametercontexts(&self) -> ParameterContexts<'_>

Access the ParameterContexts API (canonical dynamic).

pub fn parameterproviders(&self) -> ParameterProviders<'_>

Access the ParameterProviders API (canonical dynamic).

pub fn policies(&self) -> Policies<'_>

Access the Policies API (canonical dynamic).

pub fn processgroups(&self) -> ProcessGroups<'_>

Access the ProcessGroups API (canonical dynamic).

pub fn processors(&self) -> Processors<'_>

Access the Processors API (canonical dynamic).

pub fn provenance(&self) -> Provenance<'_>

Access the Provenance API (canonical dynamic).

pub fn provenanceevents(&self) -> ProvenanceEvents<'_>

Access the ProvenanceEvents API (canonical dynamic).

pub fn remoteprocessgroups(&self) -> RemoteProcessGroups<'_>

Access the RemoteProcessGroups API (canonical dynamic).

pub fn reportingtasks(&self) -> ReportingTasks<'_>

Access the ReportingTasks API (canonical dynamic).

pub fn resources(&self) -> Resources<'_>

Access the Resources API (canonical dynamic).

pub fn sitetosite(&self) -> SiteToSite<'_>

Access the SiteToSite API (canonical dynamic).

pub fn snippets(&self) -> Snippets<'_>

Access the Snippets API (canonical dynamic).

pub fn systemdiagnostics(&self) -> SystemDiagnostics<'_>

Access the SystemDiagnostics API (canonical dynamic).

pub fn tenants(&self) -> Tenants<'_>

Access the Tenants API (canonical dynamic).

pub fn versions(&self) -> Versions<'_>

Access the Versions API (canonical dynamic).

impl DynamicClient

pub fn new(client: NifiClient) -> Self

Wrap a NifiClient. Uses the default VersionResolutionStrategy. Version detection happens lazily on the first call to a method that consults require_endpoint.

pub fn with_strategy( client: NifiClient, strategy: VersionResolutionStrategy, ) -> Self

Wrap a NifiClient with a specific VersionResolutionStrategy.

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

Async constructor that eagerly detects the version and discovers cluster topology. Mirrors the legacy DynamicClient::from_client.

pub fn inner(&self) -> &NifiClient

Underlying NifiClient used by generated methods to issue HTTP requests.

pub fn strategy(&self) -> VersionResolutionStrategy

The configured VersionResolutionStrategy.

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

Authenticate and detect the server version. Mirrors the legacy DynamicClient::login.

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

Log out the current session.

pub async fn token(&self) -> Option<String>

Return the current bearer token, if any.

Useful for persisting the token between process restarts. See NifiClient::token for details.

pub async fn set_token(&self, token: String)

Restore a previously obtained bearer token.

See NifiClient::set_token for details.

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

Re-authenticate using the configured AuthProvider.

See NifiClient::authenticate for details.

pub async fn detect_version(&self) -> Result<DetectedVersion, NifiError>

Detect the NiFi server version via GET /flow/about. Idempotent — subsequent calls return the cached result. Honors the configured VersionResolutionStrategy.

pub fn detected_version(&self) -> Option<DetectedVersion>

Currently-detected version, or None if detect_version has not yet completed successfully.

pub fn detected_version_str(&self) -> String

Currently-detected version string, or an empty string if detect_version has not yet completed. Returned as an owned String so the generated URL-building code can pass it by value into the UnsupportedQueryParam error constructor without cloning.

pub fn cluster_node_id(&self) -> Option<&str>

The cluster node ID of the connected (primary) node, if this NiFi instance is part of a cluster. None for standalone instances or if cluster discovery has not yet been performed.

pub async fn require_endpoint( &self, endpoint: Endpoint, ) -> Result<(), NifiError>

Returns Ok(()) if endpoint is supported by the currently-detected server version. Detects the version lazily if not yet done.

pub fn supports(&self, endpoint: Endpoint) -> bool

Synchronous variant: returns true if endpoint is supported by the currently-detected version. Returns false if no version has been detected yet (callers should detect_version().await first).

Trait Implementations

impl Debug for DynamicClient

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

Formats the value using the given formatter.