List of all items
Structs
- config::CdcExportConfig
- config::Config
- config::DestinationConfig
- config::ExportConfig
- config::MetaColumns
- config::NotificationsConfig
- config::ParquetConfig
- config::QualityConfig
- config::SlackConfig
- config::SourceConfig
- config::TlsConfig
- error::DataIntegrityError
- error::PreclassifiedExit
- error::SchemaDriftError
- format::csv::CsvFormat
- format::csv::CsvFormatWriter
- format::parquet::ParquetFormat
- format::parquet::ParquetFormatWriter
- journal::JournalEntry
- journal::PlanSnapshot
- journal::RunJournal
- manifest::ManifestDestination
- manifest::ManifestPart
- manifest::ManifestSource
- manifest::RunManifest
- pipeline::RunOptions
- pipeline::RunSummary
- pipeline::ValidateTarget
- preflight::type_report::ExportTypeReport
- preflight::type_report::TypeReportRow
- resource::RssPeakSampler
- resource::Semaphore
- source::ExportRequest
- source::StatementDurationTimeout
- source::mssql::MssqlSource
- source::mysql::MysqlSource
- source::postgres::PostgresSource
- state::Boundary
- state::ChunkTaskInfo
- state::ExportMetric
- state::ExportProgression
- state::FileRecord
- state::MetricRow
- state::RunAggregate
- state::RunAggregateEntry
- state::SchemaChange
- state::SchemaColumn
- state::ShapeWarning
- state::StateStore
- tuning::Governor
- tuning::SourceTuning
- tuning::TuningConfig
- types::ColumnOverride
- types::CursorState
- types::SourceColumn
- types::TypeMapping
- types::policy::PolicyViolation
- types::policy::TypePolicy
- types::target::TargetColumnSpec
- types::target::TargetInput
Enums
- config::CompressionProfile
- config::CompressionType
- config::DestinationType
- config::ExportMode
- config::FormatType
- config::NotifyEvent
- config::PartitionGranularity
- config::RowGroupStrategy
- config::SchemaDriftPolicy
- config::SourceEnvironment
- config::SourceType
- config::TimeColumnType
- config::TlsMode
- config::VerifyMode
- config::cursor::IncrementalCursorMode
- error::ExitClass
- journal::RunEvent
- manifest::ManifestInconsistency
- manifest::ManifestStatus
- manifest::PartStatus
- pipeline::PlanOutputFormat
- pipeline::ReconcileOutputFormat
- pipeline::RepairOutputFormat
- pipeline::RepairReportSource
- pipeline::ValidateOutputFormat
- preflight::HealthVerdict
- source::mssql::MssqlProxyKind
- source::mysql::MysqlProxyKind
- state::StateRef
- tuning::BatchMemoryPolicy
- tuning::TuningProfile
- types::RivetType
- types::TimeUnit
- types::TypeFidelity
- types::policy::PolicyAction
- types::target::ExportTarget
- types::target::TargetStatus
Traits
Functions
- config::compression_profile_override_warning
- config::compression_supported
- config::resolve::find_unused_params
- config::resolve::parse_file_size
- config::resolve::resolve_env_vars
- config::resolve::resolve_vars
- config::resolve::warn_unused_params
- config::schema::generate_config_schema
- config::schema::generate_config_schema_pretty
- error::classify_exit
- format::create_format
- manifest::join_key
- manifest::parse_success_marker
- manifest::success_marker_body
- mcp::run_stdio
- pipeline::reset_chunk_checkpoint
- pipeline::reset_chunk_checkpoints_stuck
- pipeline::reset_state
- pipeline::run
- pipeline::run_apply_command
- pipeline::run_plan_command
- pipeline::run_reconcile_command
- pipeline::run_repair_command
- pipeline::run_validate_command
- pipeline::show_chunk_checkpoint
- pipeline::show_files
- pipeline::show_journal
- pipeline::show_metrics
- pipeline::show_progression
- pipeline::show_state
- preflight::check
- preflight::doctor
- preflight::type_report::collect_report
- preflight::type_report::print_json
- preflight::type_report::print_table
- redact::redact_error
- redact::redact_secrets
- redact::redact_url_passwords
- redact::redacted_log_line
- resource::check_memory
- resource::get_rss_mb
- source::create_source
- state::arrow_schema_to_columns
- state::schema_fingerprint
- tuning::estimate_row_bytes
- tuning::merge_tuning_config
- tuning::next_adaptive_batch_size
- types::build_arrow_field
- types::decimal::decimal_str_to_scaled_i128
- types::decimal::decimal_str_to_scaled_i256
- types::decimal::scale_int_to_i256
- types::decimal::scaled_i128_to_decimal_str
- types::derive_fidelity
- types::parse_type_str
- types::resolve_or
- types::rivet_type_to_arrow