Struct PurgeInstanceFilter 

pub struct PurgeInstanceFilter {
    pub created_time_from: Option<DateTime<Utc>>,
    pub created_time_to: Option<DateTime<Utc>>,
    pub runtime_status: Vec<OrchestrationStatus>,
}

Filter criteria for bulk-purging orchestration instances.

Build using the provided builder methods, then pass to TaskHubGrpcClient::purge_orchestrations_by_filter.

An empty filter matches all instances. Narrow the scope with with_created_time_from, with_created_time_to, and with_runtime_status.

Examples

use dapr_durabletask::api::{OrchestrationStatus, PurgeInstanceFilter};

let filter = PurgeInstanceFilter::new()
    .with_created_time_from(chrono::Utc::now() - chrono::Duration::hours(24))
    .with_runtime_status([OrchestrationStatus::Completed, OrchestrationStatus::Failed]);

Fields

created_time_from: Option<DateTime<Utc>>

Only purge instances created at or after this time.

created_time_to: Option<DateTime<Utc>>

Only purge instances created before or at this time.

runtime_status: Vec<OrchestrationStatus>

Only purge instances whose runtime status is in this list. An empty list matches all statuses.

Implementations

impl PurgeInstanceFilter

pub fn new() -> Self

Create an empty filter that matches all instances.

pub fn with_created_time_from(self, from: DateTime<Utc>) -> Self

Only purge instances created at or after the given time.

pub fn with_created_time_to(self, to: DateTime<Utc>) -> Self

Only purge instances created before or at the given time.

pub fn with_runtime_status( self, statuses: impl IntoIterator<Item = OrchestrationStatus>, ) -> Self

Only purge instances whose runtime status is in the provided list.

Trait Implementations

impl Clone for PurgeInstanceFilter

fn clone(&self) -> PurgeInstanceFilter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PurgeInstanceFilter

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

Formats the value using the given formatter.

impl Default for PurgeInstanceFilter

fn default() -> PurgeInstanceFilter

Returns the “default value” for a type.