lib.rs•5.24 kB
#![feature(assert_matches)]
#![feature(coroutines)]
#![feature(iter_advance_by)]
#![feature(type_alias_impl_trait)]
#![feature(let_chains)]
#![feature(iterator_try_collect)]
#![feature(never_type)]
#![feature(try_blocks)]
#![feature(impl_trait_in_assoc_type)]
#![feature(cow_is_borrowed)]
#![feature(try_find)]
#![feature(once_cell_try)]
mod bootstrap_model;
mod committer;
mod database;
mod database_index_workers;
mod execution_size;
mod metrics;
pub mod patch;
pub mod persistence_helpers;
mod preloaded;
pub mod query;
pub mod reads;
mod retention;
mod search_index_bootstrap;
mod search_index_workers;
mod snapshot_manager;
mod stack_traces;
pub mod streaming_export_selection;
pub mod subscription;
pub mod system_query;
pub mod system_tables;
mod table_registry;
pub mod table_summary;
mod table_usage;
mod token;
mod transaction;
mod transaction_id_generator;
mod transaction_index;
pub mod vector_index_worker;
mod virtual_tables;
mod write_limits;
#[cfg(any(test, feature = "testing"))]
pub mod write_log;
#[cfg(not(any(test, feature = "testing")))]
mod write_log;
mod writes;
mod component_registry;
mod schema_registry;
mod table_iteration;
#[cfg(any(test, feature = "testing"))]
pub mod test_helpers;
#[cfg(test)]
pub mod tests;
pub mod text_index_worker;
pub use component_registry::ComponentRegistry;
pub use database_index_workers::{
index_writer::{
IndexWriter,
PERFORM_BACKFILL_LABEL,
},
IndexWorker,
};
pub use execution_size::FunctionExecutionSize;
pub use patch::PatchValue;
pub use preloaded::PreloadedIndexRange;
pub use reads::{
ReadSet,
TransactionReadSet,
TransactionReadSize,
OVER_LIMIT_HELP,
};
pub use schema_registry::SchemaRegistry;
pub use table_registry::TableRegistry;
pub use token::{
SerializedToken,
Token,
};
pub use transaction::{
TableCountSnapshot,
Transaction,
};
pub use transaction_index::{
SearchNotEnabled,
TextIndexManagerSnapshot,
TransactionTextSnapshot,
};
pub use vector_index_worker::flusher::VectorIndexFlusher;
pub use write_limits::BiggestDocumentWrites;
pub use write_log::{
LogReader,
WriteSource,
};
pub use writes::{
DocumentWrite,
TransactionWriteSize,
Writes,
};
pub use self::{
bootstrap_model::{
components::{
definition::{
ComponentDefinitionsTable,
COMPONENT_DEFINITIONS_TABLE,
},
BootstrapComponentsModel,
ComponentsTable,
COMPONENTS_BY_PARENT_INDEX,
COMPONENTS_TABLE,
},
defaults,
import_facing::ImportFacingModel,
index::{
IndexModel,
IndexTable,
},
index_backfills::{
types::IndexBackfillMetadata,
IndexBackfillTable,
INDEX_BACKFILLS_BY_INDEX_ID,
INDEX_BACKFILLS_TABLE,
},
index_workers::{
IndexWorkerMetadataTable,
INDEX_DOC_ID_INDEX,
INDEX_WORKER_METADATA_TABLE,
},
schema::{
types::{
SchemaDiff,
SerializedSchemaDiff,
},
SchemaModel,
SchemasTable,
SCHEMAS_STATE_INDEX,
SCHEMAS_TABLE,
SCHEMA_STATE_FIELD,
},
schema_validation_progress::{
types::SchemaValidationProgressMetadata,
SchemaValidationProgressModel,
SchemaValidationProgressTable,
SCHEMA_VALIDATION_PROGRESS_BY_SCHEMA_ID,
SCHEMA_VALIDATION_PROGRESS_TABLE,
},
system_metadata::SystemMetadataModel,
table::{
TableModel,
TablesTable,
NUM_RESERVED_LEGACY_TABLE_NUMBERS,
NUM_RESERVED_SYSTEM_TABLE_NUMBERS,
TABLES_BY_NAME_INDEX,
},
user_facing::UserFacingModel,
},
database::{
unauthorized_error,
BootstrapMetadata,
Database,
DatabaseSnapshot,
DocumentDeltas,
OccRetryStats,
SnapshotPage,
StreamingExportFilter,
MAX_OCC_FAILURES,
},
database_index_workers::index_writer::IndexSelector,
query::{
soft_data_limit,
DeveloperQuery,
ResolvedQuery,
},
retention::{
latest_retention_min_snapshot_ts,
FollowerRetentionManager,
LeaderRetentionManager,
RetentionType,
},
search_index_workers::{
fast_forward::{
load_metadata_fast_forward_ts,
FastForwardIndexWorker,
},
search_worker::SearchIndexWorkers,
},
snapshot_manager::{
Snapshot,
TableSummaries,
},
subscription::Subscription,
table_iteration::{
MultiTableIterator,
TableIterator,
},
table_summary::{
TableSummary,
TableSummaryWriter,
},
table_usage::{
TableUsage,
TablesUsage,
},
transaction::DEFAULT_PAGE_SIZE,
transaction_id_generator::TransactionIdGenerator,
transaction_index::TransactionIndex,
};
#[cfg(any(test, feature = "testing"))]
pub use crate::bootstrap_model::test_facing::TestFacingModel;
pub use crate::metrics::shutdown_error;