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::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
• time_dependence::ProtoTimeDependence
• time_dependence::TimeDependence

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
• 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
• time_dependence::TimeDependenceError

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

• sources::kafka::KafkaTimestamp
• sources::mysql::GtidPartition

Statics

• sources::kafka::KAFKA_PROGRESS_DESC
• sources::load_generator::LOAD_GEN_PROGRESS_DESC
• sources::mysql::MYSQL_PROGRESS_DESC
• sources::postgres::PG_PROGRESS_DESC

Constants

• dyncfgs::CLUSTER_SHUTDOWN_GRACE_PERIOD
• dyncfgs::DELAY_SOURCES_PAST_REHYDRATION
• dyncfgs::ENFORCE_EXTERNAL_ADDRESSES
• dyncfgs::KAFKA_BUFFERED_EVENT_RESIZE_THRESHOLD_ELEMENTS
• 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_CONTINUAL_FEEDBACK_UPSERT
• dyncfgs::SUSPENDABLE_SOURCES
• dyncfgs::WALLCLOCK_LAG_HISTORY_RETENTION_INTERVAL
• 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
• sources::load_generator::LOAD_GENERATOR_DATABASE_NAME
• sources::load_generator::LOAD_GENERATOR_KEY_VALUE_OFFSET_DEFAULT