Struct CosmosDBProvider 

pub struct CosmosDBProvider { /* private fields */ }

CosmosDB provider for duroxide. Implements both Provider and ProviderAdmin traits.

Implementations

impl CosmosDBProvider

pub async fn new( endpoint: &str, key: &str, database: &str, ) -> Result<Self, ProviderError>

Create a new CosmosDB provider with default settings.

pub async fn new_with_config( config: CosmosDBProviderConfig, ) -> Result<Self, ProviderError>

Create a new CosmosDB provider with custom configuration.

pub async fn new_with_container( endpoint: &str, key: &str, database: &str, container: &str, ) -> Result<Self, ProviderError>

Create with a specific container name (for test isolation).

pub fn set_outbox_fault_injector(&mut self, injector: OutboxFaultInjector)

Set a fault injector for outbox delivery testing. When set, the next N best-effort deliveries will be skipped, forcing the background reconciler to deliver the intents.

pub async fn cleanup(&self) -> Result<(), ProviderError>

Cleanup: delete the container. Used in tests.

Trait Implementations

impl Clone for CosmosDBProvider

fn clone(&self) -> CosmosDBProvider

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Provider for CosmosDBProvider

fn name(&self) -> &str

Returns the name of this provider implementation.

fn version(&self) -> &str

Returns the version of this provider implementation.

fn fetch_orchestration_item<'life0, 'life1, 'async_trait>( &'life0 self, lock_timeout: Duration, _poll_timeout: Duration, filter: Option<&'life1 DispatcherCapabilityFilter>, ) -> Pin<Box<dyn Future<Output = Result<Option<(OrchestrationItem, String, u32)>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch the next orchestration work item atomically.

fn ack_orchestration_item<'life0, 'life1, 'async_trait>( &'life0 self, lock_token: &'life1 str, execution_id: u64, history_delta: Vec<Event>, worker_items: Vec<WorkItem>, orchestrator_items: Vec<WorkItem>, metadata: ExecutionMetadata, cancelled_activities: Vec<ScheduledActivityIdentifier>, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Acknowledge successful orchestration processing atomically.

fn abandon_orchestration_item<'life0, 'life1, 'async_trait>( &'life0 self, lock_token: &'life1 str, delay: Option<Duration>, ignore_attempt: bool, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Abandon orchestration processing (used for errors/retries).

fn read<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read the full history for the latest execution of an instance.

fn read_with_execution<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, execution_id: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read the full event history for a specific execution within an instance.

fn append_with_execution<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, execution_id: u64, new_events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Append events to a specific execution.

fn enqueue_for_worker<'life0, 'async_trait>( &'life0 self, item: WorkItem, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Enqueue an activity execution request.

fn fetch_work_item<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, lock_timeout: Duration, _poll_timeout: Duration, session: Option<&'life1 SessionFetchConfig>, tag_filter: &'life2 TagFilter, ) -> Pin<Box<dyn Future<Output = Result<Option<(WorkItem, String, u32)>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Dequeue a single work item with peek-lock semantics.

fn ack_work_item<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, completion: Option<WorkItem>, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Acknowledge successful processing of a work item.

fn renew_work_item_lock<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, extend_for: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Renew the lock on a worker queue item.

fn renew_session_lock<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, owner_ids: &'life1 [&'life2 str], extend_for: Duration, idle_timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<usize, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Heartbeat all non-idle sessions owned by the given workers.

fn cleanup_orphaned_sessions<'life0, 'async_trait>( &'life0 self, _idle_timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<usize, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sweep orphaned session entries.

fn abandon_work_item<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, delay: Option<Duration>, ignore_attempt: bool, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Abandon work item processing (release lock without completing).

fn renew_orchestration_item_lock<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, extend_for: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Renew the lock on an orchestration item.

fn enqueue_for_orchestrator<'life0, 'async_trait>( &'life0 self, item: WorkItem, delay: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<(), ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Enqueue a work item to the orchestrator queue.

fn as_management_capability(&self) -> Option<&dyn ProviderAdmin>

Check if this provider implements management capabilities.

fn get_custom_status<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, last_seen_version: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<(Option<String>, u64)>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Lightweight check for custom status changes.

fn get_kv_value<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, instance_id: &'life1 str, key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Read a single KV entry for the given instance.

fn get_kv_all_values<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, String>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read all KV entries for the given instance.

fn get_instance_stats<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SystemStats>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Compute runtime introspection stats for an orchestration instance.

impl ProviderAdmin for CosmosDBProvider

fn list_instances<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all known instance IDs.

fn list_instances_by_status<'life0, 'life1, 'async_trait>( &'life0 self, status: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List instances matching a status filter.

fn list_executions<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u64>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List all execution IDs for an instance.

fn read_history_with_execution_id<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, execution_id: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read the full event history for a specific execution within an instance.

fn read_history<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Read the full event history for the latest execution of an instance.

fn latest_execution_id<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the latest (current) execution ID for an instance.

fn get_instance_info<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<InstanceInfo, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get comprehensive information about an instance.

fn get_execution_info<'life0, 'life1, 'async_trait>( &'life0 self, instance: &'life1 str, execution_id: u64, ) -> Pin<Box<dyn Future<Output = Result<ExecutionInfo, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get detailed information about a specific execution.

fn get_system_metrics<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SystemMetrics, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get system-wide metrics for the orchestration engine.

fn get_queue_depths<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<QueueDepths, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the current depths of the internal work queues.

fn list_children<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List direct children of an instance.

fn get_parent_id<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the parent instance ID.

fn delete_instances_atomic<'life0, 'life1, 'async_trait>( &'life0 self, ids: &'life1 [String], force: bool, ) -> Pin<Box<dyn Future<Output = Result<DeleteInstanceResult, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomically delete a batch of instances.

fn delete_instance_bulk<'life0, 'async_trait>( &'life0 self, filter: InstanceFilter, ) -> Pin<Box<dyn Future<Output = Result<DeleteInstanceResult, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete multiple orchestration instances matching the filter criteria.

fn prune_executions<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, options: PruneOptions, ) -> Pin<Box<dyn Future<Output = Result<PruneResult, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Prune old executions from a single instance.

fn prune_executions_bulk<'life0, 'async_trait>( &'life0 self, filter: InstanceFilter, options: PruneOptions, ) -> Pin<Box<dyn Future<Output = Result<PruneResult, ProviderError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Prune old executions from multiple instances matching the filter.

fn get_instance_tree<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<InstanceTree, ProviderError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Get the full instance tree rooted at the given instance.

fn delete_instance<'life0, 'life1, 'async_trait>( &'life0 self, instance_id: &'life1 str, force: bool, ) -> Pin<Box<dyn Future<Output = Result<DeleteInstanceResult, ProviderError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Delete a single orchestration instance and all its associated data.