ahri_tre_lake/
lib.rs

1//! DuckLake-backed storage adapter for AHRI TRE datasets and data files.
2//!
3//! This crate owns Lake location layout, DuckDB/DuckLake attachment, dataset table
4//! loading/export, and staged data-file materialization.
5
6mod disclosure_datafile;
7pub use disclosure_datafile::{
8    DisclosureDatafileStream, PreparedDisclosureDatafile, attest_datafile,
9    run_datafile_capture_worker,
10};
11mod capture_worker;
12pub use capture_worker::{DisclosureCaptureAuthority, run_capture_worker};
13mod catalog_observations;
14mod disclosure_inputs;
15mod governance_ledger;
16pub use catalog_observations::{
17    CatalogObservation, CatalogObservationResult, LakeCatalogObservations,
18};
19pub use disclosure_inputs::{
20    DisclosureDatasetInput, PreparedDisclosureQuery, PreparedQueryOutput, RestrictedQueryStream,
21    dataset_physical_identity,
22};
23pub use governance_ledger::GovernanceLedger;
24mod restricted_query;
25mod sql_source;
26mod sql_source_mssql;
27pub use restricted_query::{
28    QueryBinding, RestrictedQueryPlan, analyze_dataset_transform, analyze_disclosure_query,
29};
30pub use sql_source::{SqlDatabaseEndpoint, SqlReadSource, SqlSourcePlan, SqlSourceRead};
31#[doc(hidden)]
32pub use sql_source_mssql::run_mssql_source;
33
34pub mod adapter;
35pub mod alias;
36pub mod dataset_loading;
37mod dataset_source;
38pub use dataset_source::PreparedDatasetSource;
39pub mod error;
40pub mod file_staging;
41pub mod preflight;
42pub mod scratch;
43
44pub use adapter::{
45    AwsWorkloadIdentitySource, DuckLakeAdapter, DuckLakeAttachPlan, DuckLakeCredentialKind,
46    DuckLakeHealth, DuckLakeLocalLayout, DuckLakeOpenOptions, DuckLakeOpenedCatalog,
47    DuckLakeTlsGuard, FilesystemCatalogTls, FilesystemLakeSessionConfig, ObjectLakeSessionConfig,
48    ObjectStorageAuthentication, ObjectStorageLocation, ObjectStorageTls, S3UrlStyle,
49};
50pub use alias::LAKE_ALIAS;
51pub use dataset_loading::{
52    DatasetCsvSeed, DatasetExportFormat, DatasetFileFormat, DatasetFileReadOptions,
53    DatasetTableRelation, ExportDatasetTableRequest, ExportedDatasetTable, ImportedColumn,
54    LoadDatasetTableFromFileRequest, LoadDatasetTableFromSqlRequest, LoadRedcapFormDatasetRequest,
55    LoadedDatasetTable, PreviewDatasetTableRequest, PreviewedDatasetTable, RedcapEavChoice,
56    RedcapEavField, RedcapSyntheticColumn,
57};
58pub use error::LakeError;
59pub use file_staging::{
60    DataFileCompression, DataFileEncryption, DeleteDataFileRequest, DeletedDataFile,
61    ExportDataFileRequest, ExportedDataFile, MaterializeDataFileRequest, MaterializedDataFile,
62    StageDataFileRequest, StageDataFileStreamRequest, StagedDataFile,
63};
64pub use scratch::{ScratchAttempt, ScratchAttemptId, ScratchError, TrustedScratch};
65
66mod dataset_executor;
67pub use dataset_executor::DatasetExecutor;
68
69pub use dataset_loading::dataset_output_key;
70
71mod upload;
72pub use upload::UploadValidation;
73
74mod redcap_upload;
75pub use redcap_upload::{RedcapExecutionLimits, RedcapUpload, RedcapUploadRole};
ahri_tre_lake/lib.rs

ahri_tre_lake/
lib.rs
