algeon-query-runtime 0.1.0

Native query runtime, lifecycle, ledger, and observation owners.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102

//! Runtime, memory, boundary, and reservation contracts for native execution.
//!
//! Values defined in this module govern observable execution behavior across crates.
//! Policy enum string representations, reservation fact keys, and retry fact keys
//! are exposed to tests, telemetry reports, and adapter diagnostics.
//! These identifiers constitute stable diagnostic contracts and are updated
//! in coordination with reporting schemas.

mod allocator_correlation;
mod attempt_domain;
mod backend_close;
mod backend_core;
mod backend_lifecycle;
mod backend_metrics;
pub mod cache;
mod cache_fill;
mod context;
mod deadline;
mod execution_policy;
pub(crate) mod gpu;
mod gpu_execution_pool;
mod io_lifecycle;
mod memory_domain;
mod object_store;
mod observation_completion;
mod process_exit;
mod query_service;
mod reservation;
/// Frontend-neutral GPU-resident data and reusable build handles.
pub mod resident;
mod service_stream;
#[doc(hidden)]
pub mod source_identity;
mod stream_cleanup;
mod supervised_worker;
#[cfg(test)]
mod tests;

#[doc(hidden)]
pub use attempt_domain::AttemptStreamProviderRoute;
#[cfg(feature = "qualification")]
pub use backend_core::GpuBackendFaultInjector;
pub use backend_core::{
    GpuBackendCloseSnapshot, GpuBackendConfig, GpuBackendCore, GpuBackendDeviceConfig,
    GpuBackendDeviceInstallationBounds, GpuBackendDeviceProfile, GpuBackendDeviceStartupRecord, GpuBackendSession,
    GpuDeviceCapacityProbe, GpuDeviceMemoryLimit, GpuMemoryFraction, GpuMemoryOwnership, ValidatedGpuBackendConfig,
    probe_device_capacity,
};
pub(crate) use backend_core::{GpuBackendConstructionCheckpoint, GpuBackendConstructionProbe};
#[cfg(any(test, feature = "test-hooks"))]
pub(crate) use backend_lifecycle::BackendLifecycle;
pub(crate) use backend_lifecycle::ObservationPermit;
pub use backend_metrics::{
    BACKEND_ATTEMPT_DURATION_BUCKET_COUNT, BACKEND_METRIC_DEVICE_CAPACITY, BackendAdmissionHealth,
    BackendAdmissionMetricsSnapshot, BackendAttemptDisposition, BackendAttemptDuration, BackendAttemptMetricsSnapshot,
    BackendAttemptOutcome, BackendDeviceMetricsSnapshot, BackendHistogramProjection, BackendHistogramSnapshot,
    BackendMetricAttribute, BackendMetricAttributeValue, BackendMetricProjectionError, BackendMetricSample,
    BackendMetricSampleValue, BackendMetricsSnapshot,
};
pub use cache::{
    CacheGraphActivity, CacheSourceActivity, CacheSourceEventSnapshot, DeviceCacheReport, cache_observation_fingerprint,
};
pub(crate) use cache_fill::CacheFillByteBudget;
pub use cache_fill::{CacheFillBytePermit, LakehouseCacheFillConfig};
pub use context::{ExecutionCancellation, ExecutionContext};
#[cfg(any(test, feature = "test-hooks"))]
#[doc(hidden)]
pub use context::{RuntimeObservationBuildError, RuntimeObservedExecutionContext, StandaloneConfig};
pub use cudf::io::{KvikioCompatMode, KvikioProcessConfig};
pub use execution_policy::{MemoryResourcePolicy, SourceSchedulerPolicy};
pub(crate) use gpu::{AlgeonGpuInventory, DeviceContext, DeviceLedger, DeviceRegistry, MemoryGrant};
pub use gpu::{
    DeviceCapabilities, DeviceCapability, DeviceFacts, DeviceLedgerGrantRow, DeviceLedgerReport,
    DeviceMemoryFailureReport, DeviceResourceProfile, DeviceTelemetrySnapshot, DeviceTelemetryStatus,
};
#[doc(hidden)]
pub use gpu_execution_pool::PoolBlockingWork;
pub use gpu_execution_pool::{
    GpuExecutionJobKind, GpuExecutionPoolSnapshot, GpuExecutionQuerySnapshot, GpuExecutorLease,
};
pub(crate) use gpu_execution_pool::{GpuExecutionPool, GpuExecutionQueryTracker};
pub use io_lifecycle::IoLifecycle;
#[doc(hidden)]
pub use object_store::S3ObjectStoreKey;
pub use object_store::{S3SourceStorageCredential, S3SourceStorageProfile, SourceStorageProfile};
#[cfg(feature = "qualification")]
pub use query_service::DeviceQuarantineInjection;
#[cfg(any(test, feature = "test-hooks"))]
#[doc(hidden)]
pub use query_service::QueryService;
pub use query_service::{
    AdmittedQueryContext, BackendDiagnostics, QueryActivityLease, QueryAdmissionRequest, QueryExecutionConfig,
    QueryHandle, QueryServiceAdmissionSnapshot, QueueBounds,
};
#[doc(hidden)]
pub use reservation::RetryFacts;
#[doc(hidden)]
pub use service_stream::AttemptWorkLease;
pub use service_stream::ServiceStreamPool;
pub(crate) use service_stream::{StreamLease, StreamPermitClass};
#[doc(hidden)]
pub use supervised_worker::{SupervisedWorker, SupervisedWorkerJoin};