List of all items

Structs

• configuration::StorageConfiguration
• connections::AwsPrivatelink
• connections::AwsPrivatelinkConnection
• connections::ConnectionContext
• connections::CsrConnection
• connections::CsrConnectionHttpAuth
• connections::IcebergCatalogConnection
• connections::KafkaBroker
• connections::KafkaConnection
• connections::KafkaSaslConfig
• connections::KafkaTlsConfig
• connections::KafkaTopicOptions
• connections::MySqlConnection
• connections::PostgresConnection
• connections::RestIcebergCatalog
• connections::S3TablesRestIcebergCatalog
• connections::SqlServerConnectionDetails
• connections::SshConnection
• connections::SshTunnel
• connections::TlsIdentity
• connections::aws::AwsAssumeRole
• connections::aws::AwsConnection
• connections::aws::AwsConnectionReference
• connections::aws::AwsCredentials
• connections::inline::InlinedConnection
• connections::inline::ReferencedConnection
• controller::AlterError
• controller::CollectionMetadata
• controller::DurableCollectionMetadata
• controller::InvalidUpper
• 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
• oneshot_sources::ContentShape
• oneshot_sources::OneshotIngestionDescription
• oneshot_sources::OneshotIngestionRequest
• parameters::PgSourceSnapshotConfig
• parameters::StorageMaxInflightBytesConfig
• parameters::StorageParameters
• read_holds::ReadHold
• sinks::KafkaSinkConnection
• sinks::KafkaSinkFormat
• sinks::S3UploadInfo
• sinks::StorageSinkDesc
• sinks::s3_oneshot_sink::S3KeyManager
• sources::IngestionDescription
• sources::MzOffset
• sources::ProtoSourceData
• sources::ProtoSourceExportStatementDetails
• sources::SourceData
• sources::SourceDataColumnarDecoder
• sources::SourceDataColumnarEncoder
• sources::SourceDesc
• sources::SourceExport
• sources::SourceExportDataConfig
• sources::SourceReferenceResolver
• sources::encoding::AvroEncoding
• sources::encoding::CsvEncoding
• sources::encoding::ProtobufEncoding
• sources::encoding::RegexEncoding
• sources::encoding::SourceDataEncoding
• sources::envelope::NoneEnvelope
• sources::envelope::UpsertEnvelope
• sources::kafka::KafkaSourceConnection
• sources::kafka::KafkaSourceExportDetails
• sources::kafka::ProtoKafkaSourceExportStatementDetails
• sources::load_generator::KeyValueLoadGenerator
• sources::load_generator::LoadGeneratorSourceConnection
• sources::load_generator::LoadGeneratorSourceExportDetails
• sources::load_generator::ProtoLoadGeneratorOutput
• sources::load_generator::ProtoLoadGeneratorSourceExportStatementDetails
• sources::mysql::MySqlSourceConnection
• sources::mysql::MySqlSourceDetails
• sources::mysql::MySqlSourceExportDetails
• sources::mysql::ProtoMySqlSourceDetails
• sources::mysql::ProtoMySqlSourceExportStatementDetails
• sources::postgres::PostgresSourceConnection
• sources::postgres::PostgresSourceExportDetails
• sources::postgres::PostgresSourcePublicationDetails
• sources::postgres::ProtoPostgresSourceExportStatementDetails
• sources::postgres::ProtoPostgresSourcePublicationDetails
• sources::sql_server::ProtoSqlServerSourceExportStatementDetails
• sources::sql_server::ProtoSqlServerSourceExtras
• sources::sql_server::SqlServerSourceConnection
• sources::sql_server::SqlServerSourceExportDetails
• sources::sql_server::SqlServerSourceExtras
• stats::RelationPartStats
• time_dependence::TimeDependence

Enums

• connections::Connection
• connections::ConnectionValidationError
• connections::IcebergCatalogImpl
• connections::IcebergCatalogType
• connections::MySqlConnectionValidationError
• connections::MySqlSslMode
• connections::PostgresConnectionValidationError
• connections::SqlServerConnectionValidationError
• connections::Tunnel
• connections::aws::AwsAuth
• connections::aws::AwsConnectionValidationError
• connections::string_or_secret::StringOrSecret
• 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
• oneshot_sources::ContentFilter
• oneshot_sources::ContentFormat
• oneshot_sources::ContentSource
• read_holds::ReadHoldDowngradeError
• read_holds::ReadHoldError
• read_policy::ReadPolicy
• sinks::KafkaIdStyle
• sinks::KafkaSinkCompressionType
• sinks::KafkaSinkFormatType
• sinks::S3SinkFormat
• sinks::SinkEnvelope
• sinks::StorageSinkConnection
• sources::Compression
• sources::ExternalReferenceResolutionError
• sources::GenericSourceConnection
• sources::SourceDataRowColumnarDecoder
• sources::SourceDataRowColumnarEncoder
• sources::SourceExportDetails
• sources::SourceExportStatementDetails
• sources::Timeline
• sources::encoding::ColumnSpec
• sources::encoding::DataEncoding
• sources::envelope::KeyEnvelope
• sources::envelope::SourceEnvelope
• sources::envelope::UnplannedSourceEnvelope
• sources::envelope::UpsertStyle
• sources::kafka::BoundKind
• sources::kafka::KafkaMetadataKind
• sources::kafka::RangeBound
• 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::mysql::GtidState
• sources::postgres::CastType
• sources::proto_source_data::Kind
• sources::proto_source_export_statement_details::Kind
• time_dependence::TimeDependenceError

Traits

• AlterCompatible
• connections::SecretsReaderExt
• connections::inline::ConnectionAccess
• connections::inline::ConnectionResolver
• connections::inline::IntoInlineConnection
• errors::ContextCreationErrorExt
• sources::ExternalCatalogReference
• sources::SourceConnection
• sources::SourceTimestamp
• sources::load_generator::Generator

Functions

• dyncfgs::all_dyncfgs
• errors::columnation::assert_copy
• sinks::s3_oneshot_sink::preflight
• 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::gtid_set_frontier

Type Aliases

• StorageDiff
• oneshot_sources::OneshotResultCallback
• read_holds::ChangeTx
• sources::kafka::KafkaTimestamp
• sources::mysql::GtidPartition

Statics

• dyncfgs::KAFKA_METADATA_FETCH_INTERVAL
• sources::kafka::KAFKA_PROGRESS_DESC
• sources::load_generator::LOAD_GEN_PROGRESS_DESC
• sources::mysql::MYSQL_PROGRESS_DESC
• sources::postgres::PG_PROGRESS_DESC
• sources::sql_server::SQL_SERVER_PROGRESS_DESC

Constants

• connections::REST_CATALOG_PROP_CREDENTIAL
• connections::REST_CATALOG_PROP_SCOPE
• 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::ORE_OVERFLOWING_BEHAVIOR
• dyncfgs::PG_FETCH_SLOT_RESUME_LSN_INTERVAL
• dyncfgs::PG_OFFSET_KNOWN_INTERVAL
• dyncfgs::PG_SCHEMA_VALIDATION_INTERVAL
• dyncfgs::REPLICA_METRICS_HISTORY_RETENTION_INTERVAL
• dyncfgs::SINK_ENSURE_TOPIC_CONFIG
• dyncfgs::SINK_PROGRESS_SEARCH
• dyncfgs::STATISTICS_RETENTION_DURATION
• dyncfgs::STORAGE_DOWNGRADE_SINCE_DURING_FINALIZATION
• dyncfgs::STORAGE_RECLOCK_TO_LATEST
• dyncfgs::STORAGE_ROCKSDB_CLEANUP_TRIES
• dyncfgs::STORAGE_ROCKSDB_USE_MERGE_OPERATOR
• dyncfgs::STORAGE_SERVER_MAINTENANCE_INTERVAL
• 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_GLOBAL_LAG_HISTOGRAM_RETENTION_INTERVAL
• 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
• sources::sql_server::CDC_CLEANUP_CHANGE_TABLE
• sources::sql_server::CDC_CLEANUP_CHANGE_TABLE_MAX_DELETES
• sources::sql_server::CDC_POLL_INTERVAL
• sources::sql_server::MAX_LSN_WAIT
• sources::sql_server::OFFSET_KNOWN_INTERVAL
• sources::sql_server::SNAPSHOT_PROGRESS_REPORT_INTERVAL