List of all items

Structs

• cdc::mysql::BeginMessage
• cdc::mysql::BinlogPosition
• cdc::mysql::ChangeEvent
• cdc::mysql::CommitMessage
• cdc::mysql::DeleteMessage
• cdc::mysql::Gtid
• cdc::mysql::GtidRange
• cdc::mysql::GtidSet
• cdc::mysql::InsertMessage
• cdc::mysql::MetricsSnapshot
• cdc::mysql::MySqlCdcConfig
• cdc::mysql::MySqlCdcMetrics
• cdc::mysql::MySqlCdcSource
• cdc::mysql::MySqlColumn
• cdc::mysql::QueryMessage
• cdc::mysql::RotateMessage
• cdc::mysql::RowData
• cdc::mysql::TableCache
• cdc::mysql::TableInfo
• cdc::mysql::TableMapMessage
• cdc::mysql::UpdateMessage
• cdc::mysql::UpdateRowData
• 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::CdcMetrics
• 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::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::backpressure::KafkaBackpressureController
• kafka::config::KafkaSourceConfig
• kafka::config::SrAuth
• kafka::discovery::KafkaDiscovery
• kafka::discovery::KafkaDiscoveryConfig
• kafka::discovery::LaminarPartitionAssignor
• 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::KafkaAlignmentConfig
• kafka::watermarks::KafkaWatermarkTracker
• kafka::watermarks::WatermarkMetrics
• kafka::watermarks::WatermarkMetricsSnapshot
• lakehouse::delta::DeltaLakeSink
• lakehouse::delta_config::CompactionConfig
• lakehouse::delta_config::DeltaLakeSinkConfig
• lakehouse::delta_io::CompactionResult
• lakehouse::delta_io::MergeResult
• lakehouse::delta_metrics::DeltaLakeSinkMetrics
• lakehouse::delta_source::DeltaSource
• lakehouse::delta_source_config::DeltaSourceConfig
• lakehouse::metrics::LakehouseSinkMetrics
• lookup::NoOpTableLoader
• lookup::cdc_adapter::CdcTableSource
• lookup::parquet_source::ParquetLookupSource
• lookup::parquet_source::ParquetLookupSourceConfig
• lookup::postgres_source::PostgresLookupSource
• lookup::postgres_source::PostgresLookupSourceConfig
• metrics::ConnectorMetrics
• metrics::RuntimeMetrics
• metrics::RuntimeMetricsSnapshot
• postgres::sink::PostgresSink
• postgres::sink_config::PostgresSinkConfig
• postgres::sink_metrics::PostgresSinkMetrics
• reference::MockReferenceTableSource
• registry::ConnectorRegistry
• schema::bridge::DeserializerDecoder
• schema::bridge::SerializerEncoder
• schema::csv::decoder::CsvDecoder
• schema::csv::decoder::CsvDecoderConfig
• schema::evolution::DefaultSchemaEvolver
• schema::evolution::SchemaEvolutionEngine
• schema::evolution::SchemaHistory
• schema::evolution::SchemaHistoryEntry
• schema::inference::CsvFormatInference
• schema::inference::FormatInferenceRegistry
• schema::inference::JsonFormatInference
• schema::inference::RawFormatInference
• 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::resolver::DeclaredColumn
• schema::resolver::DeclaredSchema
• schema::resolver::ResolvedSchema
• schema::resolver::SchemaResolver
• 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::BinlogMessage
• cdc::mysql::CdcOperation
• cdc::mysql::ColumnValue
• cdc::mysql::DecoderError
• cdc::mysql::SnapshotMode
• cdc::mysql::SslMode
• cdc::postgres::changelog::CdcOperation
• cdc::postgres::config::SnapshotMode
• cdc::postgres::config::SslMode
• 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
• 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::SecurityProtocol
• kafka::config::StartupMode
• kafka::config::TopicSubscription
• kafka::schema_registry::SchemaType
• kafka::sink_config::Acks
• kafka::sink_config::CompressionType
• kafka::sink_config::DeliveryGuarantee
• kafka::sink_config::PartitionStrategy
• kafka::watermarks::AlignmentCheckResult
• kafka::watermarks::KafkaAlignmentMode
• lakehouse::delta_config::DeliveryGuarantee
• lakehouse::delta_config::DeltaCatalogType
• lakehouse::delta_config::DeltaWriteMode
• lookup::LookupError
• lookup::LookupResult
• postgres::sink_config::DeliveryGuarantee
• postgres::sink_config::SslMode
• postgres::sink_config::WriteMode
• reference::RefreshMode
• schema::csv::decoder::FieldCountMismatchStrategy
• schema::error::SchemaError
• schema::evolution::EvolutionResult
• schema::evolution::EvolutionTrigger
• schema::json::decoder::TypeMismatchStrategy
• schema::json::decoder::UnknownFieldStrategy
• schema::parquet::RowGroupPredicate
• schema::resolver::FieldOrigin
• schema::resolver::ResolutionKind
• 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::BackpressureStrategy
• 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
• reference::ReferenceTableSource
• schema::inference::FormatInference
• schema::traits::FormatDecoder
• schema::traits::FormatEncoder
• schema::traits::SchemaEvolvable
• schema::traits::SchemaInferable
• schema::traits::SchemaProvider
• schema::traits::SchemaRegistryAware
• serde::RecordDeserializer
• serde::RecordSerializer

Functions

• cdc::mysql::cdc_envelope_schema
• cdc::mysql::column_value_to_json
• cdc::mysql::config_key_specs
• cdc::mysql::delete_to_events
• cdc::mysql::events_to_record_batch
• cdc::mysql::insert_to_events
• 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::mysql_type_name
• cdc::mysql::mysql_type_to_arrow
• cdc::mysql::mysql_type_to_sql
• cdc::mysql::register_mysql_cdc_source
• cdc::mysql::row_to_json
• cdc::mysql::update_to_events
• 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
• cdc::postgres::schema::cdc_envelope_schema
• cdc::postgres::types::pg_type_name
• cdc::postgres::types::pg_type_to_arrow
• 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::delete_by_merge
• lakehouse::delta_io::get_last_committed_epoch
• lakehouse::delta_io::get_latest_version
• lakehouse::delta_io::get_table_schema
• lakehouse::delta_io::merge_batches
• lakehouse::delta_io::merge_changelog
• lakehouse::delta_io::open_or_create_table
• lakehouse::delta_io::read_batches_at_version
• 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::register_delta_lake_sink
• lakehouse::register_delta_lake_source
• lakehouse::register_lakehouse_sinks
• lookup::postgres_source::build_query
• 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
• schema::inference::default_infer_from_samples
• 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

Statics

• schema::inference::FORMAT_INFERENCE_REGISTRY

Constants

• cdc::mysql::mysql_type::BIT
• cdc::mysql::mysql_type::BLOB
• cdc::mysql::mysql_type::DATE
• cdc::mysql::mysql_type::DATETIME
• cdc::mysql::mysql_type::DATETIME2
• cdc::mysql::mysql_type::DECIMAL
• cdc::mysql::mysql_type::DOUBLE
• cdc::mysql::mysql_type::ENUM
• cdc::mysql::mysql_type::FLOAT
• cdc::mysql::mysql_type::GEOMETRY
• cdc::mysql::mysql_type::INT24
• cdc::mysql::mysql_type::JSON
• cdc::mysql::mysql_type::LONG
• cdc::mysql::mysql_type::LONGLONG
• cdc::mysql::mysql_type::LONG_BLOB
• cdc::mysql::mysql_type::MEDIUM_BLOB
• cdc::mysql::mysql_type::NEWDATE
• cdc::mysql::mysql_type::NEWDECIMAL
• cdc::mysql::mysql_type::NULL
• cdc::mysql::mysql_type::SET
• cdc::mysql::mysql_type::SHORT
• cdc::mysql::mysql_type::STRING
• cdc::mysql::mysql_type::TIME
• cdc::mysql::mysql_type::TIME2
• cdc::mysql::mysql_type::TIMESTAMP
• cdc::mysql::mysql_type::TIMESTAMP2
• cdc::mysql::mysql_type::TINY
• cdc::mysql::mysql_type::TINY_BLOB
• cdc::mysql::mysql_type::VARCHAR
• cdc::mysql::mysql_type::VAR_STRING
• cdc::mysql::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