List of all items

Structs

• cli::Cli
• cli::DoctorArgs
• cli::InitArgs
• cli::PreviewArgs
• cli::ReplicateArgs
• cli::RunArgs
• cli::ScheduleArgs
• cli::SchemaArgs
• cli::ServeArgs
• cli::ValidateArgs
• commands::doctor::InvocationOut
• commands::doctor::ProbeOut
• 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::ShardingSpec
• config::StateStoreSpec
• config::TracingSpec
• config::TransformSpec
• executor::ExecuteOptions
• executor::InvocationOutcome
• executor::RunSummary
• expand::DeferredRef
• expand::ExpandedNode
• init_template::TaggedEnumField
• replication::compiled::CompiledReplication
• replication::orchestrator::ReplicationOptions
• replication::spec::ReplicationSpec
• replication::spec::SnapshotSpec
• replication::state::ReplicationState
• schedule::compiled::CompiledSchedule
• schedule::spec::ScheduleSpec
• schedule::state::SchedulerState
• secrets::ResolverSet
• secrets::registry::RedactingMakeWriter
• secrets::registry::RedactingWriter
• serve::cluster::ClusterConfig
• serve::cluster::ClusterHandle
• serve::config::ServeConfig
• serve::error::ApiError
• serve::error::ApiErrorBody
• serve::handlers::doctor::DoctorRequest
• serve::handlers::runs::ListQuery
• serve::handlers::runs::ListResponse
• serve::handlers::schemas::SchemaItem
• serve::handlers::schemas::SchemasResponse
• 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::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::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

Enums

• cli::Command
• cli::SchemaTarget
• config::BackoffSpec
• config::OnBatchErrorSpec
• config::OnError
• config::PoisonActionSpec
• error::CliError
• expand::NodeRole
• interpolate::Directive
• replication::spec::ReplicationMode
• replication::state::Phase
• replication::state::Plan
• 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::sql::Dialect
• serve::load::ConfigFormat
• serve::logs::LogEvent
• serve::logs::LogMsg
• 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

Traits

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

Functions

• auth_catalog::auth_ref
• auth_catalog::build_auth_catalog
• auth_catalog::resolve
• commands::doctor::count_failures
• commands::doctor::probe_invocation
• commands::doctor::probe_lineage
• commands::doctor::probe_roots
• commands::doctor::redact_invocations
• commands::doctor::run
• commands::init::run
• commands::list::run
• commands::preview::run
• commands::replicate::run
• commands::report
• commands::run::run
• commands::schedule::run
• commands::schema::lineage_schema
• commands::schema::run
• commands::serve::run
• commands::validate::run
• compose::compose
• config::parse_with_extension
• 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
• merge::merge_value
• obs::build_observability_config
• obs::install
• obs::resolve_tracing_level
• registry::build_sink
• registry::build_source
• registry::sink_descriptions
• registry::sink_exists
• 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_schema
• registry::source_supports_exactly_once
• replication::orchestrator::run_replication
• replication::state::cdc_state_key
• replication::state::marker_key
• replication::state::plan_from_marker
• run_from_yaml_str
• 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::run_outcome
• schedule::state::cooldown_delay
• secrets::collect_refs
• secrets::ensure_no_secret_directives
• secrets::registry::redact
• secrets::registry::register
• secrets::resolve_secrets
• secrets::resolve_secrets_with
• secrets::scan_path_refs
• secrets::substitute
• serve::auth::authorize_header
• serve::auth::require_auth
• serve::cluster::claim_loop
• serve::handlers::doctor::doctor
• serve::handlers::health::healthz
• serve::handlers::health::metrics
• serve::handlers::health::readyz
• serve::handlers::logs::stream_logs
• 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::connect
• serve::history::sql::decode_body
• serve::history::sql::encode_body
• 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::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
• state::available_state_kinds
• state::build_state_store
• transforms::available_transforms
• transforms::compile_transforms
• transforms::quality_descriptions
• transforms::transform_descriptions
• transforms::transform_schema

Type Aliases

• auth_catalog::AuthCatalog
• error::CliResult
• secrets::SecretRef

Constants

• expand::RESERVED_IDS
• registry::EXACTLY_ONCE_SOURCE_KINDS
• registry::IDEMPOTENT_SINK_KINDS
• registry::SCHEMA_EVOLUTION_SINK_KINDS
• registry::UPSERT_SINK_KINDS
• secrets::SECRET_SCHEMES
• 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