List of all items
Structs
- cli::Cli
- cli::DoctorArgs
- cli::InitArgs
- cli::PreviewArgs
- cli::RunArgs
- cli::ScheduleArgs
- cli::SchemaArgs
- cli::ServeArgs
- cli::ValidateArgs
- commands::doctor::InvocationOut
- commands::doctor::ProbeOut
- config::ConnectorSpec
- config::DlqSpec
- config::ExecutionSpec
- config::MatrixRow
- config::ObservabilitySpec
- config::PartialConnector
- config::PipelineConfig
- config::PipelineSpec
- config::PrometheusSpec
- config::StateStoreSpec
- config::TracingSpec
- config::TransformSpec
- executor::ExecuteOptions
- executor::InvocationOutcome
- executor::RunSummary
- expand::DeferredRef
- expand::ExpandedNode
- init_template::TaggedEnumField
- schedule::compiled::CompiledSchedule
- schedule::spec::ScheduleSpec
- schedule::state::SchedulerState
- secrets::ResolverSet
- secrets::registry::RedactingMakeWriter
- secrets::registry::RedactingWriter
- serve::config::ServeConfig
- serve::error::ApiError
- serve::error::ApiErrorBody
- serve::handlers::runs::ListQuery
- serve::handlers::runs::ListResponse
- serve::history::InvocationRecord
- serve::history::ListFilter
- serve::history::ListPage
- serve::history::RunRecord
- 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
Enums
- cli::Command
- cli::SchemaTarget
- config::OnBatchErrorSpec
- config::OnError
- error::CliError
- expand::NodeRole
- interpolate::Directive
- 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
Traits
Functions
- auth_catalog::auth_ref
- auth_catalog::build_auth_catalog
- auth_catalog::resolve
- commands::doctor::count_failures
- commands::doctor::probe_invocation
- commands::doctor::probe_roots
- commands::doctor::redact_invocations
- commands::doctor::run
- commands::init::run
- commands::list::run
- commands::preview::run
- commands::report
- commands::run::run
- commands::schedule::run
- commands::schema::run
- commands::serve::run
- commands::validate::run
- 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::iter_directives
- interpolate::resolve_config_refs
- interpolate::resolve_now
- merge::merge_value
- 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::source_descriptions
- registry::source_exists
- registry::source_kinds
- registry::source_schema
- 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
- 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::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::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::set_history_degraded
- serve::metrics::set_run_gauges
- serve::metrics::track_metrics
- serve::observability::install
- serve::run_server
- serve::runner::submit
- serve::server::build_router
- serve::server::serve
- state::available_state_kinds
- state::build_state_store
- transforms::available_transforms
- transforms::compile_transforms
- transforms::quality_descriptions
- transforms::transform_descriptions
- transforms::transform_schema