pub struct DynamicProvenanceEventsApi<'a> { /* private fields */ }Expand description
Dynamic dispatch wrapper for the ProvenanceEvents API.
Implementations§
Source§impl<'a> DynamicProvenanceEventsApi<'a>
impl<'a> DynamicProvenanceEventsApi<'a>
Sourcepub async fn get_input_content(
&self,
id: &str,
cluster_node_id: Option<&str>,
) -> Result<(), NifiError>
pub async fn get_input_content( &self, id: &str, cluster_node_id: Option<&str>, ) -> Result<(), NifiError>
Gets the input content for a provenance event
Sourcepub async fn get_latest_provenance_events(
&self,
component_id: &str,
limit: Option<i32>,
) -> Result<LatestProvenanceEventsDto, NifiError>
pub async fn get_latest_provenance_events( &self, component_id: &str, limit: Option<i32>, ) -> Result<LatestProvenanceEventsDto, NifiError>
Retrieves the latest cached Provenance Events for the specified component
Sourcepub async fn get_output_content(
&self,
id: &str,
cluster_node_id: Option<&str>,
) -> Result<(), NifiError>
pub async fn get_output_content( &self, id: &str, cluster_node_id: Option<&str>, ) -> Result<(), NifiError>
Gets the output content for a provenance event
Sourcepub async fn get_provenance_event(
&self,
id: &str,
cluster_node_id: Option<&str>,
) -> Result<ProvenanceEventDto, NifiError>
pub async fn get_provenance_event( &self, id: &str, cluster_node_id: Option<&str>, ) -> Result<ProvenanceEventDto, NifiError>
Gets a provenance event
Sourcepub async fn submit_replay(
&self,
body: &Value,
) -> Result<ProvenanceEventDto, NifiError>
pub async fn submit_replay( &self, body: &Value, ) -> Result<ProvenanceEventDto, NifiError>
Replays content from a provenance event
Sourcepub async fn submit_replay_latest_event(
&self,
body: &Value,
) -> Result<ReplayLastEventResponseEntity, NifiError>
pub async fn submit_replay_latest_event( &self, body: &Value, ) -> Result<ReplayLastEventResponseEntity, NifiError>
Replays content from a provenance event
Auto Trait Implementations§
impl<'a> Freeze for DynamicProvenanceEventsApi<'a>
impl<'a> !RefUnwindSafe for DynamicProvenanceEventsApi<'a>
impl<'a> Send for DynamicProvenanceEventsApi<'a>
impl<'a> Sync for DynamicProvenanceEventsApi<'a>
impl<'a> Unpin for DynamicProvenanceEventsApi<'a>
impl<'a> UnsafeUnpin for DynamicProvenanceEventsApi<'a>
impl<'a> !UnwindSafe for DynamicProvenanceEventsApi<'a>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more