List of all items

Structs

• backfill::orchestrator::BackfillOptions
• backfill::orchestrator::BackfillOutcome
• backfill::orchestrator::UnitReport
• backfill::plan::BackfillUnit
• backfill::spec::BackfillSpec
• backfill::state::BackfillState
• catalog::CatalogHandle
• catalog::snapshot::DiffSummary
• catalog::snapshot::FieldChange
• catalog::snapshot::RowDiff
• catalog::snapshot::SnapshotDiff
• catalog::spec::CatalogSpec
• cli::BackfillArgs
• cli::CatalogArgs
• cli::CatalogConfigArgs
• cli::CatalogDatasetsArgs
• cli::CatalogLineageArgs
• cli::CatalogShowArgs
• cli::Cli
• cli::CompletionsArgs
• cli::ConformanceArgs
• cli::ContractArgs
• cli::DevArgs
• cli::DiscoverArgs
• cli::DlqArgs
• cli::DlqDiscardArgs
• cli::DlqInspectArgs
• cli::DlqReplayArgs
• cli::DoctorArgs
• cli::ExplainArgs
• cli::FmtArgs
• cli::HistoryArgs
• cli::InitArgs
• cli::InstallArgs
• cli::ListArgs
• cli::MaskingArgs
• cli::MigrateArgs
• cli::NewArgs
• cli::NewConnectorArgs
• cli::NotifyArgs
• cli::NotifyTestArgs
• cli::PlanArgs
• cli::PreviewArgs
• cli::ReplicateArgs
• cli::RunArgs
• cli::ScheduleArgs
• cli::SchemaArgs
• cli::SearchArgs
• cli::SelectionArgs
• cli::ServeArgs
• cli::TestArgs
• cli::ValidateArgs
• commands::dev::RecordDiff
• commands::doctor::InvocationOut
• commands::doctor::LintFinding
• commands::doctor::ProbeOut
• commands::plan::PlanReport
• commands::plan::SampleReport
• commands::plan::SchemaDeltaReport
• config::CircuitBreakerSpec
• config::ConnectorSpec
• config::DlqSpec
• config::ExecutionSpec
• config::MatrixRow
• config::ObservabilitySpec
• config::OtelSpec
• config::PartialConnector
• config::PipelineConfig
• config::PipelineSpec
• config::PoisonSpec
• config::PrometheusSpec
• config::ResilienceSpec
• config::RetrySpec
• config::SelectionSpec
• config::ShardingSpec
• config::StateStoreSpec
• config::TracingSpec
• config::TransformSpec
• conformance::ConnectorFacts
• conformance::Dimension
• conformance::Report
• dlq_replay::DiscardOutcome
• dlq_replay::EnvelopeSummary
• dlq_replay::InspectSummary
• dlq_replay::ReplayInputs
• dlq_replay::ReplayOutcome
• dlq_replay::reader::DlqDecryptor
• dlq_replay::reader::DlqReaderSource
• dlq_replay::reader::ScanResult
• dlq_replay::reader::SourceOverride
• executor::ExecuteOptions
• executor::InvocationMetrics
• executor::InvocationOutcome
• executor::RunSummary
• expand::DeferredRef
• expand::ExpandedNode
• init_template::TaggedEnumField
• livemetrics::RowStats
• livemetrics::Sample
• livemetrics::Sampler
• livemetrics::TuiModel
• notify::dispatch::Notifier
• notify::event::NotifyEvent
• notify::spec::NotificationSpec
• notify::spec::PagerdutyConfig
• notify::spec::SlackConfig
• notify::spec::WebhookConfig
• pipeline_test::report::CaseOutcome
• pipeline_test::report::TestReport
• pipeline_test::runner::CaseRun
• pipeline_test::runner::ResolvedCase
• pipeline_test::spec::Expectation
• pipeline_test::spec::InlinePipeline
• pipeline_test::spec::TestCase
• pipeline_test::spec::TestSpecFile
• registry::PluginRegistry
• registry_index::ConnectorEntry
• registry_index::RegistryIndex
• replication::compiled::CompiledReplication
• replication::orchestrator::ReplicationOptions
• replication::spec::ReplicationSpec
• replication::spec::SnapshotSpec
• replication::state::ReplicationState
• scaffold::ConnectorScaffold
• scaffold::GeneratedFile
• schedule::compiled::CompiledSchedule
• schedule::spec::ScheduleSpec
• schedule::state::SchedulerState
• secrets::ResolverSet
• secrets::registry::RedactingMakeWriter
• secrets::registry::RedactingWriter
• select::RunSelection
• serve::cluster::ClusterConfig
• serve::cluster::ClusterHandle
• serve::config::ServeConfig
• serve::error::ApiError
• serve::error::ApiErrorBody
• serve::handlers::audit::AuditListResponse
• serve::handlers::audit::AuditQuery
• serve::handlers::backfill::BackfillSubmitRequest
• serve::handlers::backfill::BackfillSubmitResponse
• serve::handlers::backfill::BackfillUnitRun
• serve::handlers::catalog::DatasetsQuery
• serve::handlers::catalog::LineageQuery
• serve::handlers::catalog::LineageResponse
• serve::handlers::dlq::DlqDiscardRequest
• serve::handlers::dlq::DlqInspectRequest
• serve::handlers::dlq::DlqReplayRequest
• serve::handlers::doctor::DoctorRequest
• serve::handlers::runs::ListQuery
• serve::handlers::runs::ListResponse
• serve::handlers::schemas::SchemaItem
• serve::handlers::schemas::SchemasResponse
• serve::history::AuditEntry
• serve::history::AuditFilter
• serve::history::ClaimedShard
• serve::history::InstanceHeartbeat
• serve::history::InstanceRecord
• serve::history::InvocationRecord
• serve::history::ListFilter
• serve::history::ListPage
• serve::history::ReclaimReport
• serve::history::RunRecord
• serve::history::ShardInsert
• serve::history::ShardProgress
• serve::history::catalog::CatalogDataset
• serve::history::catalog::CatalogDatasetDetail
• serve::history::catalog::CatalogDatasetPage
• serve::history::catalog::CatalogLineageEdge
• serve::history::catalog::CatalogListFilter
• serve::history::catalog::CatalogSchemaVersion
• serve::history::catalog::CatalogStatsPoint
• serve::history::catalog::CatalogUpdate
• serve::history::catalog::ConfigSnapshot
• serve::history::catalog::ConnectorSnapshot
• serve::history::catalog::DatasetObservation
• serve::history::catalog::RowSnapshot
• serve::history::catalog::TransformSnapshot
• serve::history::fallback::FallbackHistory
• serve::history::memory::MemoryHistory
• serve::history::postgres::PostgresHistory
• serve::history::sql::Stmts
• serve::history::sqlite::SqliteHistory
• serve::load::LoadedSubmission
• serve::logs::LogHub
• serve::logs::LogLine
• serve::logs::RunLogLayer
• serve::rbac::AuthContext
• serve::rbac::PrincipalSpec
• serve::rbac::RbacConfig
• serve::registry::Registry
• serve::runner::SubmitRequest
• serve::runner::SubmitResponse
• serve::state::ServerState
• serve::triggers::compiled::CompiledTrigger
• serve::triggers::compiled::CompiledTriggers
• serve::triggers::health::TriggerHealth
• serve::triggers::health::TriggersHandle
• serve::triggers::object_arrival::Cursor
• serve::triggers::object_arrival::ListedObject
• serve::triggers::object_arrival::ObjectArrivalWatcher
• serve::triggers::queue_depth::Edge
• serve::triggers::queue_depth::QueueDepthWatcher
• serve::triggers::spec::RunTemplate
• serve::triggers::spec::TriggerSpec
• serve::triggers::spec::TriggersFile
• sla::spec::SlaSpec
• sla::spec::VolumeAnomalySpec
• sla::state::SlaState
• tui::LogBuffer
• tui::LogBufferWriter

Enums

• backfill::orchestrator::BackfillRange
• backfill::state::UnitOutcome
• catalog::snapshot::RowStatus
• cli::CatalogCommand
• cli::Command
• cli::ContractExportFormat
• cli::DlqCommand
• cli::NewTarget
• cli::NotifyCommand
• cli::RunOutput
• cli::SchemaTarget
• commands::doctor::LintSeverity
• config::BackoffSpec
• config::IncludeParents
• config::OnBatchErrorSpec
• config::OnError
• config::PoisonActionSpec
• config::SourceStatus
• conformance::Tier
• dlq_replay::reader::LineOutcome
• error::CliError
• expand::NodeRole
• interpolate::Directive
• notify::render::PdAction
• notify::spec::ChannelSpec
• notify::spec::EventKind
• notify::spec::Severity
• pipeline_test::spec::InputSpec
• pipeline_test::spec::MatchMode
• registry_index::InstallRecipe
• replication::spec::ReplicationMode
• replication::state::Phase
• replication::state::Plan
• scaffold::ConnectorKind
• schedule::spec::OverlapPolicy
• schedule::spec::ScheduleOnFailure
• schedule::state::AfterRun
• schedule::state::RunOutcome
• schedule::state::TickAction
• serve::config::AuthMode
• serve::config::HistoryBackendSpec
• serve::error::ServeError
• serve::history::Claim
• serve::history::DeleteOutcome
• serve::history::HistoryError
• serve::history::RunStatus
• serve::history::catalog::DatasetRole
• serve::history::sql::Dialect
• serve::load::ConfigFormat
• serve::logs::LogEvent
• serve::logs::LogMsg
• serve::rbac::Permission
• serve::rbac::Role
• serve::runner::ConfigFormatWire
• serve::triggers::context::TriggerEvent
• serve::triggers::enqueue::FireOutcome
• serve::triggers::spec::ArrivalMode
• serve::triggers::spec::PipelineRef
• serve::triggers::spec::QueueSpec
• serve::triggers::spec::RedisQueueKind
• serve::triggers::spec::StartAt
• serve::triggers::spec::StoreSpec
• serve::triggers::spec::TriggerKind
• sla::RunOutcome
• sla::eval::SlaViolation
• sla::spec::AnomalyMethod
• tui::view::Column

Traits

• secrets::SecretResolver
• serve::history::RunHistory
• serve::triggers::queue_depth::DepthProbe
• serve::triggers::watcher::Watcher
• tui::CancelEvents

Functions

• auth_catalog::auth_ref
• auth_catalog::build_auth_catalog
• auth_catalog::resolve
• backfill::orchestrator::run_backfill
• backfill::plan::parse_boundary
• backfill::plan::parse_window
• backfill::plan::plan_windows
• backfill::plan::range_hash
• backfill::plan::substitute_unit_tokens
• backfill::spec::has_scoping_tokens
• backfill::spec::parse_timezone
• backfill::state::marker_key
• backfill::state::split_remaining
• backfill::state::unit_row_id
• backfill::state::unit_state_key
• catalog::connect_from_spec
• catalog::model::canonicalize_uri
• catalog::model::schema_from_samples
• catalog::record
• catalog::record_config_snapshot
• catalog::snapshot::build_snapshot
• catalog::snapshot::diff
• catalog::snapshot::on_error_str
• catalog::snapshot::record_if_ok
• catalog::snapshot::redact_value
• catalog::snapshot::render_human
• catalog::snapshot::resolve_name
• commands::backfill::run
• commands::catalog::run
• commands::completions::run
• commands::conformance::run
• commands::contract::export
• commands::contract::run
• commands::dev::diff_records
• commands::dev::referenced_paths
• commands::dev::run
• commands::dev::should_refire
• commands::discover::run
• commands::dlq::run
• commands::doctor::count_failures
• commands::doctor::probe_invocation
• commands::doctor::probe_lineage
• commands::doctor::probe_roots
• commands::doctor::redact_invocations
• commands::doctor::run
• commands::explain::run
• commands::fmt::canonicalize
• commands::fmt::run
• commands::history::run
• commands::init::run
• commands::install::run
• commands::list::run
• commands::masking::run
• commands::migrate::run
• commands::new::run
• commands::notify::run
• commands::plan::build_plan_report
• commands::plan::run
• commands::preview::run
• commands::replicate::run
• commands::report
• commands::run::run
• commands::schedule::run
• commands::schema::lineage_schema
• commands::schema::run
• commands::search::run
• commands::serve::run
• commands::test::run
• commands::validate::run
• compose::compose
• config::parse_with_extension
• conformance::build_reports
• conformance::facts_for
• conformance::score
• conformance::tier_for
• dlq_replay::discard
• dlq_replay::inspect
• dlq_replay::plan::build_replay_node
• dlq_replay::plan::default_failed_dlq_path
• dlq_replay::plan::discard_keep_line
• dlq_replay::plan::dlq_encryption_value
• dlq_replay::plan::envelope_selected
• dlq_replay::plan::failed_dlq_spec
• dlq_replay::plan::select_replay_node
• dlq_replay::plan::validate_reason
• dlq_replay::reader::classify_line
• dlq_replay::reader::classify_line_with
• dlq_replay::reader::expand_location
• dlq_replay::reader::reason_matches
• dlq_replay::reader::scan_files
• dlq_replay::replay
• env_config::build_named_sinks
• env_config::build_named_sources
• env_config::build_pipeline_config
• env_config::build_sink
• env_config::build_source
• env_config::build_state
• env_config::build_transforms
• env_config::build_vars
• env_config::extract_scope
• env_config::from_process_env
• env_loader::discover_config_path
• env_loader::load_env_file_if_present
• env_loader::resolve_env_file
• executor::build_dlq_config
• executor::run_expanded
• expand::expand
• init_template::discover_tagged_enum_fields
• init_template::schema_to_yaml_template
• init_template::schema_to_yaml_template_with_choices
• interpolate::classify_directive
• interpolate::interpolate
• interpolate::interpolate_record
• interpolate::interpolate_value
• interpolate::iter_directives
• interpolate::resolve_config_refs
• interpolate::resolve_lineage_job_name
• interpolate::resolve_now
• lineage_glue::build_emitter
• lineage_glue::check_transport
• lineage_glue::column_ops
• livemetrics::install_metrics_recorder
• livemetrics::parse_samples
• livemetrics::setup_observability
• merge::merge_value
• notify::channels::send_pagerduty
• notify::channels::send_slack
• notify::channels::send_webhook
• notify::metrics::record_dropped
• notify::metrics::record_duration
• notify::metrics::record_sent
• notify::render::pagerduty
• notify::render::slack
• notify::render::webhook
• notify::spec::validate_all
• obs::build_observability_config
• obs::install
• obs::resolve_tracing_level
• pipeline_test::diff::evaluate
• pipeline_test::diff::value_matches
• pipeline_test::fixtures::load_input
• pipeline_test::runner::run_case
• pipeline_test::spec::load_spec
• progress::drive
• progress::format_row_line
• progress::is_progress_session
• registry::build_sink
• registry::build_source
• registry::sink_descriptions
• registry::sink_exists
• registry::sink_guarantee
• registry::sink_kinds
• registry::sink_schema
• registry::sink_supported_write_modes
• registry::sink_supports_idempotent_writes
• registry::sink_supports_schema_evolution
• registry::source_descriptions
• registry::source_exists
• registry::source_kinds
• registry::source_replay_guarantee
• registry::source_schema
• registry::source_supports_discover
• registry::source_supports_exactly_once
• registry_index::install_recipe
• replication::orchestrator::run_replication
• replication::state::cdc_state_key
• replication::state::marker_key
• replication::state::plan_from_marker
• run_command
• run_from_yaml_str
• run_main
• scaffold::validate_name
• schedule::metrics::consecutive_failures
• schedule::metrics::describe
• schedule::metrics::heartbeat
• schedule::metrics::in_flight
• schedule::metrics::last_run_completed
• schedule::metrics::last_run_duration
• schedule::metrics::last_run_started
• schedule::metrics::lateness
• schedule::metrics::next_tick
• schedule::metrics::overlap
• schedule::metrics::reload
• schedule::metrics::run_outcome
• schedule::state::cooldown_delay
• schema_compose::config_schema
• secrets::collect_refs
• secrets::ensure_no_secret_directives
• secrets::registry::redact
• secrets::registry::redact_with
• secrets::registry::register
• secrets::resolve_secrets
• secrets::resolve_secrets_with
• secrets::scan_path_refs
• secrets::substitute
• select::select_nodes
• serve::audit::write
• serve::auth::authorize_header
• serve::auth::require_auth
• serve::cluster::claim_loop
• serve::handlers::audit::list_audit
• serve::handlers::backfill::submit_backfill
• serve::handlers::catalog::get_dataset
• serve::handlers::catalog::lineage
• serve::handlers::catalog::list_datasets
• serve::handlers::dlq::discard
• serve::handlers::dlq::inspect
• serve::handlers::dlq::replay
• serve::handlers::doctor::doctor
• serve::handlers::health::healthz
• serve::handlers::health::metrics
• serve::handlers::health::readyz
• serve::handlers::logs::stream_logs
• serve::handlers::reload::reload
• serve::handlers::runs::cancel_run
• serve::handlers::runs::delete_run
• serve::handlers::runs::get_run
• serve::handlers::runs::list_runs
• serve::handlers::runs::submit_run
• serve::handlers::schemas::get_schema
• serve::handlers::schemas::list_schemas
• serve::history::catalog::apply_edge
• serve::history::catalog::apply_observation
• serve::history::catalog::dataset_id
• serve::history::catalog::filter_datasets
• serve::history::catalog::lineage_slice
• serve::history::catalog::schema_hash
• serve::history::connect
• serve::history::sql::decode_body
• serve::history::sql::decode_json
• serve::history::sql::encode_body
• serve::history::sql::encode_json
• serve::history::sql::fmt_ts
• serve::history::sql::is_expired
• serve::history::sql::parse_status
• serve::history::sql::threshold
• serve::idempotency::fingerprint
• serve::idempotency::request_fingerprint
• serve::load::load_submission
• serve::logs::log_events
• serve::metrics::matched_path_label
• serve::metrics::record_idempotency_hit
• serve::metrics::record_run_finished
• serve::metrics::record_runs_claimed
• serve::metrics::record_runs_reclaimed
• serve::metrics::record_shards_claimed
• serve::metrics::record_shards_reclaimed
• serve::metrics::set_cluster_enabled
• serve::metrics::set_cluster_instances
• serve::metrics::set_history_degraded
• serve::metrics::set_run_gauges
• serve::metrics::track_metrics
• serve::observability::install
• serve::rbac::audit_action
• serve::rbac::required_permission
• serve::run_server
• serve::runner::resume_claimed_run
• serve::runner::resume_claimed_shard
• serve::runner::submit
• serve::server::build_router
• serve::server::serve
• serve::triggers::context::idempotency_key
• serve::triggers::context::labels
• serve::triggers::context::render_name
• serve::triggers::context::substitute
• serve::triggers::enqueue::build_submit_request
• serve::triggers::enqueue::fire
• serve::triggers::enqueue::resolve_config_text
• serve::triggers::load_triggers
• serve::triggers::metrics::active
• serve::triggers::metrics::coalesced
• serve::triggers::metrics::describe
• serve::triggers::metrics::dropped
• serve::triggers::metrics::enqueued
• serve::triggers::metrics::error
• serve::triggers::metrics::fired
• serve::triggers::metrics::healthy
• serve::triggers::metrics::last_fire
• serve::triggers::metrics::preinit
• serve::triggers::queue_depth::build_probe
• serve::triggers::spawn_watchers
• serve::triggers::spec::unknown_trigger_fields
• serve::triggers::watcher::backoff
• serve::triggers::watcher::run_supervised
• serve::triggers::webhook::handle
• serve::ui_assets::asset
• serve::ui_assets::index
• serve::ui_assets::spa_fallback
• sla::doctor_probes
• sla::eval::detect_anomaly
• sla::eval::evaluate_failure
• sla::eval::evaluate_success
• sla::evaluate_post_run
• sla::metrics::record_violation
• sla::metrics::set_baseline_runs
• sla::state::sla_state_key
• state::available_state_kinds
• state::build_state_store
• transforms::available_transforms
• transforms::compile_transforms
• transforms::compile_transforms_columnar
• transforms::quality_descriptions
• transforms::transform_descriptions
• transforms::transform_schema
• tui::drive
• tui::drive_loop
• tui::flush_logs_to_stderr
• tui::install_tui_tracing
• tui::is_tui_session
• tui::log_buffer
• tui::view::draw
• tui::view::format_bookmark_age
• tui::view::format_count
• tui::view::format_elapsed
• tui::view::format_rate
• tui::view::row_status
• tui::view::visible_columns

Type Aliases

• auth_catalog::AuthCatalog
• error::CliResult
• registry::SchemaFn
• registry::SinkFactory
• registry::SourceFactory
• secrets::SecretRef

Constants

• backfill::plan::MAX_UNITS
• backfill::plan::WARN_UNITS
• catalog::DEFAULT_SAMPLE_RECORDS
• expand::RESERVED_IDS
• notify::channels::PAGERDUTY_ENDPOINT
• registry::DISCOVER_SOURCE_KINDS
• registry::EXACTLY_ONCE_SOURCE_KINDS
• registry::IDEMPOTENT_SINK_KINDS
• registry::SCHEMA_EVOLUTION_SINK_KINDS
• registry::UPSERT_SINK_KINDS
• secrets::SECRET_SCHEMES
• serve::history::catalog::LINEAGE_DEFAULT_DEPTH
• serve::history::catalog::STATS_DETAIL_LIMIT
• serve::history::catalog::STATS_RETAIN
• serve::history::sql::CLAIM_ATTEMPTS
• serve::history::sql::DDL
• serve::logs::BROADCAST_CAPACITY
• serve::logs::LOG_DRAIN
• serve::logs::RING_CAPACITY
• serve::triggers::watcher::MAX_BACKOFF
• serve::triggers::watcher::UNHEALTHY_THRESHOLD
• sla::spec::DEFAULT_IQR_SENSITIVITY
• sla::spec::DEFAULT_MIN_HISTORY
• sla::spec::DEFAULT_WINDOW
• sla::spec::DEFAULT_ZSCORE_SENSITIVITY
• sla::state::SLA_STATE_SUFFIX