List of all items

Structs

• admin::AdminServer
• admin::HealthState
• admin::HealthThresholds
• backpressure::BackpressureParams
• backpressure::InflightBudget
• backpressure::MonotonicClock
• backpressure::WatermarkController
• checkpoint::AckIssuer
• checkpoint::AckMsg
• checkpoint::AckRef
• checkpoint::AckSet
• checkpoint::BatchId
• checkpoint::Checkpointer
• checkpoint::DrainStats
• checkpoint::PartitionTracker
• config::BackpressureSection
• config::CheckpointSection
• config::ComponentConfig
• config::MetricsSection
• config::PipelineConfig
• config::PipelineSection
• deser::BytesPassthrough
• deser::Owned
• error::FatalError
• metrics::BackpressureMetrics
• metrics::CheckpointMetrics
• metrics::ComponentLabels
• metrics::DeserMetrics
• metrics::MetricsHandle
• metrics::MetricsSettings
• metrics::OperatorMetrics
• metrics::PipelineMetrics
• metrics::QueueMetrics
• metrics::SinkShardMetrics
• metrics::SourceMetrics
• ops::ChainBuilder
• ops::ChainFactory
• ops::ChunkConfig
• ops::Emitter
• ops::Filter
• ops::FilterPart
• ops::FlatMap
• ops::FlatMapPart
• ops::Inspect
• ops::InspectPart
• ops::Map
• ops::MapPart
• ops::Root
• ops::SinkHandoff
• ops::SinkedChain
• ops::TryMap
• ops::TryMapPart
• ops::TypedChain
• pipeline::ChainCtx
• pipeline::ExitReport
• pipeline::FatalErrorReport
• pipeline::Pipeline
• pipeline::PipelineRuntime
• pipeline::RuntimeOptions
• pipeline::ShutdownHandle
• pipeline::SinkOptions
• pipeline::SinkRuntime
• record::PartitionId
• record::RawPayload
• record::Record
• record::RecordMeta
• sink::BatchConfig
• sink::BreakerConfig
• sink::ChunkSendError
• sink::DrainReport
• sink::EncodedChunk
• sink::InflightConfig
• sink::KeyHashRouter
• sink::RetryConfig
• sink::SealedBatch
• sink::ShardQueues
• sink::SinkParts
• sink::SinkPool
• sink::SinkPoolConfig
• source::DrainBarrier
• source::LaneId
• source::SourceCtx
• telemetry::RateLimit

Enums

• backpressure::Transition
• checkpoint::AckStatus
• checkpoint::ResolveOutcome
• config::ConfigError
• config::E2eBasis
• config::MetricsExporter
• config::PinningMode
• config::YamlValue
• error::DeserError
• error::ErrorClass
• error::ErrorPolicy
• error::SinkError
• error::SourceError
• metrics::E2eBasis
• metrics::Exporter
• metrics::FlushReason
• metrics::MetricsError
• metrics::PipelineState
• ops::BlockReason
• ops::PushOutcome
• pipeline::BuildError
• pipeline::ExitState
• pipeline::PipelineError
• pipeline::StartError
• record::Flow
• source::SourceEvent
• telemetry::Decision
• telemetry::LogFormat

Traits

• backpressure::Clock
• deser::Deserializer
• deser::EmitRecord
• deser::RecFamily
• ops::Assemble
• ops::Collector
• ops::CollectorFor
• ops::RunnableChain
• ops::StageLifecycle
• sink::RowEncoder
• sink::ShardRouter
• sink::ShardWriter
• sink::SinkBundle
• source::PayloadBatch
• source::Source
• source::SourceLane

Macros

• rate_limited_warn

Functions

• metrics::install
• ops::chain
• ops::chain_owned
• pipeline::metrics_settings
• record::stable_key_hash
• sink::endpoint_probe
• sink::shard_queues
• telemetry::init

Type Aliases

• admin::RenderFn
• sink::SinkDrainFn
• sink::SinkProbeFn

Constants

• metrics::BATCH_BYTES_BUCKETS
• metrics::BATCH_ROWS_BUCKETS
• metrics::DURATION_SECONDS_BUCKETS
• metrics::names::BACKPRESSURE_INFLIGHT_BYTES
• metrics::names::BACKPRESSURE_PAUSED
• metrics::names::BACKPRESSURE_PAUSED_SECONDS_TOTAL
• metrics::names::BACKPRESSURE_PAUSE_EVENTS_TOTAL
• metrics::names::CHECKPOINT_COMMITS_TOTAL
• metrics::names::CHECKPOINT_COMMIT_DURATION_SECONDS
• metrics::names::CHECKPOINT_PENDING_BATCHES
• metrics::names::CHECKPOINT_WATERMARK_AGE_SECONDS
• metrics::names::COUNTERS
• metrics::names::DESER_BATCH_DURATION_SECONDS
• metrics::names::DESER_NOT_READY_TOTAL
• metrics::names::DESER_RECORDS_DROPPED_TOTAL
• metrics::names::DESER_RECORDS_TOTAL
• metrics::names::E2E_LATENCY_SECONDS
• metrics::names::GAUGES
• metrics::names::HISTOGRAMS
• metrics::names::L_COMPONENT
• metrics::names::L_COMPONENT_TYPE
• metrics::names::L_ERROR_TYPE
• metrics::names::L_EVENT
• metrics::names::L_OUTCOME
• metrics::names::L_PARTITION
• metrics::names::L_PIPELINE
• metrics::names::L_QUEUE
• metrics::names::L_REASON
• metrics::names::L_REPLICA
• metrics::names::L_SHARD
• metrics::names::L_STATE
• metrics::names::L_VERSION
• metrics::names::OPERATOR_BATCH_DURATION_SECONDS
• metrics::names::OPERATOR_ERRORS_TOTAL
• metrics::names::OPERATOR_RECORDS_DROPPED_TOTAL
• metrics::names::OPERATOR_RECORDS_IN_TOTAL
• metrics::names::OPERATOR_RECORDS_OUT_TOTAL
• metrics::names::PIPELINE_INFO
• metrics::names::PIPELINE_STATE
• metrics::names::PIPELINE_THREADS
• metrics::names::QUEUE_CAPACITY
• metrics::names::QUEUE_DEPTH
• metrics::names::QUEUE_FULL_EVENTS_TOTAL
• metrics::names::SINK_ABANDONED_BATCHES_TOTAL
• metrics::names::SINK_BATCH_BYTES
• metrics::names::SINK_BATCH_ROWS
• metrics::names::SINK_BREAKER_OPENS_TOTAL
• metrics::names::SINK_BYTES_TOTAL
• metrics::names::SINK_ERRORS_TOTAL
• metrics::names::SINK_FLUSHES_TOTAL
• metrics::names::SINK_FLUSH_DURATION_SECONDS
• metrics::names::SINK_INFLIGHT_BATCHES
• metrics::names::SINK_RECORDS_TOTAL
• metrics::names::SINK_REPLICA_HEALTHY
• metrics::names::SINK_RETRIES_TOTAL
• metrics::names::SOURCE_BYTES_TOTAL
• metrics::names::SOURCE_LAG_RECORDS
• metrics::names::SOURCE_LANES_ACTIVE
• metrics::names::SOURCE_POLL_DURATION_SECONDS
• metrics::names::SOURCE_REBALANCES_TOTAL
• metrics::names::SOURCE_RECORDS_TOTAL