oris_execution_runtime/
lib.rs

1//! Execution runtime control-plane, scheduler, and durable runtime repositories.
2
3#[cfg(feature = "execution-server")]
4pub mod api_contract;
5#[cfg(feature = "execution-server")]
6pub mod api_errors;
7#[cfg(all(feature = "execution-server", feature = "sqlite-persistence"))]
8pub mod api_idempotency;
9#[cfg(feature = "execution-server")]
10pub mod api_models;
11#[cfg(feature = "sqlite-persistence")]
12pub mod backend_config;
13#[cfg(feature = "execution-server")]
14pub mod graph_bridge;
15pub mod lease;
16pub mod models;
17pub mod observability;
18#[cfg(feature = "kernel-postgres")]
19pub mod postgres_runtime_repository;
20pub mod recovery;
21pub mod repository;
22pub mod scheduler;
23#[cfg(feature = "sqlite-persistence")]
24pub mod sqlite_runtime_repository;
25
26#[cfg(feature = "execution-server")]
27pub use api_contract::{
28    canonical_runtime_api_contract_path, generate_runtime_api_contract,
29    runtime_api_contract_pretty_json, write_runtime_api_contract, RUNTIME_API_CONTRACT_DOC_PATH,
30};
31#[cfg(feature = "execution-server")]
32pub use api_errors::ApiError;
33#[cfg(all(feature = "execution-server", feature = "sqlite-persistence"))]
34pub use api_idempotency::{IdempotencyRecord, SqliteIdempotencyStore};
35#[cfg(feature = "execution-server")]
36pub use api_models::{
37    ApiEnvelope, ApiMeta, AttemptRetryHistoryItem, AttemptRetryHistoryResponse, AuditLogItem,
38    AuditLogListResponse, CancelJobRequest, CancelJobResponse, CheckpointInspectResponse,
39    DeadLetterItem, DeadLetterListResponse, DeadLetterReplayResponse, InterruptDetailResponse,
40    InterruptListResponse, JobDetailResponse, JobHistoryItem, JobHistoryResponse, JobStateResponse,
41    JobTimelineItem, JobTimelineResponse, ListAuditLogsQuery, ListDeadLettersQuery,
42    ListInterruptsQuery, ListJobsQuery, ListJobsResponse, RejectInterruptRequest, ReplayJobRequest,
43    ResumeInterruptRequest, ResumeJobRequest, RetryPolicyRequest, RunJobRequest, RunJobResponse,
44    TimelineExportResponse, TimeoutPolicyRequest, TraceContextResponse, WorkerAckRequest,
45    WorkerAckResponse, WorkerExtendLeaseRequest, WorkerHeartbeatRequest, WorkerLeaseResponse,
46    WorkerPollRequest, WorkerPollResponse, WorkerReportStepRequest,
47};
48#[cfg(feature = "sqlite-persistence")]
49pub use backend_config::{RuntimeStorageBackend, RuntimeStorageConfig};
50#[cfg(feature = "execution-server")]
51pub use graph_bridge::{
52    ExecutionCheckpointView, ExecutionGraphBridge, ExecutionGraphBridgeError,
53    ExecutionGraphBridgeErrorKind, ExecutionInvokeView, ExecutionStateView,
54};
55pub use lease::{LeaseConfig, LeaseManager, LeaseTickResult, RepositoryLeaseManager, WorkerLease};
56pub use models::{
57    AttemptDispatchRecord, AttemptExecutionStatus, InterruptRecord, LeaseRecord, RunRecord,
58    RunRuntimeStatus,
59};
60pub use observability::{KernelObservability, RejectionReason};
61#[cfg(feature = "kernel-postgres")]
62pub use postgres_runtime_repository::PostgresRuntimeRepository;
63pub use recovery::{CrashRecoveryPipeline, RecoveryContext, RecoveryStep};
64pub use repository::RuntimeRepository;
65pub use scheduler::{DispatchContext, SchedulerDecision, SkeletonScheduler};
66#[cfg(feature = "sqlite-persistence")]
67pub use sqlite_runtime_repository::SqliteRuntimeRepository;
oris_execution_runtime/lib.rs

oris_execution_runtime/
lib.rs
