List of all items

Structs

• decode::DataDecoder
• decode::YieldingIter
• decode::avro::AvroDecoderState
• decode::csv::CsvDecoderState
• decode::protobuf::ProtobufDecoderState
• healthcheck::DefaultWriter
• healthcheck::HealthState
• healthcheck::HealthStatusMessage
• healthcheck::PerWorkerHealthStatus
• internal_control::DataflowParameters
• metrics::StorageMetrics
• metrics::decode::DecodeMetricDefs
• metrics::sink::SinkMetricDefs
• metrics::sink::kafka::KafkaSinkMetricDefs
• metrics::sink::kafka::KafkaSinkMetrics
• metrics::source::GeneralSourceMetricDefs
• metrics::source::OffsetCommitMetrics
• metrics::source::SourceMetricDefs
• metrics::source::SourceMetrics
• metrics::source::SourcePersistSinkMetrics
• metrics::source::kafka::KafkaSourceMetricDefs
• metrics::source::kafka::KafkaSourceMetrics
• metrics::source::mysql::MySqlSnapshotMetricDefs
• metrics::source::mysql::MySqlSnapshotMetrics
• metrics::source::mysql::MySqlSourceMetricDefs
• metrics::source::mysql::MySqlSourceMetrics
• metrics::source::postgres::PgSnapshotMetrics
• metrics::source::postgres::PgSourceMetricDefs
• metrics::source::postgres::PgSourceMetrics
• metrics::upsert::UpsertBackpressureMetricDefs
• metrics::upsert::UpsertMetricDefs
• metrics::upsert::UpsertMetrics
• metrics::upsert::UpsertSharedMetrics
• render::persist_sink::BatchBuilderAndMetadata
• render::persist_sink::BatchMetrics
• render::persist_sink::BatchSet
• render::persist_sink::FinishedBatch
• render::persist_sink::HollowBatchAndMetadata
• render::sources::KV
• server::Config
• server::Server
• sink::kafka::KafkaHeader
• sink::kafka::KafkaMessage
• sink::kafka::LegacyProgressRecord
• sink::kafka::ProgressRecord
• sink::kafka::TransactionalProducer
• source::KafkaSourceReader
• source::RawSourceCreationConfig
• source::SourceExportCreationConfig
• source::generator::Auction
• source::generator::Clock
• source::generator::Counter
• source::generator::Datums
• source::generator::Tpch
• source::generator::auction::Auction
• source::generator::clock::Clock
• source::generator::counter::Counter
• source::generator::datums::Datums
• source::generator::key_value::PartitionKeyIterator
• source::generator::key_value::TransactionalSnapshotProducer
• source::generator::key_value::UpdateProducer
• source::generator::marketing::FutureUpdates
• source::generator::marketing::Lead
• source::generator::marketing::Marketing
• source::generator::tpch::Context
• source::generator::tpch::Tpch
• source::kafka::GlueConsumerContext
• source::kafka::HealthStatus
• source::kafka::KafkaResumeUpperProcessor
• source::kafka::KafkaSourceReader
• source::kafka::MetadataUpdate
• source::kafka::PartialProgressStatistics
• source::kafka::PartitionCapability
• source::kafka::PartitionConsumer
• source::kafka::SourceOutputInfo
• source::mysql::MySqlTableName
• source::mysql::RewindRequest
• source::mysql::SourceOutputInfo
• source::mysql::replication::context::ReplContext
• source::mysql::replication::partitions::GtidReplicationPartitions
• source::mysql::snapshot::TableStatistics
• source::postgres::SlotMetadata
• source::postgres::SourceOutputInfo
• source::postgres::replication::RewindRequest
• source::postgres::snapshot::TableStatistics
• source::reclock::ReclockBatch
• source::reclock::ReclockOperator
• source::reclock::compat::PersistHandle
• source::source_reader_pipeline::FrontierCapture
• source::source_reader_pipeline::RawSourceCreationConfig
• source::source_reader_pipeline::SourceExportCreationConfig
• source::types::DecodeResult
• source::types::Probe
• source::types::SignaledFuture
• source::types::SourceMessage
• source::types::SourceOutput
• source::types::columnation::SourceMessageRegion
• statistics::AggregatedStatistics
• statistics::SinkStatisticsMetricDefs
• statistics::SinkStatisticsMetrics
• statistics::SinkStatisticsRecord
• statistics::SourceStatisticsMetadata
• statistics::SourceStatisticsMetricDefs
• statistics::SourceStatisticsMetrics
• statistics::SourceStatisticsRecord
• statistics::StatsInner
• statistics::StorageStatistics
• storage_state::StorageInstanceContext
• storage_state::StorageState
• storage_state::Worker
• storage_state::async_storage_worker::ActivatingSender
• storage_state::async_storage_worker::AsyncStorageWorker
• upsert::DigestHasher
• upsert::UpsertConfig
• upsert::UpsertKey
• upsert::autospill::AutoSpillBackend
• upsert::memory::InMemoryHashMap
• upsert::rocksdb::RocksDB
• upsert::types::Consolidating
• upsert::types::GetStats
• upsert::types::MergeStats
• upsert::types::MergeValue
• upsert::types::PutStats
• upsert::types::PutValue
• upsert::types::SnapshotStats
• upsert::types::UpsertState
• upsert::types::UpsertValueAndSize
• upsert::types::ValueMetadata

Enums

• decode::DataDecoderInner
• decode::PreDelimitedFormat
• healthcheck::HealthStatusUpdate
• healthcheck::OverallStatus
• healthcheck::StatusNamespace
• internal_control::InternalStorageCommand
• source::generator::GeneratorKind
• source::kafka::KafkaHeaderParseError
• source::mysql::DefiniteError
• source::mysql::ReplicationError
• source::mysql::TransientError
• source::postgres::DefiniteError
• source::postgres::ReplicationError
• source::postgres::TransientError
• source::types::ProgressStatisticsUpdate
• storage_state::async_storage_worker::AsyncStorageWorkerCommand
• storage_state::async_storage_worker::AsyncStorageWorkerResponse
• upsert::DrainStyle
• upsert::autospill::BackendType
• upsert::types::StateValue
• upsert::types::Value
• upsert_continual_feedback::DrainStyle

Traits

• healthcheck::HealthOperator
• internal_control::InternalCommandSender
• render::sinks::SinkRender
• source::types::SourceRender
• upsert::UpsertErrorEmitter
• upsert::types::UpsertStateBackend

Functions

• decode::decode_delimited
• decode::get_decoder
• decode::render_decode_cdcv2
• decode::render_decode_delimited
• healthcheck::health_operator
• internal_control::setup_command_sequencer
• render::build_export_dataflow
• render::build_ingestion_dataflow
• render::persist_sink::append_batches
• render::persist_sink::mint_batch_descriptions
• render::persist_sink::render
• render::persist_sink::write_batches
• render::sinks::get_sink_render_for
• render::sinks::render_sink
• render::sinks::zip_into_diff_pairs
• render::sources::append_metadata_to_value
• render::sources::flatten_results_prepend_keys
• render::sources::get_backpressure_max_inflight_bytes
• render::sources::raise_key_value_errors
• render::sources::render_source
• render::sources::render_source_stream
• render::sources::split_ok_err
• render::sources::upsert_commands
• server::serve
• sink::kafka::collect_statistics
• sink::kafka::deserialize_frontier
• sink::kafka::deserialize_some
• sink::kafka::determine_sink_progress
• sink::kafka::encode_collection
• sink::kafka::encode_headers
• sink::kafka::evaluate_partition_by
• sink::kafka::fetch_partition_count
• sink::kafka::fetch_partition_count_loop
• sink::kafka::parse_progress_record
• sink::kafka::serialize_frontier
• sink::kafka::sink_collection
• source::create_raw_source
• source::generator::key_value::create_consistent_rng
• source::generator::key_value::render
• source::generator::key_value::render_statistics_operator
• source::generator::render_simple_generator
• source::generator::tpch::date
• source::generator::tpch::decimal
• source::generator::tpch::order_key
• source::generator::tpch::pad_nine
• source::generator::tpch::partkey_retailprice
• source::generator::tpch::phone
• source::generator::tpch::syllables
• source::generator::tpch::text_string
• source::generator::tpch::v_string
• source::kafka::construct_source_message
• source::kafka::fetch_partition_info
• source::kafka::render_metadata_fetcher
• source::kafka::render_reader
• source::kafka::responsible_for_pid
• source::kafka::spawn_metadata_thread
• source::mysql::replication::events::handle_query_event
• source::mysql::replication::events::handle_rows_event
• source::mysql::replication::events::table_ident
• source::mysql::replication::raw_stream
• source::mysql::replication::render
• source::mysql::return_definite_error
• source::mysql::schemas::verify_schemas
• source::mysql::snapshot::collect_table_statistics
• source::mysql::snapshot::fetch_snapshot_size
• source::mysql::snapshot::render
• source::mysql::statistics::aggregate_mysql_frontier
• source::mysql::statistics::render
• source::mysql::validate_mysql_repl_settings
• source::postgres::cast_row
• source::postgres::decode_utf8_text
• source::postgres::ensure_replication_slot
• source::postgres::fetch_max_lsn
• source::postgres::fetch_slot_metadata
• source::postgres::replication::ensure_publication_exists
• source::postgres::replication::ensure_replication_timeline_id
• source::postgres::replication::extract_transaction
• source::postgres::replication::raw_stream
• source::postgres::replication::render
• source::postgres::replication::unpack_tuple
• source::postgres::snapshot::collect_table_statistics
• source::postgres::snapshot::decode_copy_row
• source::postgres::snapshot::export_snapshot
• source::postgres::snapshot::export_snapshot_inner
• source::postgres::snapshot::fetch_snapshot_size
• source::postgres::snapshot::render
• source::postgres::snapshot::set_statement_timeout
• source::postgres::snapshot::use_snapshot
• source::postgres::verify_schema
• source::source_reader_pipeline::create_raw_source
• source::source_reader_pipeline::demux_source_exports
• source::source_reader_pipeline::reclock_committed_upper
• source::source_reader_pipeline::remap_operator
• source::source_reader_pipeline::source_render_operator
• source::source_reader_pipeline::synthesize_probes
• source::statistics::process_statistics
• storage_state::async_storage_worker::reclock_resume_uppers
• upsert::drain_staged_input
• upsert::process_upsert_state_error
• upsert::rehydration_finished
• upsert::stage_input
• upsert::types::consolidating_merge_function
• upsert::types::upsert_bincode_opts
• upsert::upsert
• upsert::upsert_classic
• upsert::upsert_operator
• upsert::upsert_thinning
• upsert_continual_feedback::drain_staged_input
• upsert_continual_feedback::stage_input
• upsert_continual_feedback::upsert_inner

Type Aliases

• render::sources::OutputIndex
• source::kafka::HighWatermark
• source::mysql::StackedAsyncOutputHandle
• source::types::StackedCollection
• statistics::SinkStatistics
• statistics::SourceStatistics
• storage_state::CommandReceiver
• storage_state::ResponseSender
• upsert::KeyHash
• upsert::UpsertValue
• upsert::types::BincodeOpts

Statics

• source::generator::tpch::CURRENT_DATE
• source::generator::tpch::END_DATE
• source::generator::tpch::ORDER_END_DAYS
• source::generator::tpch::START_DATE
• source::mysql::replication::REPLICATION_SERVER_ID_OFFSET
• source::mysql::replication::REPL_READER
• source::mysql::statistics::STATISTICS
• source::postgres::replication::PG_EPOCH

Constants

• source::generator::auction::AUCTIONS
• source::generator::auction::CELEBRETIES
• source::generator::auction::COMPANIES
• source::generator::marketing::CONTROL
• source::generator::marketing::CUSTOMERS
• source::generator::marketing::EXPERIMENT
• source::generator::tpch::CONTAINERS
• source::generator::tpch::INSTRUCTIONS
• source::generator::tpch::MODES
• source::generator::tpch::NATIONS
• source::generator::tpch::PARTNAMES
• source::generator::tpch::PRIORITIES
• source::generator::tpch::REGIONS
• source::generator::tpch::SEGMENTS
• source::generator::tpch::TYPES