List of all items

Structs

• cdc::mysql::changelog::ChangeEvent
• cdc::mysql::config::MySqlCdcConfig
• cdc::mysql::decoder::BeginMessage
• cdc::mysql::decoder::BinlogPosition
• cdc::mysql::decoder::CommitMessage
• cdc::mysql::decoder::DeleteMessage
• cdc::mysql::decoder::InsertMessage
• cdc::mysql::decoder::QueryMessage
• cdc::mysql::decoder::RotateMessage
• cdc::mysql::decoder::RowData
• cdc::mysql::decoder::TableMapMessage
• cdc::mysql::decoder::UpdateMessage
• cdc::mysql::decoder::UpdateRowData
• cdc::mysql::gtid::Gtid
• cdc::mysql::gtid::GtidRange
• cdc::mysql::gtid::GtidSet
• cdc::mysql::metrics::MetricsSnapshot
• cdc::mysql::metrics::MySqlCdcMetrics
• cdc::mysql::schema::TableCache
• cdc::mysql::schema::TableInfo
• cdc::mysql::source::MySqlCdcSource
• cdc::mysql::types::MySqlColumn
• cdc::postgres::changelog::ChangeEvent
• cdc::postgres::config::PostgresCdcConfig
• cdc::postgres::decoder::BeginMessage
• cdc::postgres::decoder::CommitMessage
• cdc::postgres::decoder::DeleteMessage
• cdc::postgres::decoder::InsertMessage
• cdc::postgres::decoder::OriginMessage
• cdc::postgres::decoder::RelationMessage
• cdc::postgres::decoder::TruncateMessage
• cdc::postgres::decoder::TupleData
• cdc::postgres::decoder::TypeMessage
• cdc::postgres::decoder::UpdateMessage
• cdc::postgres::lsn::Lsn
• cdc::postgres::metrics::PostgresCdcMetrics
• cdc::postgres::schema::RelationCache
• cdc::postgres::schema::RelationInfo
• cdc::postgres::source::PostgresCdcSource
• cdc::postgres::types::PgColumn
• checkpoint::RuntimeCheckpoint
• checkpoint::SourceCheckpoint
• config::ConfigKeySpec
• config::ConnectorConfig
• config::ConnectorInfo
• connector::PartitionInfo
• connector::SinkConnectorCapabilities
• connector::SourceBatch
• connector::WriteResult
• files::arrow_ipc_codec::ArrowIpcDecoder
• files::arrow_ipc_codec::ArrowIpcEncoder
• files::config::FileSinkConfig
• files::config::FileSourceConfig
• files::discovery::DiscoveredFile
• files::discovery::DiscoveryConfig
• files::discovery::FileDiscoveryEngine
• files::manifest::FileEntry
• files::manifest::FileIngestionManifest
• files::sink::FileSink
• files::source::FileSource
• files::text_decoder::TextLineDecoder
• kafka::avro::AvroDeserializer
• kafka::avro_serializer::AvroSerializer
• kafka::config::KafkaSourceConfig
• kafka::config::SrAuth
• kafka::metrics::KafkaSourceMetrics
• kafka::offsets::OffsetTracker
• kafka::partitioner::KeyHashPartitioner
• kafka::partitioner::RoundRobinPartitioner
• kafka::partitioner::StickyPartitioner
• kafka::rebalance::LaminarConsumerContext
• kafka::rebalance::RebalanceState
• kafka::schema_registry::CachedSchema
• kafka::schema_registry::CompatibilityResult
• kafka::schema_registry::SchemaRegistryCacheConfig
• kafka::schema_registry::SchemaRegistryClient
• kafka::sink::KafkaSink
• kafka::sink_config::KafkaSinkConfig
• kafka::sink_metrics::KafkaSinkMetrics
• kafka::source::KafkaSource
• kafka::watermarks::KafkaWatermarkTracker
• kafka::watermarks::WatermarkMetrics
• lakehouse::delta::DeltaLakeSink
• lakehouse::delta_config::CompactionConfig
• lakehouse::delta_config::DeltaLakeSinkConfig
• lakehouse::delta_config::ParquetWriteConfig
• lakehouse::delta_io::CompactionResult
• lakehouse::delta_io::MergeResult
• lakehouse::delta_metrics::DeltaLakeSinkMetrics
• lakehouse::delta_source::DeltaSource
• lakehouse::delta_source_config::DeltaSourceConfig
• lakehouse::iceberg::IcebergSink
• lakehouse::iceberg_config::IcebergCatalogConfig
• lakehouse::iceberg_config::IcebergSinkConfig
• lakehouse::iceberg_config::IcebergSourceConfig
• lakehouse::iceberg_reference::IcebergReferenceTableSource
• lakehouse::iceberg_source::IcebergSource
• lakehouse::metrics::LakehouseSinkMetrics
• lookup::NoOpTableLoader
• lookup::cdc_adapter::CdcTableSource
• lookup::delta_lookup::DeltaLookupSource
• lookup::delta_lookup::DeltaLookupSourceConfig
• lookup::delta_reference::DeltaReferenceTableSource
• lookup::parquet_source::ParquetLookupSource
• lookup::parquet_source::ParquetLookupSourceConfig
• lookup::postgres_reference::PostgresReferenceTableSource
• lookup::postgres_source::PostgresLookupSource
• lookup::postgres_source::PostgresLookupSourceConfig
• metrics::ConnectorMetrics
• mongodb::change_event::MongoDbChangeEvent
• mongodb::change_event::Namespace
• mongodb::change_event::TruncatedArray
• mongodb::change_event::UpdateDescription
• mongodb::config::MongoDbSinkConfig
• mongodb::config::MongoDbSourceConfig
• mongodb::config::WriteConcernConfig
• mongodb::large_event::EventFragment
• mongodb::large_event::LargeEventReassembler
• mongodb::large_event::SplitEventInfo
• mongodb::metrics::MongoDbCdcMetrics
• mongodb::metrics::MongoDbSinkMetrics
• mongodb::resume_token::FileResumeTokenStore
• mongodb::resume_token::InMemoryResumeTokenStore
• mongodb::resume_token::MongoResumeTokenStore
• mongodb::resume_token::ResumeToken
• mongodb::sink::MongoDbSink
• mongodb::source::MongoDbCdcSource
• mongodb::timeseries::TimeSeriesConfig
• nats::config::NatsSinkConfig
• nats::config::NatsSourceConfig
• nats::config::TlsConfig
• nats::metrics::NatsSinkMetrics
• nats::metrics::NatsSourceMetrics
• nats::sink::NatsSink
• nats::source::NatsSource
• otel::config::OtelSourceConfig
• otel::server::OtelReceiver
• otel::source::OtelSource
• postgres::sink::PostgresSink
• postgres::sink_config::PostgresSinkConfig
• postgres::sink_metrics::PostgresSinkMetrics
• reference::MockReferenceTableSource
• registry::ConnectorRegistry
• schema::csv::CsvDecoder
• schema::csv::CsvDecoderConfig
• schema::csv::CsvEncoder
• schema::csv::CsvEncoderConfig
• schema::evolution::SchemaEvolution
• schema::evolution::SchemaEvolutionEngine
• schema::evolution::SchemaHistory
• schema::evolution::SchemaHistoryEntry
• schema::json::decoder::JsonDecoder
• schema::json::decoder::JsonDecoderConfig
• schema::json::encoder::JsonEncoder
• schema::json::jsonb::JsonbAccessor
• schema::json::jsonb::JsonbEncoder
• schema::parquet::ParquetDecoder
• schema::parquet::ParquetDecoderConfig
• schema::parquet::ParquetEncoder
• schema::parquet::ParquetEncoderConfig
• schema::parquet::ParquetSchemaProvider
• schema::traits::ColumnProjection
• schema::traits::ConfigOption
• schema::traits::ConnectorConfigSchema
• schema::traits::FieldInferenceDetail
• schema::traits::InferenceConfig
• schema::traits::InferenceWarning
• schema::traits::InferredSchema
• schema::traits::RegisteredSchema
• schema::traits::RegistryConfig
• schema::traits::RegistryCredentials
• schema::types::FieldMeta
• schema::types::RawRecord
• schema::types::SinkConfig
• schema::types::SourceConfig
• schema::types::SourceMetadata
• serde::csv::CsvDeserializer
• serde::csv::CsvSerializer
• serde::debezium::DebeziumDeserializer
• serde::json::JsonDeserializer
• serde::json::JsonSerializer
• serde::raw::RawBytesDeserializer
• serde::raw::RawBytesSerializer
• storage::masking::SecretMasker
• storage::resolver::ResolvedStorageOptions
• storage::resolver::StorageCredentialResolver
• storage::validation::CloudConfigValidator
• storage::validation::CloudValidationError
• storage::validation::CloudValidationResult
• storage::validation::CloudValidationWarning
• testing::MockSinkConnector
• testing::MockSourceConnector
• websocket::checkpoint::WebSocketSourceCheckpoint
• websocket::connection::ConnectionManager
• websocket::fanout::BroadcastResult
• websocket::fanout::ClientState
• websocket::fanout::FanoutManager
• websocket::fanout::ReplayBuffer
• websocket::fanout::RingReceiver
• websocket::fanout::RingSender
• websocket::metrics::WebSocketSourceMetrics
• websocket::parser::MessageParser
• websocket::serializer::BatchSerializer
• websocket::sink::WebSocketSinkServer
• websocket::sink_client::WebSocketSinkClient
• websocket::sink_config::WebSocketSinkConfig
• websocket::sink_metrics::WebSocketSinkMetrics
• websocket::source::WebSocketSource
• websocket::source_config::ReconnectConfig
• websocket::source_config::WebSocketSourceConfig
• websocket::source_server::WebSocketSourceServer

Enums

• cdc::mysql::changelog::CdcOperation
• cdc::mysql::config::SnapshotMode
• cdc::mysql::config::SslMode
• cdc::mysql::decoder::BinlogMessage
• cdc::mysql::decoder::ColumnValue
• cdc::mysql::decoder::DecoderError
• cdc::mysql::gtid::GtidParseError
• cdc::postgres::changelog::CdcOperation
• cdc::postgres::config::SnapshotMode
• cdc::postgres::decoder::ColumnValue
• cdc::postgres::decoder::DecoderError
• cdc::postgres::decoder::WalMessage
• cdc::postgres::lsn::LsnParseError
• cdc::postgres::postgres_io::ReplicationMessage
• config::ConnectorState
• connector::DeliveryGuarantee
• connector::PostgresSslMode
• error::ConnectorError
• error::SerdeError
• files::config::FileFormat
• files::config::SinkMode
• health::HealthStatus
• kafka::config::AssignmentStrategy
• kafka::config::CompatibilityLevel
• kafka::config::IsolationLevel
• kafka::config::OffsetReset
• kafka::config::SaslMechanism
• kafka::config::SchemaEvolutionStrategy
• kafka::config::SecurityProtocol
• kafka::config::StartupMode
• kafka::config::SubjectNameStrategy
• kafka::config::TopicSubscription
• kafka::schema_registry::SchemaType
• kafka::sink_config::Acks
• kafka::sink_config::CompressionType
• kafka::sink_config::PartitionStrategy
• lakehouse::delta_config::DeltaCatalogType
• lakehouse::delta_config::DeltaWriteMode
• lakehouse::delta_source_config::DeltaReadMode
• lakehouse::delta_source_config::SchemaEvolutionAction
• lakehouse::iceberg_config::IcebergCatalogType
• lookup::LookupError
• lookup::LookupResult
• mongodb::change_event::OperationType
• mongodb::config::FullDocumentMode
• mongodb::config::WriteConcernLevel
• mongodb::large_event::LargeEventError
• mongodb::resume_token::ResumeTokenStoreConfig
• mongodb::resume_token::ResumeTokenStoreError
• mongodb::timeseries::CollectionKind
• mongodb::timeseries::TimeSeriesGranularity
• mongodb::write_model::WriteMode
• nats::config::AckPolicy
• nats::config::AuthMode
• nats::config::DeliverPolicy
• nats::config::Mode
• nats::config::SubjectSpec
• otel::config::OtelSignal
• postgres::sink_config::WriteMode
• reference::RefreshMode
• schema::WarningSeverity
• schema::csv::FieldCountMismatchStrategy
• schema::error::SchemaError
• schema::evolution::EvolutionResult
• schema::evolution::EvolutionTrigger
• schema::json::decoder::TypeMismatchStrategy
• schema::json::decoder::UnknownFieldStrategy
• schema::parquet::RowGroupPredicate
• schema::traits::ArrayInference
• schema::traits::CompatibilityMode
• schema::traits::ConfigValueType
• schema::traits::EvolutionVerdict
• schema::traits::NumberInference
• schema::traits::RegistrySchemaType
• schema::traits::SchemaChange
• schema::traits::WarningSeverity
• serde::Format
• serde::debezium::DebeziumOp
• storage::provider::StorageProvider
• websocket::backpressure::WsBackpressure
• websocket::fanout::RingSendResult
• websocket::protocol::ClientMessage
• websocket::protocol::ServerMessage
• websocket::sink_config::SinkFormat
• websocket::sink_config::SinkMode
• websocket::sink_config::SlowClientPolicy
• websocket::source_config::EventTimeFormat
• websocket::source_config::MessageFormat
• websocket::source_config::SourceMode
• websocket::source_config::WsAuthConfig

Traits

• connector::SinkConnector
• connector::SourceConnector
• kafka::partitioner::KafkaPartitioner
• lookup::TableLoader
• mongodb::resume_token::ResumeTokenStore
• reference::ReferenceTableSource
• registry::LookupSourceFactory
• schema::traits::FormatDecoder
• schema::traits::FormatEncoder
• schema::traits::SchemaProvider
• schema::traits::SchemaRegistryAware
• serde::RecordDeserializer
• serde::RecordSerializer

Functions

• cdc::mysql::changelog::cdc_metadata_schema
• cdc::mysql::changelog::column_value_to_json
• cdc::mysql::changelog::delete_to_events
• cdc::mysql::changelog::events_to_record_batch
• cdc::mysql::changelog::insert_to_events
• cdc::mysql::changelog::row_to_json
• cdc::mysql::changelog::update_to_events
• cdc::mysql::decoder::mysql_timestamp_to_unix_ms
• cdc::mysql::mysql_io::build_binlog_request
• cdc::mysql::mysql_io::build_opts
• cdc::mysql::mysql_io::build_ssl_opts
• cdc::mysql::mysql_io::connect
• cdc::mysql::mysql_io::decode_binlog_event
• cdc::mysql::mysql_io::read_events
• cdc::mysql::mysql_io::start_binlog_stream
• cdc::mysql::register_mysql_cdc_source
• cdc::mysql::schema::cdc_envelope_schema
• cdc::mysql::types::mysql_type_name
• cdc::mysql::types::mysql_type_to_arrow
• cdc::mysql::types::mysql_type_to_sql
• cdc::postgres::changelog::events_to_record_batch
• cdc::postgres::changelog::tuple_to_json
• cdc::postgres::decoder::decode_message
• cdc::postgres::decoder::pg_timestamp_to_unix_ms
• cdc::postgres::postgres_io::build_replication_config
• cdc::postgres::postgres_io::build_start_replication_query
• cdc::postgres::postgres_io::connect
• cdc::postgres::postgres_io::drop_replication_slot
• cdc::postgres::postgres_io::encode_standby_status
• cdc::postgres::postgres_io::ensure_replication_slot
• cdc::postgres::postgres_io::parse_replication_message
• cdc::postgres::register_postgres_cdc_source
• cdc::postgres::schema::cdc_envelope_schema
• cdc::postgres::types::pg_type_name
• cdc::postgres::types::pg_type_to_arrow
• config::decode_arrow_schema_ipc
• config::encode_arrow_schema_ipc
• config::parse_port
• config::require_non_empty
• files::register_file_sink
• files::register_file_source
• kafka::register_kafka_sink
• kafka::register_kafka_source
• kafka::schema_registry::arrow_to_avro_schema
• kafka::schema_registry::avro_to_arrow_schema
• lakehouse::delta_io::get_last_committed_epoch
• lakehouse::delta_io::get_latest_version
• lakehouse::delta_io::get_table_schema
• lakehouse::delta_io::map_cdf_to_changelog
• lakehouse::delta_io::merge_changelog
• lakehouse::delta_io::open_or_create_table
• lakehouse::delta_io::read_batches_at_version
• lakehouse::delta_io::read_cdf_batches
• lakehouse::delta_io::read_version_diff
• lakehouse::delta_io::resolve_catalog_options
• lakehouse::delta_io::run_compaction
• lakehouse::delta_io::run_vacuum
• lakehouse::delta_io::write_batches
• lakehouse::delta_table_provider::register_delta_table
• lakehouse::iceberg_config::validate_sink_schema
• lakehouse::iceberg_incremental::scan_incremental
• lakehouse::iceberg_io::build_catalog
• lakehouse::iceberg_io::commit_data_files
• lakehouse::iceberg_io::current_snapshot_id
• lakehouse::iceberg_io::ensure_table_exists
• lakehouse::iceberg_io::get_last_committed_epoch
• lakehouse::iceberg_io::load_table
• lakehouse::iceberg_io::scan_table
• lakehouse::register_delta_lake_sink
• lakehouse::register_delta_lake_source
• lakehouse::register_iceberg_sink
• lakehouse::register_iceberg_source
• lakehouse::register_lakehouse_sinks
• lakehouse::register_lakehouse_sources
• lookup::postgres_source::build_query
• mongodb::register_mongodb_cdc_source
• mongodb::register_mongodb_sink
• mongodb::source::mongodb_cdc_envelope_schema
• mongodb::write_model::validate_timeseries_write_mode
• nats::register_nats_sink
• nats::register_nats_source
• otel::config::otel_source_config_keys
• otel::convert::logs_request_to_batch
• otel::convert::metrics_request_to_batch
• otel::convert::trace_request_to_batch
• otel::register_otel_source
• otel::schema::logs_schema
• otel::schema::metrics_schema
• otel::schema::traces_schema
• postgres::register_postgres_sink
• postgres::types::arrow_column_to_pg_array
• postgres::types::arrow_to_pg_ddl_type
• postgres::types::arrow_type_to_pg_array_cast
• postgres::types::arrow_type_to_pg_sql
• schema::evolution::apply_changes
• schema::evolution::diff_schemas_by_name
• schema::evolution::evaluate_changes
• schema::evolution::is_safe_widening
• serde::create_deserializer
• serde::create_serializer
• testing::mock_batch
• testing::mock_schema
• testing::register_mock_sink
• testing::register_mock_source
• websocket::fanout::ring_channel
• websocket::parser::extract_max_event_time
• websocket::parser::infer_schema_from_json
• websocket::parser::infer_schema_from_json_with_path
• websocket::register_websocket_sink
• websocket::register_websocket_source

Type Aliases

• registry::SinkFactory
• registry::SourceFactory
• registry::TableSourceFactory
• schema::error::SchemaResult
• websocket::fanout::ClientId

Constants

• cdc::mysql::types::mysql_type::BIT
• cdc::mysql::types::mysql_type::BLOB
• cdc::mysql::types::mysql_type::DATE
• cdc::mysql::types::mysql_type::DATETIME
• cdc::mysql::types::mysql_type::DATETIME2
• cdc::mysql::types::mysql_type::DECIMAL
• cdc::mysql::types::mysql_type::DOUBLE
• cdc::mysql::types::mysql_type::ENUM
• cdc::mysql::types::mysql_type::FLOAT
• cdc::mysql::types::mysql_type::GEOMETRY
• cdc::mysql::types::mysql_type::INT24
• cdc::mysql::types::mysql_type::JSON
• cdc::mysql::types::mysql_type::LONG
• cdc::mysql::types::mysql_type::LONGLONG
• cdc::mysql::types::mysql_type::LONG_BLOB
• cdc::mysql::types::mysql_type::MEDIUM_BLOB
• cdc::mysql::types::mysql_type::NEWDATE
• cdc::mysql::types::mysql_type::NEWDECIMAL
• cdc::mysql::types::mysql_type::NULL
• cdc::mysql::types::mysql_type::SET
• cdc::mysql::types::mysql_type::SHORT
• cdc::mysql::types::mysql_type::STRING
• cdc::mysql::types::mysql_type::TIME
• cdc::mysql::types::mysql_type::TIME2
• cdc::mysql::types::mysql_type::TIMESTAMP
• cdc::mysql::types::mysql_type::TIMESTAMP2
• cdc::mysql::types::mysql_type::TINY
• cdc::mysql::types::mysql_type::TINY_BLOB
• cdc::mysql::types::mysql_type::VARCHAR
• cdc::mysql::types::mysql_type::VAR_STRING
• cdc::mysql::types::mysql_type::YEAR
• cdc::postgres::types::BOOL_ARRAY_OID
• cdc::postgres::types::BOOL_OID
• cdc::postgres::types::BPCHAR_OID
• cdc::postgres::types::BYTEA_OID
• cdc::postgres::types::CHAR_OID
• cdc::postgres::types::CIDR_OID
• cdc::postgres::types::DATE_OID
• cdc::postgres::types::FLOAT4_ARRAY_OID
• cdc::postgres::types::FLOAT4_OID
• cdc::postgres::types::FLOAT8_ARRAY_OID
• cdc::postgres::types::FLOAT8_OID
• cdc::postgres::types::INET_OID
• cdc::postgres::types::INT2_ARRAY_OID
• cdc::postgres::types::INT2_OID
• cdc::postgres::types::INT4_ARRAY_OID
• cdc::postgres::types::INT4_OID
• cdc::postgres::types::INT8_ARRAY_OID
• cdc::postgres::types::INT8_OID
• cdc::postgres::types::INTERVAL_OID
• cdc::postgres::types::JSONB_OID
• cdc::postgres::types::JSON_OID
• cdc::postgres::types::MACADDR_OID
• cdc::postgres::types::NAME_OID
• cdc::postgres::types::NUMERIC_OID
• cdc::postgres::types::OID_OID
• cdc::postgres::types::TEXT_ARRAY_OID
• cdc::postgres::types::TEXT_OID
• cdc::postgres::types::TIMESTAMPTZ_OID
• cdc::postgres::types::TIMESTAMP_OID
• cdc::postgres::types::TIME_OID
• cdc::postgres::types::UUID_OID
• cdc::postgres::types::VARCHAR_ARRAY_OID
• cdc::postgres::types::VARCHAR_OID
• cdc::postgres::types::XML_OID
• schema::json::jsonb::tags::ARRAY
• schema::json::jsonb::tags::BOOL_FALSE
• schema::json::jsonb::tags::BOOL_TRUE
• schema::json::jsonb::tags::FLOAT64
• schema::json::jsonb::tags::INT64
• schema::json::jsonb::tags::NULL
• schema::json::jsonb::tags::OBJECT
• schema::json::jsonb::tags::STRING