List of all items
Structs
- collections::DurableCollectionMetadata
- collections::GlobalId
- collections::Timestamp
- collections::TimestampAntichain
- configuration::ProtoKafkaTimeouts
- configuration::ProtoMySqlSourceTimeouts
- configuration::ProtoPgSourceSnapshotConfig
- configuration::ProtoSshTimeoutConfig
- configuration::ProtoStorageMaxInflightBytesConfig
- configuration::ProtoStorageParameters
- configuration::ProtoUpsertAutoSpillConfig
- configuration::StorageConfiguration
- connections::AwsPrivatelink
- connections::AwsPrivatelinkConnection
- connections::ConnectionContext
- connections::CsrConnection
- connections::CsrConnectionHttpAuth
- connections::KafkaBroker
- connections::KafkaConnection
- connections::KafkaSaslConfig
- connections::KafkaTlsConfig
- connections::KafkaTopicOptions
- connections::MySqlConnection
- connections::PostgresConnection
- connections::ProtoAwsPrivatelink
- connections::ProtoCsrConnection
- connections::ProtoCsrConnectionHttpAuth
- connections::ProtoKafkaBroker
- connections::ProtoKafkaConnection
- connections::ProtoKafkaConnectionSaslConfig
- connections::ProtoKafkaConnectionTlsConfig
- connections::ProtoKafkaTopicOptions
- connections::ProtoMySqlConnection
- connections::ProtoPostgresConnection
- connections::ProtoSshConnection
- connections::ProtoSshTunnel
- connections::ProtoTlsIdentity
- connections::ProtoTunnel
- connections::SshConnection
- connections::SshTunnel
- connections::TlsIdentity
- connections::aws::AwsAssumeRole
- connections::aws::AwsConnection
- connections::aws::AwsConnectionReference
- connections::aws::AwsCredentials
- connections::aws::ProtoAwsAssumeRole
- connections::aws::ProtoAwsConnection
- connections::aws::ProtoAwsConnectionReference
- connections::aws::ProtoAwsCredentials
- connections::inline::InlinedConnection
- connections::inline::ReferencedConnection
- connections::string_or_secret::ProtoStringOrSecret
- controller::AlterError
- controller::CollectionMetadata
- controller::DurableCollectionMetadata
- controller::InvalidUpper
- controller::ProtoCollectionMetadata
- controller::ProtoDurableCollectionMetadata
- controller::TxnsCodecRow
- errors::DecodeError
- errors::ProtoDataflowError
- errors::ProtoDecodeError
- errors::ProtoDecodeErrorKind
- errors::ProtoEnvelopeErrorV1
- errors::ProtoSourceError
- errors::ProtoSourceErrorDetails
- errors::ProtoUpsertError
- errors::ProtoUpsertNullKeyError
- errors::ProtoUpsertValueError
- errors::ProtoUpsertValueErrorLegacy
- errors::SourceError
- errors::UpsertNullKeyError
- errors::UpsertValueError
- errors::boxed_str::BoxStrStack
- errors::columnation::DataflowErrorRegion
- instances::ProtoStorageInstanceId
- parameters::PgSourceSnapshotConfig
- parameters::ProtoKafkaTimeouts
- parameters::ProtoMySqlSourceTimeouts
- parameters::ProtoPgSourceSnapshotConfig
- parameters::ProtoSshTimeoutConfig
- parameters::ProtoStorageMaxInflightBytesConfig
- parameters::ProtoStorageParameters
- parameters::ProtoUpsertAutoSpillConfig
- parameters::StorageMaxInflightBytesConfig
- parameters::StorageParameters
- parameters::UpsertAutoSpillConfig
- read_holds::ReadHold
- sinks::KafkaSinkConnection
- sinks::KafkaSinkFormat
- sinks::MetadataFilled
- sinks::MetadataUnfilled
- sinks::ProtoKafkaIdStyle
- sinks::ProtoKafkaSinkConnectionV2
- sinks::ProtoKafkaSinkFormat
- sinks::ProtoKafkaSinkFormatType
- sinks::ProtoPersistSinkConnection
- sinks::ProtoS3SinkFormat
- sinks::ProtoS3UploadInfo
- sinks::ProtoSinkEnvelope
- sinks::ProtoSinkPartitionStrategy
- sinks::ProtoStorageSinkConnection
- sinks::ProtoStorageSinkDesc
- sinks::S3UploadInfo
- sinks::StorageSinkDesc
- sinks::proto_kafka_id_style::ProtoKafkaIdStylePrefix
- sinks::proto_kafka_sink_connection_v2::ProtoKeyDescAndIndices
- sinks::proto_kafka_sink_connection_v2::ProtoRelationKeyIndicesVec
- sinks::proto_kafka_sink_format_type::ProtoKafkaSinkAvroFormat
- sources::IndexedSourceExport
- sources::IngestionDescription
- sources::MzOffset
- sources::ProtoCompression
- sources::ProtoIngestionDescription
- sources::ProtoMzOffset
- sources::ProtoSourceConnection
- sources::ProtoSourceData
- sources::ProtoSourceDesc
- sources::ProtoSourceExportDataConfig
- sources::ProtoSourceExportDetails
- sources::ProtoSourceExportStatementDetails
- sources::ProtoTimeline
- sources::SourceData
- sources::SourceDataColumnarDecoder
- sources::SourceDataColumnarEncoder
- sources::SourceDesc
- sources::SourceExport
- sources::SourceExportDataConfig
- sources::SourceReferenceResolver
- sources::encoding::AvroEncoding
- sources::encoding::CsvEncoding
- sources::encoding::ProtoAvroEncoding
- sources::encoding::ProtoColumnSpec
- sources::encoding::ProtoCsvEncoding
- sources::encoding::ProtoDataEncoding
- sources::encoding::ProtoProtobufEncoding
- sources::encoding::ProtoRegexEncoding
- sources::encoding::ProtoSourceDataEncoding
- sources::encoding::ProtobufEncoding
- sources::encoding::RegexEncoding
- sources::encoding::SourceDataEncoding
- sources::encoding::proto_column_spec::ProtoHeader
- sources::envelope::NoneEnvelope
- sources::envelope::ProtoKeyEnvelope
- sources::envelope::ProtoNoneEnvelope
- sources::envelope::ProtoSourceEnvelope
- sources::envelope::ProtoUpsertEnvelope
- sources::envelope::ProtoUpsertStyle
- sources::envelope::UpsertEnvelope
- sources::envelope::proto_upsert_style::ProtoDebezium
- sources::envelope::proto_upsert_style::ProtoValueErrInline
- sources::kafka::KafkaSourceConnection
- sources::kafka::KafkaSourceExportDetails
- sources::kafka::ProtoKafkaHeader
- sources::kafka::ProtoKafkaMetadataColumn
- sources::kafka::ProtoKafkaMetadataKind
- sources::kafka::ProtoKafkaSourceConnection
- sources::kafka::ProtoKafkaSourceExportDetails
- sources::kafka::ProtoKafkaSourceExportStatementDetails
- sources::load_generator::KeyValueLoadGenerator
- sources::load_generator::LoadGeneratorSourceConnection
- sources::load_generator::LoadGeneratorSourceExportDetails
- sources::load_generator::ProtoCounterLoadGenerator
- sources::load_generator::ProtoKeyValueLoadGenerator
- sources::load_generator::ProtoLoadGeneratorOutput
- sources::load_generator::ProtoLoadGeneratorSourceConnection
- sources::load_generator::ProtoLoadGeneratorSourceExportDetails
- sources::load_generator::ProtoLoadGeneratorSourceExportStatementDetails
- sources::load_generator::ProtoTpchLoadGenerator
- sources::mysql::MySqlSourceConnection
- sources::mysql::MySqlSourceDetails
- sources::mysql::MySqlSourceExportDetails
- sources::mysql::ProtoMySqlSourceConnection
- sources::mysql::ProtoMySqlSourceDetails
- sources::mysql::ProtoMySqlSourceExportDetails
- sources::mysql::ProtoMySqlSourceExportStatementDetails
- sources::postgres::PostgresSourceConnection
- sources::postgres::PostgresSourceExportDetails
- sources::postgres::PostgresSourcePublicationDetails
- sources::postgres::ProtoCastType
- sources::postgres::ProtoPostgresColumnCast
- sources::postgres::ProtoPostgresSourceConnection
- sources::postgres::ProtoPostgresSourceExportDetails
- sources::postgres::ProtoPostgresSourceExportStatementDetails
- sources::postgres::ProtoPostgresSourcePublicationDetails
- sources::proto_ingestion_description::ProtoSourceExport
- sources::proto_ingestion_description::ProtoSourceImport
- stats::RelationPartStats
Enums
- collections::global_id::Value
- connections::Connection
- connections::ConnectionValidationError
- connections::MySqlSslMode
- connections::ProtoMySqlSslMode
- connections::Tunnel
- connections::aws::AwsAuth
- connections::aws::AwsConnectionValidationError
- connections::aws::proto_aws_connection::Auth
- connections::proto_tunnel::Tunnel
- connections::string_or_secret::StringOrSecret
- connections::string_or_secret::proto_string_or_secret::Kind
- controller::StorageError
- errors::ContextCreationError
- errors::CsrConnectError
- errors::DataflowError
- errors::DecodeErrorKind
- errors::EnvelopeError
- errors::SourceErrorDetails
- errors::UpsertError
- errors::proto_dataflow_error::Kind
- errors::proto_decode_error_kind::Kind
- errors::proto_envelope_error_v1::Kind
- errors::proto_source_error_details::Kind
- errors::proto_upsert_error::Kind
- instances::StorageInstanceId
- instances::proto_storage_instance_id::Kind
- read_holds::ReadHoldDowngradeError
- read_holds::ReadHoldError
- read_policy::ReadPolicy
- shim::ProtoUpsertValueErrorShim
- sinks::KafkaIdStyle
- sinks::KafkaSinkCompressionType
- sinks::KafkaSinkFormatType
- sinks::S3SinkFormat
- sinks::SinkEnvelope
- sinks::SinkPartitionStrategy
- sinks::StorageSinkConnection
- sinks::proto_kafka_id_style::Kind
- sinks::proto_kafka_sink_connection_v2::CompressionType
- sinks::proto_kafka_sink_format_type::Type
- sinks::proto_kafka_sink_format_type::proto_kafka_sink_avro_format::CompatibilityLevel
- sinks::proto_s3_sink_format::Kind
- sinks::proto_sink_envelope::Kind
- sinks::proto_sink_partition_strategy::Kind
- sinks::proto_storage_sink_connection::Kind
- sources::Compression
- sources::ExternalReferenceResolutionError
- sources::GenericSourceConnection
- sources::SourceDataRowColumnarDecoder
- sources::SourceDataRowColumnarEncoder
- sources::SourceExportDetails
- sources::SourceExportStatementDetails
- sources::Timeline
- sources::encoding::ColumnSpec
- sources::encoding::DataEncoding
- sources::encoding::proto_column_spec::Kind
- sources::encoding::proto_data_encoding::Kind
- sources::envelope::KeyEnvelope
- sources::envelope::SourceEnvelope
- sources::envelope::UnplannedSourceEnvelope
- sources::envelope::UpsertStyle
- sources::envelope::proto_key_envelope::Kind
- sources::envelope::proto_source_envelope::Kind
- sources::envelope::proto_upsert_style::Kind
- sources::kafka::BoundKind
- sources::kafka::KafkaMetadataKind
- sources::kafka::RangeBound
- sources::kafka::proto_kafka_metadata_kind::Kind
- sources::load_generator::AuctionView
- sources::load_generator::Event
- sources::load_generator::LoadGenerator
- sources::load_generator::LoadGeneratorOutput
- sources::load_generator::MarketingView
- sources::load_generator::ProtoLoadGeneratorAuctionOutput
- sources::load_generator::ProtoLoadGeneratorMarketingOutput
- sources::load_generator::ProtoLoadGeneratorTpchOutput
- sources::load_generator::TpchView
- sources::load_generator::proto_load_generator_output::Kind
- sources::load_generator::proto_load_generator_source_connection::Kind
- sources::mysql::GtidState
- sources::postgres::CastType
- sources::postgres::proto_cast_type::Kind
- sources::proto_compression::Kind
- sources::proto_source_connection::Kind
- sources::proto_source_data::Kind
- sources::proto_source_export_details::Kind
- sources::proto_source_export_statement_details::Kind
- sources::proto_timeline::Kind
Traits
- AlterCompatible
- connections::SecretsReaderExt
- connections::inline::ConnectionAccess
- connections::inline::ConnectionResolver
- connections::inline::IntoInlineConnection
- errors::ContextCreationErrorExt
- sinks::StorageSinkDescFillState
- sources::ExternalCatalogReference
- sources::SourceConnection
- sources::SourceTimestamp
- sources::load_generator::Generator
Functions
- connections::any_mysql_ssl_mode
- dyncfgs::all_dyncfgs
- errors::columnation::assert_copy
- sinks::csr_compat_level_from_proto
- sinks::csr_compat_level_to_proto
- sources::arb_source_data_for_relation_desc
- sources::encoding::included_column_desc
- sources::envelope::compute_envelope_value_desc
- sources::envelope::match_key_indices
- sources::kafka::kafka_metadata_columns_desc
- sources::mysql::any_gtidset
- sources::mysql::gtid_set_frontier
Type Aliases
Statics
- sources::kafka::KAFKA_PROGRESS_DESC
- sources::load_generator::LOAD_GEN_PROGRESS_DESC
- sources::mysql::MYSQL_PROGRESS_DESC
- sources::postgres::PG_PROGRESS_DESC
Constants
- collections::_IMPL_ARBITRARY_FOR_DurableCollectionMetadata
- collections::_IMPL_ARBITRARY_FOR_GlobalId
- collections::_IMPL_ARBITRARY_FOR_Timestamp
- collections::_IMPL_ARBITRARY_FOR_TimestampAntichain
- collections::global_id::_IMPL_ARBITRARY_FOR_Value
- connections::_IMPL_ARBITRARY_FOR_AwsPrivatelink
- connections::_IMPL_ARBITRARY_FOR_AwsPrivatelinkConnection
- connections::_IMPL_ARBITRARY_FOR_Connection
- connections::_IMPL_ARBITRARY_FOR_CsrConnection
- connections::_IMPL_ARBITRARY_FOR_CsrConnectionHttpAuth
- connections::_IMPL_ARBITRARY_FOR_KafkaBroker
- connections::_IMPL_ARBITRARY_FOR_KafkaConnection
- connections::_IMPL_ARBITRARY_FOR_KafkaSaslConfig
- connections::_IMPL_ARBITRARY_FOR_KafkaTlsConfig
- connections::_IMPL_ARBITRARY_FOR_KafkaTopicOptions
- connections::_IMPL_ARBITRARY_FOR_MySqlConnection
- connections::_IMPL_ARBITRARY_FOR_MySqlSslMode
- connections::_IMPL_ARBITRARY_FOR_PostgresConnection
- connections::_IMPL_ARBITRARY_FOR_SshConnection
- connections::_IMPL_ARBITRARY_FOR_SshTunnel
- connections::_IMPL_ARBITRARY_FOR_TlsIdentity
- connections::_IMPL_ARBITRARY_FOR_Tunnel
- connections::aws::_IMPL_ARBITRARY_FOR_AwsAssumeRole
- connections::aws::_IMPL_ARBITRARY_FOR_AwsAuth
- connections::aws::_IMPL_ARBITRARY_FOR_AwsConnection
- connections::aws::_IMPL_ARBITRARY_FOR_AwsConnectionReference
- connections::aws::_IMPL_ARBITRARY_FOR_AwsCredentials
- connections::inline::_IMPL_ARBITRARY_FOR_InlinedConnection
- connections::inline::_IMPL_ARBITRARY_FOR_ReferencedConnection
- connections::string_or_secret::_IMPL_ARBITRARY_FOR_StringOrSecret
- controller::_IMPL_ARBITRARY_FOR_CollectionMetadata
- controller::_IMPL_ARBITRARY_FOR_DurableCollectionMetadata
- dyncfgs::CLUSTER_SHUTDOWN_GRACE_PERIOD
- dyncfgs::DELAY_SOURCES_PAST_REHYDRATION
- dyncfgs::ENFORCE_EXTERNAL_ADDRESSES
- dyncfgs::KAFKA_CLIENT_ID_ENRICHMENT_RULES
- dyncfgs::KAFKA_DEFAULT_AWS_PRIVATELINK_ENDPOINT_IDENTIFICATION_ALGORITHM
- dyncfgs::KAFKA_POLL_MAX_WAIT
- dyncfgs::MYSQL_OFFSET_KNOWN_INTERVAL
- dyncfgs::MYSQL_REPLICATION_HEARTBEAT_INTERVAL
- dyncfgs::PG_FETCH_SLOT_RESUME_LSN_INTERVAL
- dyncfgs::PG_OFFSET_KNOWN_INTERVAL
- dyncfgs::REPLICA_METRICS_HISTORY_RETENTION_INTERVAL
- dyncfgs::STORAGE_DOWNGRADE_SINCE_DURING_FINALIZATION
- dyncfgs::STORAGE_RECLOCK_TO_LATEST
- dyncfgs::STORAGE_ROCKSDB_CLEANUP_TRIES
- dyncfgs::STORAGE_ROCKSDB_USE_MERGE_OPERATOR
- dyncfgs::STORAGE_SUSPEND_AND_RESTART_DELAY
- dyncfgs::STORAGE_UPSERT_MAX_SNAPSHOT_BATCH_BUFFERING
- dyncfgs::STORAGE_UPSERT_PREVENT_SNAPSHOT_BUFFERING
- dyncfgs::STORAGE_USE_RECLOCK_V2
- dyncfgs::SUSPENDABLE_SOURCES
- dyncfgs::WALLCLOCK_LAG_HISTORY_RETENTION_INTERVAL
- errors::_IMPL_ARBITRARY_FOR_DataflowError
- errors::_IMPL_ARBITRARY_FOR_DecodeError
- errors::_IMPL_ARBITRARY_FOR_DecodeErrorKind
- errors::_IMPL_ARBITRARY_FOR_EnvelopeError
- errors::_IMPL_ARBITRARY_FOR_SourceError
- errors::_IMPL_ARBITRARY_FOR_SourceErrorDetails
- errors::_IMPL_ARBITRARY_FOR_UpsertError
- errors::_IMPL_ARBITRARY_FOR_UpsertNullKeyError
- errors::_IMPL_ARBITRARY_FOR_UpsertValueError
- instances::_IMPL_ARBITRARY_FOR_StorageInstanceId
- parameters::DEFAULT_PG_SOURCE_CONNECT_TIMEOUT
- parameters::DEFAULT_PG_SOURCE_TCP_CONFIGURE_SERVER
- parameters::DEFAULT_PG_SOURCE_TCP_KEEPALIVES_IDLE
- parameters::DEFAULT_PG_SOURCE_TCP_KEEPALIVES_INTERVAL
- parameters::DEFAULT_PG_SOURCE_TCP_KEEPALIVES_RETRIES
- parameters::DEFAULT_PG_SOURCE_TCP_USER_TIMEOUT
- parameters::DEFAULT_PG_SOURCE_WAL_SENDER_TIMEOUT
- parameters::REPLICA_STATUS_HISTORY_RETENTION_WINDOW_DEFAULT
- parameters::STATISTICS_COLLECTION_INTERVAL_DEFAULT
- parameters::STATISTICS_INTERVAL_DEFAULT
- parameters::STORAGE_MANAGED_COLLECTIONS_BATCH_DURATION_DEFAULT
- sinks::MAX_S3_SINK_FILE_SIZE
- sinks::MIN_S3_SINK_FILE_SIZE
- sinks::_IMPL_ARBITRARY_FOR_KafkaIdStyle
- sinks::_IMPL_ARBITRARY_FOR_KafkaSinkCompressionType
- sinks::_IMPL_ARBITRARY_FOR_KafkaSinkConnection
- sinks::_IMPL_ARBITRARY_FOR_KafkaSinkFormat
- sinks::_IMPL_ARBITRARY_FOR_KafkaSinkFormatType
- sinks::_IMPL_ARBITRARY_FOR_S3SinkFormat
- sinks::_IMPL_ARBITRARY_FOR_S3UploadInfo
- sinks::_IMPL_ARBITRARY_FOR_SinkEnvelope
- sinks::_IMPL_ARBITRARY_FOR_SinkPartitionStrategy
- sinks::_IMPL_ARBITRARY_FOR_StorageSinkConnection
- sources::_IMPL_ARBITRARY_FOR_Compression
- sources::_IMPL_ARBITRARY_FOR_GenericSourceConnection
- sources::_IMPL_ARBITRARY_FOR_IndexedSourceExport
- sources::_IMPL_ARBITRARY_FOR_IngestionDescription
- sources::_IMPL_ARBITRARY_FOR_MzOffset
- sources::_IMPL_ARBITRARY_FOR_SourceData
- sources::_IMPL_ARBITRARY_FOR_SourceDesc
- sources::_IMPL_ARBITRARY_FOR_SourceExport
- sources::_IMPL_ARBITRARY_FOR_SourceExportDataConfig
- sources::_IMPL_ARBITRARY_FOR_SourceExportDetails
- sources::_IMPL_ARBITRARY_FOR_Timeline
- sources::encoding::_IMPL_ARBITRARY_FOR_AvroEncoding
- sources::encoding::_IMPL_ARBITRARY_FOR_ColumnSpec
- sources::encoding::_IMPL_ARBITRARY_FOR_CsvEncoding
- sources::encoding::_IMPL_ARBITRARY_FOR_DataEncoding
- sources::encoding::_IMPL_ARBITRARY_FOR_ProtobufEncoding
- sources::encoding::_IMPL_ARBITRARY_FOR_RegexEncoding
- sources::encoding::_IMPL_ARBITRARY_FOR_SourceDataEncoding
- sources::envelope::_IMPL_ARBITRARY_FOR_KeyEnvelope
- sources::envelope::_IMPL_ARBITRARY_FOR_NoneEnvelope
- sources::envelope::_IMPL_ARBITRARY_FOR_SourceEnvelope
- sources::envelope::_IMPL_ARBITRARY_FOR_UpsertEnvelope
- sources::envelope::_IMPL_ARBITRARY_FOR_UpsertStyle
- sources::kafka::_IMPL_ARBITRARY_FOR_KafkaMetadataKind
- sources::kafka::_IMPL_ARBITRARY_FOR_KafkaSourceConnection
- sources::kafka::_IMPL_ARBITRARY_FOR_KafkaSourceExportDetails
- sources::load_generator::LOAD_GENERATOR_DATABASE_NAME
- sources::load_generator::LOAD_GENERATOR_KEY_VALUE_OFFSET_DEFAULT
- sources::load_generator::_IMPL_ARBITRARY_FOR_AuctionView
- sources::load_generator::_IMPL_ARBITRARY_FOR_KeyValueLoadGenerator
- sources::load_generator::_IMPL_ARBITRARY_FOR_LoadGenerator
- sources::load_generator::_IMPL_ARBITRARY_FOR_LoadGeneratorOutput
- sources::load_generator::_IMPL_ARBITRARY_FOR_LoadGeneratorSourceConnection
- sources::load_generator::_IMPL_ARBITRARY_FOR_LoadGeneratorSourceExportDetails
- sources::load_generator::_IMPL_ARBITRARY_FOR_MarketingView
- sources::load_generator::_IMPL_ARBITRARY_FOR_TpchView
- sources::mysql::_IMPL_ARBITRARY_FOR_MySqlSourceConnection
- sources::mysql::_IMPL_ARBITRARY_FOR_MySqlSourceDetails
- sources::mysql::_IMPL_ARBITRARY_FOR_MySqlSourceExportDetails
- sources::postgres::_IMPL_ARBITRARY_FOR_CastType
- sources::postgres::_IMPL_ARBITRARY_FOR_PostgresSourceConnection
- sources::postgres::_IMPL_ARBITRARY_FOR_PostgresSourceExportDetails
- sources::postgres::_IMPL_ARBITRARY_FOR_PostgresSourcePublicationDetails