List of all items

Structs

• checkpoint::PersistentOffset
• checkpoint::SourceCheckpoint
• config::ConfigKeySpec
• config::ConnectorConfig
• config::ConnectorInfo
• connector::ConnectorTaskAdmission
• connector::ConnectorTaskGuard
• connector::ConnectorTaskOwner
• connector::ConnectorTaskTracker
• connector::CoordinatedCommitBatch
• connector::CoordinatedCommitContext
• connector::CoordinatedCommitCursor
• connector::CoordinatedCommitNamespace
• connector::CoordinatedCommitPayload
• connector::SinkContract
• connector::SourceBatch
• connector::SourceContract
• connector::SourceDrainRequest
• connector::SourceDrainResolution
• connector::SourceStart
• 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::FileIngestionManifest
• files::sink::FileSink
• files::source::FileSource
• files::text_decoder::TextLineDecoder
• generator::GeneratorSource
• kafka::avro::AvroDeserializer
• kafka::avro_serializer::AvroSerializer
• kafka::config::KafkaSourceConfig
• kafka::config::SrAuth
• kafka::metrics::KafkaSourceMetrics
• 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
• lakehouse::delta::DeltaLakeSink
• lakehouse::delta_config::DeltaLakeSinkConfig
• lakehouse::delta_config::ParquetWriteConfig
• lakehouse::delta_io::MergeResult
• lakehouse::delta_lookup::DeltaLookupSource
• lakehouse::delta_lookup::DeltaLookupSourceConfig
• lakehouse::delta_metrics::DeltaLakeSinkMetrics
• lakehouse::delta_reference::DeltaReferenceTableSource
• 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_lookup::IcebergLookupSource
• lakehouse::iceberg_lookup::IcebergLookupSourceConfig
• lakehouse::iceberg_reference::IcebergReferenceTableSource
• lakehouse::iceberg_source::IcebergSource
• lakehouse::metrics::LakehouseSinkMetrics
• mongodb::change_event::MongoDbChangeEvent
• mongodb::change_event::Namespace
• mongodb::change_event::TruncatedArray
• mongodb::change_event::UpdateDescription
• mongodb::config::MongoDbSinkConfig
• mongodb::config::MongoDbSourceConfig
• mongodb::lookup::MongoLookupSource
• mongodb::lookup::MongoLookupSourceConfig
• mongodb::metrics::MongoDbCdcMetrics
• mongodb::metrics::MongoDbSinkMetrics
• 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::cdc::changelog::ChangeEvent
• postgres::cdc::config::PostgresCdcConfig
• postgres::cdc::decoder::BeginMessage
• postgres::cdc::decoder::CommitMessage
• postgres::cdc::decoder::DeleteMessage
• postgres::cdc::decoder::InsertMessage
• postgres::cdc::decoder::OriginMessage
• postgres::cdc::decoder::RelationMessage
• postgres::cdc::decoder::TruncateMessage
• postgres::cdc::decoder::TupleData
• postgres::cdc::decoder::TypeMessage
• postgres::cdc::decoder::UpdateMessage
• postgres::cdc::lsn::Lsn
• postgres::cdc::metrics::PostgresCdcMetrics
• postgres::cdc::schema::RelationCache
• postgres::cdc::schema::RelationInfo
• postgres::cdc::source::PostgresCdcSource
• postgres::cdc::types::PgColumn
• postgres::lookup::PostgresLookupSource
• postgres::lookup::PostgresLookupSourceConfig
• postgres::reference::PostgresReferenceTableSource
• postgres::sink::PostgresSink
• postgres::sink_config::PostgresSinkConfig
• postgres::sink_metrics::PostgresSinkMetrics
• prom::RegHandle
• reference::MockReferenceTableSource
• registry::ConnectorRegistry
• retry::Backoff
• 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::traits::ColumnProjection
• schema::traits::FieldInferenceDetail
• schema::traits::InferenceConfig
• schema::traits::InferenceWarning
• schema::traits::InferredSchema
• schema::types::FieldMeta
• schema::types::RawRecord
• 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

Enums

• config::ConnectorState
• connector::ConnectorCancellationPolicy
• connector::DeliveryGuarantee
• connector::SinkConsistency
• connector::SinkInputMode
• connector::SinkTopology
• connector::SourceConsistency
• connector::SourceDrainOutcome
• connector::SourcePosition
• connector::SourceTopology
• error::ConnectorError
• error::SerdeError
• files::config::FileFormat
• 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::CompressionType
• kafka::sink_config::PartitionStrategy
• kafka::sink_config::SinkEnvelope
• lakehouse::delta_config::DeltaCatalogType
• lakehouse::delta_config::DeltaWriteMode
• lakehouse::delta_source_config::DeltaReadMode
• lakehouse::delta_source_config::SchemaEvolutionAction
• lakehouse::iceberg_config::IcebergCatalogType
• mongodb::change_event::OperationType
• mongodb::config::FullDocumentMode
• 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::SslMode
• postgres::cdc::changelog::CdcOperation
• postgres::cdc::decoder::ColumnValue
• postgres::cdc::decoder::DecoderError
• postgres::cdc::decoder::OldTuple
• postgres::cdc::decoder::WalMessage
• postgres::cdc::lsn::LsnParseError
• postgres::sink_config::WriteMode
• schema::WarningSeverity
• schema::csv::FieldCountMismatchStrategy
• schema::error::SchemaError
• schema::evolution::EvolutionResult
• schema::evolution::EvolutionTrigger
• schema::json::decoder::EpochUnit
• schema::json::decoder::TypeMismatchStrategy
• schema::json::decoder::UnknownFieldStrategy
• schema::parquet::RowGroupPredicate
• schema::traits::ArrayInference
• schema::traits::CompatibilityMode
• schema::traits::EvolutionVerdict
• schema::traits::NumberInference
• schema::traits::SchemaChange
• schema::traits::WarningSeverity
• serde::Format
• serde::debezium::DebeziumOp
• storage::provider::StorageProvider

Traits

• connector::CoordinatedCommitter
• connector::SinkConnector
• connector::SourceConnector
• kafka::partitioner::KafkaPartitioner
• reference::ReferenceTableSource
• registry::LookupSourceFactory
• schema::traits::FormatDecoder
• schema::traits::FormatEncoder
• serde::RecordDeserializer
• serde::RecordSerializer

Functions

• changelog::collapse_changelog
• 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
• generator::register_generator_source
• kafka::register_kafka_sink
• kafka::register_kafka_source
• kafka::schema_registry::arrow_to_avro_schema
• kafka::schema_registry::avro_to_arrow_schema
• kafka::testing::partition_vnodes
• lakehouse::delta_io::get_coordinated_cursor
• lakehouse::delta_io::get_latest_version
• lakehouse::delta_io::get_partition_columns
• lakehouse::delta_io::get_table_schema
• lakehouse::delta_io::map_cdf_to_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_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_append
• lakehouse::iceberg_io::current_snapshot_id
• lakehouse::iceberg_io::ensure_table_exists
• 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
• 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::cdc::register_postgres_cdc_source
• postgres::cdc::schema::cdc_envelope_schema
• postgres::cdc::types::pg_type_name
• postgres::cdc::types::pg_type_to_arrow
• postgres::register_postgres_sink
• prom::reg_or_local
• schema::evolution::apply_changes
• schema::evolution::diff_schemas_by_name
• schema::evolution::evaluate_changes
• schema::evolution::is_safe_widening
• security::is_env_reference
• security::is_secret_option_key
• security::is_sensitive_uri_query_key
• security::sanitize_identity_value
• security::value_contains_uri_secret
• serde::create_deserializer
• serde::create_serializer
• testing::mock_batch
• testing::mock_schema
• testing::register_mock_sink
• testing::register_mock_source
• websocket::register_websocket_sink
• websocket::register_websocket_source

Type Aliases

• registry::SinkFactory
• registry::SourceFactory
• registry::TableSourceFactory
• schema::error::SchemaResult

Constants

• connector::MAX_COORDINATED_COMMIT_BATCH_BYTES
• connector::MAX_COORDINATED_COMMIT_BATCH_ENTRIES
• connector::MAX_COORDINATED_COMMIT_PAYLOAD_BYTES
• postgres::cdc::types::BOOL_ARRAY_OID
• postgres::cdc::types::BOOL_OID
• postgres::cdc::types::BPCHAR_OID
• postgres::cdc::types::BYTEA_OID
• postgres::cdc::types::CHAR_OID
• postgres::cdc::types::CIDR_OID
• postgres::cdc::types::DATE_OID
• postgres::cdc::types::FLOAT4_ARRAY_OID
• postgres::cdc::types::FLOAT4_OID
• postgres::cdc::types::FLOAT8_ARRAY_OID
• postgres::cdc::types::FLOAT8_OID
• postgres::cdc::types::INET_OID
• postgres::cdc::types::INT2_ARRAY_OID
• postgres::cdc::types::INT2_OID
• postgres::cdc::types::INT4_ARRAY_OID
• postgres::cdc::types::INT4_OID
• postgres::cdc::types::INT8_ARRAY_OID
• postgres::cdc::types::INT8_OID
• postgres::cdc::types::INTERVAL_OID
• postgres::cdc::types::JSONB_OID
• postgres::cdc::types::JSON_OID
• postgres::cdc::types::MACADDR_OID
• postgres::cdc::types::NAME_OID
• postgres::cdc::types::NUMERIC_OID
• postgres::cdc::types::OID_OID
• postgres::cdc::types::TEXT_ARRAY_OID
• postgres::cdc::types::TEXT_OID
• postgres::cdc::types::TIMESTAMPTZ_OID
• postgres::cdc::types::TIMESTAMP_OID
• postgres::cdc::types::TIME_OID
• postgres::cdc::types::UUID_OID
• postgres::cdc::types::VARCHAR_ARRAY_OID
• postgres::cdc::types::VARCHAR_OID
• postgres::cdc::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