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

• client::StorageGrpcClient

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