List of all items

Structs

• backend::binary_heap::BinaryHeap
• backend::binary_heap::PeekMut
• backend::kmerge_batch::EagerStream
• backend::kmerge_batch::ElementBatchIter
• backend::kmerge_batch::KMerge
• backend::migration::CatalogMigrationPlan
• backend::migration::CatalogMigrationReport
• backend::migration::CatalogMigrationTypeReport
• backend::migration::PlannedMigrationFile
• backend::migration::PreparedMigrationPart
• backend::migration::SchemaConflict
• backend::migration::SchemaConflictExample
• backend::migration::UnmigratedFile
• backend::migration::UnresolvedSchema
• backend::parquet::catalog::ParquetDataCatalog
• backend::parquet::consolidation::ConsolidationQuery
• backend::parquet::delete::DeleteOperation
• backend::parquet::migration::ParquetMigrationConfig
• backend::session::DataBackendSession
• backend::session::DataQueryResult
• backend::session::QueryResult
• backend::session::TsInitComparator
• catalog::factory::CatalogConnectConfig
• catalog::session::TypedDataBatchSession
• catalog::traits::CatalogMetadata
• catalog::traits::RecordBatch
• catalog::types::CatalogCommit
• catalog::types::CatalogInstrumentQuery
• catalog::types::CatalogQuery
• catalog::types::CatalogRecordQuery
• catalog::worker::CatalogWorker
• catalog::worker::CatalogWriteJob
• common::conversion::FeatherConversionSummary
• common::coverage::CatalogCoverageRow
• common::coverage::CoverageIntervals
• common::coverage::CoverageSegment
• common::datafusion::DataBackendSession
• common::storage::RunManifest
• common::storage::StorageBackend
• config::DataCatalogConfig
• config::DataCatalogConfigBuilder
• config::StreamingConfig
• config::StreamingConfigBuilder
• config::StreamingRecordFilterConfig
• python::backend::PyCatalogDataType
• python::backend::feather::PyStreamingFeatherWriter
• python::backend::parquet::catalog::PyParquetDataCatalog
• python::backend::writer::PyStreamingWriter
• python::config::PyCatalogBackend
• python::config::PyRotationConfig
• python::wranglers::bar::BarDataWrangler
• python::wranglers::delta::OrderBookDeltaDataWrangler
• python::wranglers::depth::OrderBookDepthDataWrangler
• python::wranglers::quote::QuoteTickDataWrangler
• python::wranglers::trade::TradeTickDataWrangler
• test_data::MacroYieldCurveData
• test_data::RustTestBytesCustomData
• test_data::RustTestCustomData
• test_data::RustTestFixedCustomData
• test_data::RustTestHashMapCustomData
• test_data::RustTestParamsCustomData
• test_data::RustTestPriceMapCustomData
• test_data::RustTestSerdeFieldCustomData
• test_data::RustTestSerdeFieldPayload
• test_data::RustTestTypedMapCustomData
• writer::PromotionResult
• writer::factory::WriterConnectConfig
• writer::feather::FeatherBuffer
• writer::feather::FeatherWriter
• writer::feather::FileWriterPath
• writer::filter::WriterRecordFilter
• writer::run::FeatherSessionSource
• writer::subscription::StreamingSinkSubscription

Enums

• backend::migration::IdentifierSource
• backend::parquet::delete::DeleteOperationKind
• backend::session::QueryError
• catalog::types::CatalogAsOf
• catalog::types::CatalogDataType
• catalog::worker::CatalogCommand
• common::coverage::CoverageKind
• config::CatalogBackendType
• config::RotationConfig
• errors::PersistenceError
• test_data::RustTestSerdeFieldKind
• writer::factory::WriterBackendType
• writer::feather::RotationConfig
• writer::feather::WriterClock
• writer::run::RunStatus

Traits

• backend::compare::Compare
• backend::migration::ParquetCatalogSource
• catalog::session::DataBatchQuery
• catalog::traits::Catalog
• catalog::traits::CatalogReader
• catalog::traits::CatalogWriter
• catalog::traits::NautilusDataTypePrefix
• catalog::traits::NautilusRecordTypePrefix
• catalog::types::HasCatalogDataType
• common::paths::CatalogPathPrefix
• writer::traits::StreamingSink

Functions

• backend::catalog::extract_identifier_from_path
• backend::default_catalog_factories
• backend::default_writer_factories
• backend::extend_catalog_factories
• backend::extend_writer_factories
• backend::migration::build_catalog_migration_plan
• backend::migration::parse_storage_option
• backend::migration::prepare_migration_parts
• backend::migration::read_planned_migration_file
• backend::parquet::intervals::are_intervals_contiguous
• backend::parquet::intervals::are_intervals_disjoint
• backend::parquet::io::combine_parquet_files
• backend::parquet::io::combine_parquet_files_from_object_store
• backend::parquet::io::create_object_store_from_path
• backend::parquet::io::min_max_from_parquet_metadata
• backend::parquet::io::min_max_from_parquet_metadata_object_store
• backend::parquet::io::read_parquet_from_object_store
• backend::parquet::io::read_parquet_schema_from_object_store
• backend::parquet::io::write_batch_to_parquet
• backend::parquet::io::write_batches_to_object_store
• backend::parquet::io::write_batches_to_parquet
• backend::parquet::migration::migrate_parquet_catalog
• backend::parquet::paths::extract_sql_safe_filename
• backend::parquet::paths::make_local_path
• backend::parquet::paths::parse_filename_timestamps
• backend::parquet::paths::timestamps_to_filename
• backend::session::build_query
• catalog::types::custom_data_read_prefixes
• catalog::types::custom_type_name
• catalog::types::data_path_prefix
• catalog::types::data_type_from_data_path_prefix
• catalog::types::instrument_any_type
• catalog::types::instrument_path_prefix
• catalog::types::parquet_catalog_data_type_path_prefixes
• catalog::types::parquet_catalog_data_type_table_stem
• catalog::types::parquet_data_path_prefix
• catalog::types::record_path_prefix
• common::coverage::compare_coverage_rows_causal
• common::coverage::coverage_batch_schema
• common::coverage::coverage_intervals_by_kind
• common::coverage::coverage_kind_to_str
• common::coverage::coverage_rows_to_batch
• common::coverage::covered_intervals
• common::coverage::decode_coverage_batches
• common::coverage::deduplicate_and_sort_coverage_rows
• common::coverage::deduplicate_coverage_rows
• common::coverage::filter_record_batch_by_ts_init_intervals
• common::coverage::last_data_timestamp
• common::coverage::merge_closed_intervals
• common::coverage::missing_intervals
• common::coverage::missing_segments_for_request
• common::coverage::rows_to_segments
• common::coverage::subtract_interval_from_intervals
• common::custom::augment_batch_with_data_type_column
• common::custom::custom_data_path_components
• common::custom::decode_batch_to_data
• common::custom::decode_custom_batches_to_data
• common::custom::group_custom_data_by_type
• common::custom::prepare_custom_data_batch
• common::custom::schema_with_data_type_column
• common::datafusion::build_identifier_query
• common::datafusion::build_query
• common::datafusion::identifiers_from_record_batches
• common::paths::extract_identifier_from_path
• common::paths::extract_path_components
• common::paths::local_to_object_store_path
• common::paths::make_object_store_path
• common::paths::make_sql_safe_identifier
• common::paths::normalize_path_separators
• common::paths::normalize_path_to_uri
• common::paths::safe_directory_identifier
• common::paths::urisafe_instrument_id
• common::storage::create_storage_backend_from_path
• common::storage::datafusion_root_url
• common::storage::normalize_storage_location
• python::backend::nautilus_data_type_from_py
• python::persistence
• writer::factory::create_writer
• writer::factory::replace_existing_writer_data

Type Aliases

• catalog::factory::CatalogFactory
• catalog::factory::CatalogFactoryRegistry
• catalog::session::DataBatchQueryResult
• catalog::traits::DataCatalog
• writer::factory::WriterFactory
• writer::factory::WriterFactoryRegistry
• writer::traits::StreamingDataSink

Constants

• backend::migration::DEFAULT_MIGRATION_COMMIT_ROWS
• backend::parquet::DEFAULT_ROW_GROUP_SIZE
• backend::parquet::catalog::QUERY_OPTIMIZE_FILE_LOADING
• backend::parquet::catalog::WRITE_SKIP_DISJOINT_CHECK
• catalog::factory::PARQUET_CATALOG_FACTORY_NAME
• catalog::session::DEFAULT_DATA_BATCH_CHUNK_SIZE
• catalog::types::INSTRUMENT_PATH_PREFIXES
• common::CLUSTER_KEY_COLUMN
• common::CREATED_TS_COLUMN
• common::DATA_TYPE_COLUMN
• common::DATA_VERSION_COLUMN
• common::END_TS_COLUMN
• common::FORMAT_VERSION_COLUMN
• common::METADATA_ID_COLUMN
• common::METADATA_JSON_COLUMN
• common::ROW_COUNT_COLUMN
• common::SCHEMA_VERSION_COLUMN
• common::SOURCE_COLUMN
• common::START_TS_COLUMN
• common::STATUS_COLUMN
• common::TABLE_PATH_COLUMN
• common::coverage::COVERAGE_SCHEMA_VERSION
• common::storage::RUN_MANIFEST_FILENAME
• writer::factory::FEATHER_WRITER_FACTORY_NAME
• writer::factory::PARQUET_WRITER_FACTORY_NAME