Skip to main content

vv_agent/runtime/backends/
distributed.rs

1#[cfg(feature = "apalis")]
2pub mod apalis;
3mod backend;
4mod capabilities;
5mod checkpoint_loop;
6mod checkpoint_worker;
7mod contract;
8mod contract_helpers;
9mod dispatch;
10mod driver;
11mod execution;
12mod worker;
13
14pub use backend::DistributedBackend;
15pub use capabilities::{
16    toolset_schema_digest, DistributedCapabilityError, DistributedCapabilityRegistry,
17    ResolvedDistributedCapabilities, ResolvedDistributedCheckpointExtension,
18};
19pub use checkpoint_worker::{
20    DistributedCheckpointProgress, DistributedCycleExecutor, DistributedCycleOutcome,
21    DistributedDeliveryMetadata,
22};
23pub use contract::{
24    CapabilityRef, DistributedCapabilities, DistributedCheckpointConfig,
25    DistributedCheckpointExtensionRef, DistributedRunEnvelope, DistributedToolPolicy, ToolsetRef,
26    DEFAULT_CYCLE_NAME, DEFAULT_LEASE_DURATION_MS, DEFAULT_TOOLSET_ID,
27    DEFAULT_TOOLSET_SCHEMA_DIGEST, DEFAULT_TOOLSET_VERSION, DISTRIBUTED_RUN_SCHEMA_VERSION,
28};
29pub use dispatch::{
30    CycleDispatchResult, CycleDispatcher, DISTRIBUTED_WORKER_RESPONSE_SCHEMA_VERSION,
31};
32pub use driver::{
33    CycleEnqueuer, DistributedAdvanceDecision, DistributedDeliveryOutcome, DistributedRunHandle,
34    DistributedWaitReason,
35};
36pub use worker::DistributedCycleWorker;