List of all items
Structs
- client::CreateSinkCommand
- client::CreateSourceCommand
- client::PartitionedStorageState
- client::ProtoAllowCompaction
- client::ProtoCompaction
- client::ProtoCreateSinkCommand
- client::ProtoCreateSinks
- client::ProtoCreateSourceCommand
- client::ProtoCreateSources
- client::ProtoFrontierUppersKind
- client::ProtoStorageCommand
- client::ProtoStorageResponse
- client::ProtoTrace
- client::SinkStatisticsUpdate
- client::SourceStatisticsUpdate
- client::TimestamplessUpdate
- client::Update
- client::__FieldVisitor
- client::__Visitor
- client::proto_storage_client::ProtoStorageClient
- client::proto_storage_response::ProtoDroppedIds
- client::proto_storage_response::ProtoSinkStatisticsUpdate
- client::proto_storage_response::ProtoSourceStatisticsUpdate
- client::proto_storage_response::ProtoStatisticsUpdates
- client::proto_storage_server::CommandResponseStreamSvc
- client::proto_storage_server::ProtoStorageServer
- client::proto_storage_server::_Inner
- controller::CollectionDescription
- controller::CollectionMetadata
- controller::CollectionState
- controller::Controller
- controller::CreateExportToken
- controller::DurableCollectionMetadata
- controller::DurableExportMetadata
- controller::ExportDescription
- controller::ExportState
- controller::MetadataExportFetcher
- controller::PersistEpoch
- controller::ProtoCollectionMetadata
- controller::ProtoDurableCollectionMetadata
- controller::ScalarWrapper
- controller::StorageControllerState
- controller::__FieldVisitor
- controller::__Visitor
- controller::collection_mgmt::CollectionManager
- controller::persist_handles::PersistReadWorker
- controller::persist_handles::PersistWriteWorker
- controller::rehydration::RehydratingStorageClient
- controller::rehydration::RehydrationTask
- metrics::RehydratingStorageClientMetrics
- metrics::RehydratingStorageClientMetricsInner
- metrics::StorageControllerMetrics
- source::persist_source::FlowControl
- types::connections::AwsPrivatelink
- types::connections::AwsPrivatelinkConnection
- types::connections::ConnectionContext
- types::connections::CsrClient
- types::connections::CsrConnection
- types::connections::CsrConnectionHttpAuth
- types::connections::KafkaBroker
- types::connections::KafkaConnection
- types::connections::KafkaTlsConfig
- types::connections::MapWrapper
- types::connections::PostgresConnection
- types::connections::ProtoAwsPrivatelink
- types::connections::ProtoCsrConnection
- types::connections::ProtoCsrConnectionHttpAuth
- types::connections::ProtoKafkaBroker
- types::connections::ProtoKafkaConnection
- types::connections::ProtoKafkaConnectionSaslConfig
- types::connections::ProtoKafkaConnectionSecurity
- types::connections::ProtoKafkaConnectionTlsConfig
- types::connections::ProtoPostgresConnection
- types::connections::ProtoSshConnection
- types::connections::ProtoSshTunnel
- types::connections::ProtoStringOrSecret
- types::connections::ProtoTlsIdentity
- types::connections::ProtoTunnel
- types::connections::SaslConfig
- types::connections::ScalarWrapper
- types::connections::SshConnection
- types::connections::SshTunnel
- types::connections::TlsIdentity
- types::connections::__FieldVisitor
- types::connections::__Visitor
- types::connections::aws::AwsAssumeRole
- types::connections::aws::AwsConfig
- types::connections::aws::AwsCredentials
- types::connections::aws::ProtoAwsAssumeRole
- types::connections::aws::ProtoAwsConfig
- types::connections::aws::ProtoAwsCredentials
- types::connections::aws::ProtoSerdeUri
- types::connections::aws::ScalarWrapper
- types::connections::aws::SerdeUri
- types::connections::aws::__DeserializeWith
- types::connections::aws::__FieldVisitor
- types::connections::aws::__SerializeWith
- types::connections::aws::__Visitor
- types::connections::proto_ssh_connection::ProtoPublicKeys
- types::errors::DecodeError
- types::errors::ProtoDataflowError
- types::errors::ProtoDecodeError
- types::errors::ProtoDecodeErrorKind
- types::errors::ProtoEnvelopeErrorV1
- types::errors::ProtoSourceError
- types::errors::ProtoSourceErrorDetails
- types::errors::ProtoUpsertError
- types::errors::ProtoUpsertValueError
- types::errors::ScalarWrapper
- types::errors::SourceError
- types::errors::UpsertValueError
- types::errors::__FieldVisitor
- types::errors::__Visitor
- types::instances::ProtoStorageInstanceId
- types::instances::__FieldVisitor
- types::instances::__Visitor
- types::parameters::ProtoStorageParameters
- types::parameters::StorageParameters
- types::parameters::__FieldVisitor
- types::parameters::__Visitor
- types::sinks::KafkaSinkConnection
- types::sinks::KafkaSinkConnectionBuilder
- types::sinks::KafkaSinkConnectionRetention
- types::sinks::KafkaSinkProgressConnection
- types::sinks::MetadataFilled
- types::sinks::MetadataUnfilled
- types::sinks::ProtoDurableExportMetadata
- types::sinks::ProtoKafkaSinkConnection
- types::sinks::ProtoKafkaSinkProgressConnection
- types::sinks::ProtoPersistSinkConnection
- types::sinks::ProtoPublishedSchemaInfo
- types::sinks::ProtoSinkAsOf
- types::sinks::ProtoSinkEnvelope
- types::sinks::ProtoStorageSinkConnection
- types::sinks::ProtoStorageSinkDesc
- types::sinks::PublishedSchemaInfo
- types::sinks::ScalarWrapper
- types::sinks::SinkAsOf
- types::sinks::StorageSinkDesc
- types::sinks::__FieldVisitor
- types::sinks::__Visitor
- types::sinks::proto_kafka_sink_connection::ProtoKeyDescAndIndices
- types::sinks::proto_kafka_sink_connection::ProtoRelationKeyIndicesVec
- types::sinks::proto_kafka_sink_connection::ScalarWrapper
- types::sources::DebeziumDedupProjection
- types::sources::DebeziumEnvelope
- types::sources::DebeziumTransactionMetadata
- types::sources::IncludedColumnPos
- types::sources::IngestionDescription
- types::sources::KafkaSourceConnection
- types::sources::KinesisSourceConnection
- types::sources::LoadGeneratorSourceConnection
- types::sources::MapWrapper
- types::sources::MzOffset
- types::sources::NoneEnvelope
- types::sources::PostgresSourceConnection
- types::sources::PostgresSourcePublicationDetails
- types::sources::ProtoCompression
- types::sources::ProtoDebeziumDedupProjection
- types::sources::ProtoDebeziumEnvelope
- types::sources::ProtoDebeziumSourceProjection
- types::sources::ProtoDebeziumTransactionMetadata
- types::sources::ProtoIncludedColumnPos
- types::sources::ProtoIncludedColumnSource
- types::sources::ProtoIngestionDescription
- types::sources::ProtoKafkaSourceConnection
- types::sources::ProtoKeyEnvelope
- types::sources::ProtoKinesisSourceConnection
- types::sources::ProtoLoadGeneratorSourceConnection
- types::sources::ProtoMzOffset
- types::sources::ProtoNoneEnvelope
- types::sources::ProtoPostgresSourceConnection
- types::sources::ProtoPostgresSourcePublicationDetails
- types::sources::ProtoS3KeySource
- types::sources::ProtoS3SourceConnection
- types::sources::ProtoSourceConnection
- types::sources::ProtoSourceData
- types::sources::ProtoSourceDesc
- types::sources::ProtoSourceEnvelope
- types::sources::ProtoTestScriptSourceConnection
- types::sources::ProtoTimeline
- types::sources::ProtoTpchLoadGenerator
- types::sources::ProtoUpsertEnvelope
- types::sources::ProtoUpsertStyle
- types::sources::S3SourceConnection
- types::sources::ScalarWrapper
- types::sources::SourceData
- types::sources::SourceDesc
- types::sources::SourceExport
- types::sources::SourceToken
- types::sources::TestScriptSourceConnection
- types::sources::UpsertEnvelope
- types::sources::__FieldVisitor
- types::sources::__Visitor
- types::sources::encoding::AvroEncoding
- types::sources::encoding::CsvEncoding
- types::sources::encoding::DataEncoding
- types::sources::encoding::ProtoAvroEncoding
- types::sources::encoding::ProtoColumnSpec
- types::sources::encoding::ProtoCsvEncoding
- types::sources::encoding::ProtoDataEncoding
- types::sources::encoding::ProtoDataEncodingInner
- types::sources::encoding::ProtoProtobufEncoding
- types::sources::encoding::ProtoRegexEncoding
- types::sources::encoding::ProtoSourceDataEncoding
- types::sources::encoding::ProtobufEncoding
- types::sources::encoding::RegexEncoding
- types::sources::encoding::__FieldVisitor
- types::sources::encoding::__Visitor
- types::sources::encoding::proto_column_spec::ProtoHeader
- types::sources::encoding::proto_column_spec::ScalarWrapper
- types::sources::encoding::proto_source_data_encoding::ProtoKeyValue
- types::sources::proto_debezium_source_projection::ProtoMySql
- types::sources::proto_debezium_source_projection::ProtoPostgres
- types::sources::proto_debezium_source_projection::ProtoSqlServer
- types::sources::proto_ingestion_description::ProtoSourceExport
- types::sources::proto_ingestion_description::ProtoSourceImport
- types::sources::proto_postgres_source_connection::ProtoPostgresTableCast
- types::sources::proto_upsert_style::ProtoDebezium
- util::antichain::MutableOffsetAntichain
- util::antichain::OffsetAntichain
- util::antichain::PartitionOffset
- util::antichain::__FieldVisitor
- util::antichain::__Visitor
Enums
- client::StorageCommand
- client::StorageProtoServiceTypes
- client::StorageResponse
- client::__Field
- client::proto_storage_command::Kind
- client::proto_storage_response::Kind
- controller::DataSource
- controller::IntrospectionType
- controller::ReadPolicy
- controller::StorageError
- controller::__Field
- controller::persist_handles::PersistReadWorkerCmd
- controller::persist_handles::PersistWriteWorkerCmd
- controller::rehydration::RehydrationCommand
- controller::rehydration::RehydrationTaskState
- types::connections::Connection
- types::connections::KafkaSecurity
- types::connections::StringOrSecret
- types::connections::Tunnel
- types::connections::__Field
- types::connections::aws::__Field
- types::connections::proto_kafka_connection_security::Kind
- types::connections::proto_string_or_secret::Kind
- types::connections::proto_tunnel::Tunnel
- types::errors::DataflowError
- types::errors::DecodeErrorKind
- types::errors::EnvelopeError
- types::errors::SourceErrorDetails
- types::errors::UpsertError
- types::errors::__Field
- types::errors::proto_dataflow_error::Kind
- types::errors::proto_decode_error_kind::Kind
- types::errors::proto_envelope_error_v1::Kind
- types::errors::proto_source_error_details::Kind
- types::errors::proto_upsert_error::Kind
- types::instances::StorageInstanceId
- types::instances::__Field
- types::instances::proto_storage_instance_id::Kind
- types::parameters::__Field
- types::sinks::KafkaConsistencyConfig
- types::sinks::KafkaSinkFormat
- types::sinks::SinkEnvelope
- types::sinks::StorageSinkConnection
- types::sinks::StorageSinkConnectionBuilder
- types::sinks::__Field
- types::sinks::proto_sink_envelope::Kind
- types::sinks::proto_storage_sink_connection::Kind
- types::sources::Compression
- types::sources::DebeziumSourceProjection
- types::sources::GeneratorMessageType
- types::sources::GenericSourceConnection
- types::sources::IncludedColumnSource
- types::sources::KeyEnvelope
- types::sources::LoadGenerator
- types::sources::S3KeySource
- types::sources::SourceEnvelope
- types::sources::Timeline
- types::sources::UnplannedSourceEnvelope
- types::sources::UpsertStyle
- types::sources::__Field
- types::sources::encoding::ColumnSpec
- types::sources::encoding::DataEncodingInner
- types::sources::encoding::SourceDataEncoding
- types::sources::encoding::SourceDataEncodingInner
- types::sources::encoding::__Field
- types::sources::encoding::proto_column_spec::Kind
- types::sources::encoding::proto_data_encoding_inner::Kind
- types::sources::encoding::proto_source_data_encoding::Kind
- types::sources::proto_compression::Kind
- types::sources::proto_debezium_source_projection::Kind
- types::sources::proto_included_column_source::Kind
- types::sources::proto_key_envelope::Kind
- types::sources::proto_load_generator_source_connection::Generator
- types::sources::proto_s3_key_source::Kind
- types::sources::proto_source_connection::Kind
- types::sources::proto_source_data::Kind
- types::sources::proto_source_envelope::Kind
- types::sources::proto_timeline::Kind
- types::sources::proto_upsert_style::Kind
- util::antichain::__Field
Traits
- client::PackableStats
- client::StorageClient
- client::proto_storage_server::ProtoStorage
- controller::MetadataExport
- controller::ResumptionFrontierCalculator
- controller::StorageController
- types::sinks::StorageSinkDescFillState
- types::sources::Generator
- types::sources::SourceConnection
- types::sources::SourceTimestamp
- util::remap_handle::RemapHandle
- util::remap_handle::RemapHandleReader
Macros
- client::try
- controller::try
- types::connections::aws::try
- types::connections::try
- types::errors::try
- types::instances::try
- types::parameters::try
- types::sinks::try
- types::sources::encoding::try
- types::sources::try
- util::antichain::try
Functions
- client::proto_storage_response::ScalarWrapper
- controller::Inner
- controller::ScalarWrapper
- controller::maybe_get_init_batch
- controller::persist_handles::append_work
- controller::statistics::spawn_statistics_scraper
- healthcheck::pack_status_row
- sink::build_kafka
- sink::build_sink_connection
- sink::ensure_kafka_topic
- sink::publish_kafka_schemas
- source::persist_source::decode_and_mfp
- source::persist_source::persist_source
- source::persist_source::persist_source_core
- source::util::async_source
- source::util::source
- types::connections::Inner
- types::connections::KeyWrapper
- types::connections::ScalarWrapper
- types::connections::ValueWrapper
- types::connections::aws::Inner
- types::connections::aws::ScalarWrapper
- types::connections::aws::any_serde_uri
- types::connections::proto_ssh_connection::ScalarWrapper
- types::connections::proto_string_or_secret::ScalarWrapper
- types::errors::Inner
- types::errors::proto_decode_error_kind::ScalarWrapper
- types::errors::proto_envelope_error_v1::ScalarWrapper
- types::errors::proto_source_error_details::ScalarWrapper
- types::instances::proto_storage_instance_id::ScalarWrapper
- types::sinks::Inner
- types::sinks::ScalarWrapper
- types::sinks::any_kafka_sink_connection
- types::sinks::proto_kafka_sink_connection::Inner
- types::sources::Inner
- types::sources::KeyWrapper
- types::sources::ScalarWrapper
- types::sources::ValueWrapper
- types::sources::any_glob
- types::sources::encoding::ScalarWrapper
- types::sources::encoding::included_column_desc
- types::sources::encoding::proto_column_spec::Inner
- types::sources::encoding::proto_column_spec::ScalarWrapper
- types::sources::match_key_indices
- types::sources::proto_debezium_source_projection::ScalarWrapper
- types::sources::proto_ingestion_description::ScalarWrapper
- types::sources::proto_key_envelope::ScalarWrapper
- types::sources::proto_s3_key_source::ScalarWrapper
- types::sources::proto_timeline::ScalarWrapper
- types::sources::proto_upsert_style::ScalarWrapper
Type Definitions
Opaque Types
- client::proto_storage_client::
- controller::
- controller::collection_mgmt::
- controller::command_wals::
- controller::persist_handles::
- controller::rehydration::
- sink::
- types::connections::
- types::connections::aws::
- types::sinks::
- types::sources::
- util::antichain::
Statics
- controller::ALL_COLLECTIONS
- controller::CALLSITE
- controller::META
- controller::METADATA_COLLECTION
- controller::METADATA_EXPORT
- controller::collection_mgmt::CALLSITE
- controller::collection_mgmt::META
- controller::command_wals::SHARD_FINALIZATION
- controller::persist_handles::CALLSITE
- controller::persist_handles::META
- controller::rehydration::CALLSITE
- controller::rehydration::META
- controller::statistics::CALLSITE
- controller::statistics::META
- healthcheck::MZ_SINK_STATUS_HISTORY_DESC
- healthcheck::MZ_SOURCE_STATUS_HISTORY_DESC
- metrics::CALLSITE
- metrics::META
- types::connections::CALLSITE
- types::connections::META
- types::errors::CALLSITE
- types::errors::META
- types::sources::KAFKA_PROGRESS_DESC
- types::sources::KINESIS_PROGRESS_DESC
- types::sources::LOADGEN_PROGRESS_DESC
- types::sources::PG_PROGRESS_DESC
- types::sources::S3_PROGRESS_DESC
- types::sources::TESTSCRIPT_PROGRESS_DESC
Constants
- client::FIELDS
- client::STRUCT_NAME
- client::VARIANTS
- client::proto_storage_response::STRUCT_NAME
- controller::BRANCHES
- controller::FIELDS
- controller::STRUCT_NAME
- controller::VARIANTS
- controller::_IMPL_ARBITRARY_FOR_CollectionMetadata
- controller::_IMPL_ARBITRARY_FOR_DurableCollectionMetadata
- controller::collection_mgmt::BRANCHES
- controller::persist_handles::BRANCHES
- controller::rehydration::BRANCHES
- controller::statistics::BRANCHES
- controller::statistics::STATISTICS_INTERVAL
- types::connections::DUMMY_PORT
- types::connections::FIELDS
- types::connections::STRUCT_NAME
- types::connections::VARIANTS
- types::connections::_IMPL_ARBITRARY_FOR_AwsPrivatelink
- types::connections::_IMPL_ARBITRARY_FOR_AwsPrivatelinkConnection
- types::connections::_IMPL_ARBITRARY_FOR_Connection
- types::connections::_IMPL_ARBITRARY_FOR_CsrConnectionHttpAuth
- types::connections::_IMPL_ARBITRARY_FOR_KafkaBroker
- types::connections::_IMPL_ARBITRARY_FOR_KafkaConnection
- types::connections::_IMPL_ARBITRARY_FOR_KafkaSecurity
- types::connections::_IMPL_ARBITRARY_FOR_KafkaTlsConfig
- types::connections::_IMPL_ARBITRARY_FOR_SshConnection
- types::connections::_IMPL_ARBITRARY_FOR_SshTunnel
- types::connections::_IMPL_ARBITRARY_FOR_StringOrSecret
- types::connections::_IMPL_ARBITRARY_FOR_TlsIdentity
- types::connections::_IMPL_ARBITRARY_FOR_Tunnel
- types::connections::aws::FIELDS
- types::connections::aws::STRUCT_NAME
- types::connections::aws::_IMPL_ARBITRARY_FOR_AwsAssumeRole
- types::connections::aws::_IMPL_ARBITRARY_FOR_AwsConfig
- types::connections::aws::_IMPL_ARBITRARY_FOR_AwsCredentials
- types::connections::proto_ssh_connection::STRUCT_NAME
- types::errors::FIELDS
- types::errors::STRUCT_NAME
- types::errors::VARIANTS
- types::instances::STRUCT_NAME
- types::instances::VARIANTS
- types::instances::_IMPL_ARBITRARY_FOR_StorageInstanceId
- types::parameters::FIELDS
- types::parameters::STRUCT_NAME
- types::sinks::FIELDS
- types::sinks::STRUCT_NAME
- types::sinks::VARIANTS
- types::sinks::_IMPL_ARBITRARY_FOR_KafkaSinkProgressConnection
- types::sinks::_IMPL_ARBITRARY_FOR_PublishedSchemaInfo
- types::sinks::_IMPL_ARBITRARY_FOR_SinkEnvelope
- types::sinks::_IMPL_ARBITRARY_FOR_StorageSinkConnection
- types::sinks::proto_kafka_sink_connection::STRUCT_NAME
- types::sources::FIELDS
- types::sources::STRUCT_NAME
- types::sources::VARIANTS
- types::sources::_IMPL_ARBITRARY_FOR_Compression
- types::sources::_IMPL_ARBITRARY_FOR_DebeziumDedupProjection
- types::sources::_IMPL_ARBITRARY_FOR_DebeziumEnvelope
- types::sources::_IMPL_ARBITRARY_FOR_DebeziumSourceProjection
- types::sources::_IMPL_ARBITRARY_FOR_DebeziumTransactionMetadata
- types::sources::_IMPL_ARBITRARY_FOR_GenericSourceConnection
- types::sources::_IMPL_ARBITRARY_FOR_IncludedColumnPos
- types::sources::_IMPL_ARBITRARY_FOR_IncludedColumnSource
- types::sources::_IMPL_ARBITRARY_FOR_KeyEnvelope
- types::sources::_IMPL_ARBITRARY_FOR_KinesisSourceConnection
- types::sources::_IMPL_ARBITRARY_FOR_LoadGenerator
- types::sources::_IMPL_ARBITRARY_FOR_LoadGeneratorSourceConnection
- types::sources::_IMPL_ARBITRARY_FOR_MzOffset
- types::sources::_IMPL_ARBITRARY_FOR_NoneEnvelope
- types::sources::_IMPL_ARBITRARY_FOR_PostgresSourcePublicationDetails
- types::sources::_IMPL_ARBITRARY_FOR_S3KeySource
- types::sources::_IMPL_ARBITRARY_FOR_SourceEnvelope
- types::sources::_IMPL_ARBITRARY_FOR_TestScriptSourceConnection
- types::sources::_IMPL_ARBITRARY_FOR_Timeline
- types::sources::_IMPL_ARBITRARY_FOR_UpsertStyle
- types::sources::encoding::FIELDS
- types::sources::encoding::STRUCT_NAME
- types::sources::encoding::VARIANTS
- types::sources::encoding::_IMPL_ARBITRARY_FOR_AvroEncoding
- types::sources::encoding::_IMPL_ARBITRARY_FOR_ColumnSpec
- types::sources::encoding::_IMPL_ARBITRARY_FOR_CsvEncoding
- types::sources::encoding::_IMPL_ARBITRARY_FOR_DataEncoding
- types::sources::encoding::_IMPL_ARBITRARY_FOR_DataEncodingInner
- types::sources::encoding::_IMPL_ARBITRARY_FOR_ProtobufEncoding
- types::sources::encoding::_IMPL_ARBITRARY_FOR_SourceDataEncoding
- types::sources::encoding::proto_column_spec::STRUCT_NAME
- types::sources::encoding::proto_source_data_encoding::STRUCT_NAME
- types::sources::proto_debezium_source_projection::STRUCT_NAME
- types::sources::proto_ingestion_description::STRUCT_NAME
- types::sources::proto_postgres_source_connection::STRUCT_NAME
- types::sources::proto_upsert_style::STRUCT_NAME
- util::antichain::FIELDS