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 execution;
11mod worker;
12
13pub use backend::DistributedBackend;
14pub use capabilities::{
15    toolset_schema_digest, DistributedCapabilityError, DistributedCapabilityRegistry,
16    ResolvedDistributedCapabilities, ResolvedDistributedCheckpointExtension,
17};
18pub use checkpoint_worker::{
19    DistributedCheckpointProgress, DistributedCycleExecutor, DistributedCycleOutcome,
20    DistributedDeliveryMetadata,
21};
22pub use contract::{
23    CapabilityRef, DistributedCapabilities, DistributedCheckpointConfig,
24    DistributedCheckpointExtensionRef, DistributedRunEnvelope, DistributedToolPolicy, ToolsetRef,
25    DEFAULT_CYCLE_NAME, DEFAULT_LEASE_DURATION_MS, DEFAULT_TOOLSET_ID,
26    DEFAULT_TOOLSET_SCHEMA_DIGEST, DEFAULT_TOOLSET_VERSION, DISTRIBUTED_RUN_SCHEMA_VERSION,
27};
28pub use dispatch::{
29    CycleDispatchResult, CycleDispatcher, DISTRIBUTED_WORKER_RESPONSE_SCHEMA_VERSION,
30};
31pub use worker::DistributedCycleWorker;