List of all items

Structs

• DataIngestionMetrics
• FileProgressStore
• IndexerExecutor
• ReaderOptions
• ShimProgressStore
• WorkerPool
• history::manifest::CheckpointUpdates
• history::manifest::FileMetadata
• history::manifest::ManifestV1
• history::reader::HistoricalReader
• reader::v2::CheckpointReaderConfig

Enums

• IngestionError
• history::manifest::Manifest
• reader::v2::RemoteUrl

Traits

• ProgressStore
• Reducer
• Worker

Functions

• create_remote_store_client
• create_remote_store_client_with_ops
• history::manifest::create_file_metadata
• history::manifest::create_file_metadata_from_bytes
• history::manifest::finalize_manifest
• history::manifest::read_manifest
• history::manifest::read_manifest_from_bytes
• history::manifest::verify_historical_checkpoints_with_checksums
• history::manifest::write_manifest
• history::reader::make_blob_iterator_for_range
• setup_single_workflow

Type Aliases

• IngestionResult

Constants

• MAX_CHECKPOINTS_IN_PROGRESS
• history::CHECKPOINT_FILE_MAGIC
• history::CHECKPOINT_FILE_SUFFIX
• history::MAGIC_BYTES
• history::MANIFEST_FILENAME
• history::MANIFEST_FILE_MAGIC