[−][src]Struct azure_functions_durable::Client
Represents the Durable Functions HTTP client.
Methods
impl Client
[src]
pub fn new(status_query_url: &str) -> Self
[src]
Creates a new client from the given status query URL.
pub fn task_hub(&self) -> &str
[src]
Gets the task hub associated with the client.
pub async fn instance_status<'_, '_>(
&'_ self,
instance_id: &'_ str,
show_history: bool,
show_history_output: bool,
show_input: bool
) -> Result<OrchestrationStatus>
[src]
&'_ self,
instance_id: &'_ str,
show_history: bool,
show_history_output: bool,
show_input: bool
) -> Result<OrchestrationStatus>
Gets the status of an orchestration instance.
pub async fn query_instances<'_, I>(
&'_ self,
created_time_from: Option<DateTime<Utc>>,
created_time_to: Option<DateTime<Utc>>,
runtime_statuses: Option<I>,
top: Option<u32>,
show_history: bool,
show_history_output: bool,
show_input: bool
) -> Result<Vec<OrchestrationStatus>> where
I: Iterator<Item = OrchestrationRuntimeStatus>,
[src]
&'_ self,
created_time_from: Option<DateTime<Utc>>,
created_time_to: Option<DateTime<Utc>>,
runtime_statuses: Option<I>,
top: Option<u32>,
show_history: bool,
show_history_output: bool,
show_input: bool
) -> Result<Vec<OrchestrationStatus>> where
I: Iterator<Item = OrchestrationRuntimeStatus>,
Queries the status for instances in a given date range or with runtime status.
pub async fn purge_history<'_, '_>(&'_ self, instance_id: &'_ str) -> Result<()>
[src]
Purges the history of the given orchestration instance.
pub async fn purge_history_by_query<'_, I>(
&'_ self,
created_time_from: Option<DateTime<Utc>>,
created_time_to: Option<DateTime<Utc>>,
runtime_statuses: Option<I>
) -> Result<u32> where
I: Iterator<Item = OrchestrationRuntimeStatus>,
[src]
&'_ self,
created_time_from: Option<DateTime<Utc>>,
created_time_to: Option<DateTime<Utc>>,
runtime_statuses: Option<I>
) -> Result<u32> where
I: Iterator<Item = OrchestrationRuntimeStatus>,
Purges the history of orchestrations matching the given date range or runtime statuses.
pub async fn raise_event<'_, '_, '_, D>(
&'_ self,
instance_id: &'_ str,
event_name: &'_ str,
event_data: D
) -> Result<()> where
D: Into<Value>,
[src]
&'_ self,
instance_id: &'_ str,
event_name: &'_ str,
event_data: D
) -> Result<()> where
D: Into<Value>,
Raises an event for the given orchestration instance.
pub async fn rewind<'_, '_, '_>(
&'_ self,
instance_id: &'_ str,
reason: &'_ str
) -> Result<()>
[src]
&'_ self,
instance_id: &'_ str,
reason: &'_ str
) -> Result<()>
Restores a failed orchestration instance into a running state by replaying the most recent failed operations.
pub async fn start_new<'_, '_, '_, D>(
&'_ self,
function_name: &'_ str,
instance_id: Option<&'_ str>,
input: D
) -> Result<OrchestrationData> where
D: Into<Value>,
[src]
&'_ self,
function_name: &'_ str,
instance_id: Option<&'_ str>,
input: D
) -> Result<OrchestrationData> where
D: Into<Value>,
Starts a new orchestration by calling the given orchestration function.
pub async fn terminate<'_, '_, '_>(
&'_ self,
instance_id: &'_ str,
reason: &'_ str
) -> Result<()>
[src]
&'_ self,
instance_id: &'_ str,
reason: &'_ str
) -> Result<()>
Terminates a running orchestration instance.
Auto Trait Implementations
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl !UnwindSafe for Client
impl !RefUnwindSafe for Client
Blanket Implementations
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> From<T> for T
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,