List of all items

Structs

• CancellationToken
• adaptive::AdaptiveBatchConfig
• adaptive::Adjustment
• adaptive::AimdController
• adaptive::Observation
• auth::AuthReference
• check::CheckContext
• check::CheckReport
• check::Probe
• contract::ContractOutcome
• contract::ContractViolation
• contract::ViolatingRecord
• contract::compile::CompiledContract
• contract::compile::CompiledField
• contract::config::ContractSpec
• contract::config::FieldContract
• dlq::DlqConfig
• dlq::DlqStats
• dlq::UnwrappedEnvelope
• drift::ColumnChange
• drift::SchemaDiff
• drift::SchemaDriftPolicy
• drift::SchemaDriftSpec
• drift::SchemaEvolution
• idempotency::GuaranteeInputs
• masking::MaskHit
• masking::MaskingOutcome
• masking::compile::CompiledMasking
• masking::config::MaskRule
• masking::config::MaskingSpec
• masking::config::MatchSpec
• observability::DurationGuard
• observability::InstallReport
• observability::InstrumentedSink
• observability::InstrumentedSource
• observability::InstrumentedStateStore
• observability::Labels
• observability::ObservabilityConfig
• observability::PrometheusConfig
• observability::RunStreamOptions
• observability::TracingConfig
• observability::otel::OtelConfig
• observability::otel::OtelErrorCountLayer
• observability::otel::OtelGuard
• pipeline::Pipeline
• pipeline::PipelineResult
• pipeline::StreamPage
• quality::CheckTally
• quality::QualityOutcome
• quality::QuarantinedRecord
• quality::compile::CompiledBatchCheck
• quality::compile::CompiledQuality
• quality::compile::CompiledRecordCheck
• quality::config::QualitySpec
• resilience::CircuitBreaker
• resilience::CircuitBreakerConfig
• resilience::PoisonPolicy
• resilience::ResiliencePolicy
• resilience::RetryClassSet
• resilience::RetryMetrics
• resilience::RetryPolicy
• shard::HashShard
• shard::PkShardBounds
• shard::ShardSpec
• stage::CdcUnwrapSpec
• stage::CompiledCdcUnwrap
• stage::CompiledExplode
• stage::CompiledFilter
• stage::CompiledPath
• stage::ExplodeSpec
• stage::FilterSpec
• state::FileStateStore
• state::MemoryStateStore
• transforming_source::TransformingSource
• verify::LengthCheck
• verify::VerifyingReader
• write_mode::DeleteMarker
• write_mode::KeyTuple
• write_mode::WritePlan
• write_mode::WriteSpec

Enums

• Value
• adaptive::AdjustDirection
• adaptive::AdjustReason
• auth::AuthSpec
• auth::Credential
• check::ProbeStatus
• compression::Compression
• compression::CompressionConfig
• compression::SyncCompressWriter
• contract::config::ContractFieldType
• contract::config::OnBreach
• dlq::DlqReason
• dlq::EnvelopeError
• dlq::OnBatchError
• drift::OnDrift
• drift::OnIncompatible
• drift::SqlBaseType
• error::FaucetError
• idempotency::DeliveryGuarantee
• idempotency::DeliveryMode
• idempotency::EffectivelyOnceMechanism
• idempotency::ReplayGuarantee
• idempotency::SinkGuarantee
• masking::config::Detector
• masking::config::MaskAction
• observability::InstallError
• observability::otel::OtelProtocol
• observability::otel::OtelSignal
• quality::compile::CompiledBatchKind
• quality::compile::CompiledRecordKind
• quality::config::BatchCheck
• quality::config::CompareOp
• quality::config::JsonType
• quality::config::OnFailure
• quality::config::RecordCheck
• replication::ReplicationMethod
• resilience::BackoffKind
• resilience::PoisonAction
• resilience::RetryClass
• stage::CompiledStage
• stage::FilterOp
• stage::OnMissing
• stage::PathSegment
• stage::TransformStage
• transform::CastOnError
• transform::CastType
• transform::CompiledTransform
• transform::KeyCaseMode
• transform::RecordTransform
• transform::ValueCaseMode
• write_mode::WriteMode

Traits

• JsonSchema
• Stream
• auth::AuthProvider
• state::StateStore
• traits::Sink
• traits::Source
• verify::IntegrityCheck

Macros

• json
• schema_for

Attribute Macros

• async_trait

Derive Macros

• JsonSchema

Functions

• compression::compress_buf
• compression::detect_from_path
• compression::sync_compress_writer
• compression::warn_mismatch
• compression::wrap_async_reader
• compression::wrap_async_writer
• compression::wrap_sync_reader
• compression::wrap_sync_writer
• config::duration_secs::deserialize
• config::duration_secs::serialize
• config::duration_secs_option::deserialize
• config::duration_secs_option::serialize
• config::load_env
• config::load_env_file
• config::load_json
• contract::apply_contract
• contract::export::to_json_schema
• contract::export::to_openlineage_facet
• dlq::build_envelope
• dlq::unwrap_envelope
• drift::adds_null
• drift::base_widened
• drift::diff_schema
• drift::json_schema_base_type
• idempotency::derive_delivery_guarantee
• idempotency::format_token
• idempotency::format_token_with_bookmark
• idempotency::parse_token
• idempotency::parse_token_parts
• idempotency::unwrap_state
• idempotency::wrap_state
• masking::apply_masking
• observability::install_observability
• observability::instrumented_apply_contract
• observability::instrumented_apply_masking
• observability::instrumented_apply_quality
• observability::instrumented_apply_stages
• observability::otel::build_meter_provider
• observability::otel::build_trace_provider
• observability::otel::describe
• observability::otel::install_propagator
• observability::otel::set_guard
• observability::otel::shutdown_otel
• observability::register_build_info
• observability::resilience::circuit_opened
• observability::resilience::describe
• observability::resilience::giveup
• observability::resilience::poison_rows
• observability::resilience::retry
• observability::resilience::retry_sleep
• observability::schema_drift
• observability::strip_type_name
• observability::update_bookmark_lag
• pipeline::run_stream
• pipeline::validate_batch_size
• quality::apply_quality
• quality::batch::evaluate_aggregate_check
• quality::batch::evaluate_unique_check
• quality::record::evaluate_record_check
• replication::filter_incremental
• replication::max_replication_value
• replication::max_value
• resilience::classify
• resilience::execute_with_policy
• resilience::execute_with_policy_metered
• retry::backoff_with_jitter
• retry::execute_with_retry
• schema::infer_schema
• shard::parse_hash_shard
• shard::parse_pk_shard
• shard::pk_bounds_query
• shard::pk_shards_from_bounds
• shard::plan_hash_shards
• shard::plan_pk_shards
• shard::shard_hash
• stage::apply_stages
• stage::apply_stages_to_page
• stage::compile_stage
• state::validate_state_key
• transform::apply_all
• transform::compile
• transform::default_symbol_map
• util::check_http_response
• util::extract_context
• util::extract_records
• util::quote_ident
• util::redact_uri_credentials
• util::substitute_context
• util::substitute_context_bind_params
• util::substitute_context_json
• write_mode::key_to_doc_id
• write_mode::key_to_filter
• write_mode::plan_writes

Type Aliases

• auth::SharedAuthProvider
• observability::otel::OtelError
• stage::PageFnBox
• traits::RowOutcome

Constants

• contract::export::OPENLINEAGE_SCHEMA_FACET_URL
• idempotency::COMMIT_TOKEN_SCOPE_COL
• idempotency::COMMIT_TOKEN_TABLE
• idempotency::COMMIT_TOKEN_TOKEN_COL
• idempotency::ICEBERG_SCOPE_PROP
• idempotency::ICEBERG_TOKEN_PROP
• pipeline::DEFAULT_BATCH_SIZE
• pipeline::MAX_BATCH_SIZE
• state::DOCTOR_SENTINEL_KEY
• util::DEFAULT_ERROR_BODY_MAX_LEN