List of all items

Structs

• client::PartitionedStorageState
• client::ProtoCompaction
• client::ProtoRunIngestionCommand
• client::ProtoRunOneshotIngestion
• client::ProtoRunSinkCommand
• client::ProtoStorageCommand
• client::ProtoStorageResponse
• client::RunIngestionCommand
• client::RunOneshotIngestion
• client::RunSinkCommand
• client::StatusUpdate
• client::TimestamplessUpdate
• client::TimestamplessUpdateBuilder
• client::Update
• client::proto_storage_client::ProtoStorageClient
• client::proto_storage_command::ProtoCreateTimely
• client::proto_storage_response::ProtoDroppedId
• client::proto_storage_response::ProtoFrontierUpper
• client::proto_storage_response::ProtoStagedBatches
• client::proto_storage_response::ProtoStatisticsUpdates
• client::proto_storage_response::ProtoStatus
• client::proto_storage_response::ProtoStatusUpdate
• client::proto_storage_response::proto_staged_batches::BatchResult
• client::proto_storage_response::proto_staged_batches::Inner
• client::proto_storage_server::ProtoStorageServer
• controller::CollectionDescription
• controller::ExportDescription
• controller::ExportState
• controller::MonotonicAppender
• controller::PersistEpoch
• controller::StorageMetadata
• controller::WallclockLagHistogramPeriod
• metrics::HistoryMetrics
• metrics::InstanceMetrics
• metrics::ReplicaMetrics
• metrics::ReplicaMetricsInner
• metrics::StorageControllerMetrics
• sink::TopicConfigs
• sink::progress_key::ProgressKey
• statistics::Boolean
• statistics::ControllerSinkStatistics
• statistics::ControllerSourceStatistics
• statistics::Counter
• statistics::Gauge
• statistics::ProtoSinkStatisticsUpdate
• statistics::ProtoSourceStatisticsUpdate
• statistics::ResettingLatency
• statistics::ResettingNullableTotal
• statistics::ResettingTotal
• statistics::SinkStatisticsUpdate
• statistics::SourceStatisticsUpdate
• statistics::Total
• statistics::WebhookStatistics
• storage_collections::BackgroundTask
• storage_collections::CollectionFrontiers
• storage_collections::CollectionState
• storage_collections::FinalizeShardsTaskConfig
• storage_collections::SnapshotCursor
• storage_collections::SnapshotStatsRes
• storage_collections::StorageCollectionsImpl
• storage_collections::metrics::ShardIdSet
• storage_collections::metrics::ShardIdSetGuard
• storage_collections::metrics::StorageCollectionsMetrics

Enums

• client::AppendOnlyUpdate
• client::Status
• client::StorageCommand
• client::StorageProtoServiceTypes
• client::StorageResponse
• client::TableData
• client::proto_storage_command::Kind
• client::proto_storage_response::Kind
• client::proto_storage_response::proto_staged_batches::batch_result::Value
• client::proto_storage_response::proto_status::Kind
• controller::DataSource
• controller::IntrospectionType
• controller::Response
• controller::StorageWriteOp
• controller::WallclockLag
• storage_collections::BackgroundCmd
• storage_collections::SinceHandleWrapper
• storage_collections::SnapshotStatsAsOf

Traits

• client::StorageClient
• client::proto_storage_server::ProtoStorage
• controller::StorageController
• controller::StorageTxn
• statistics::ExpirableStats
• statistics::PackableStats
• statistics::StorageMetric
• statistics::ZeroInitializedStats
• storage_collections::StorageCollections
• util::remap_handle::RemapHandle
• util::remap_handle::RemapHandleReader

Functions

• sink::discover_topic_configs
• sink::ensure_kafka_topic
• sink::publish_kafka_schema
• storage_collections::finalize_shards_task

Type Aliases

• client::StorageGrpcClient
• controller::BoxFuture
• controller::RowPredicate
• metrics::UIntGauge

Statics

• healthcheck::MZ_AWS_PRIVATELINK_CONNECTION_STATUS_HISTORY_DESC
• healthcheck::MZ_PREPARED_STATEMENT_HISTORY_DESC
• healthcheck::MZ_SESSION_HISTORY_DESC
• healthcheck::MZ_SINK_STATUS_HISTORY_DESC
• healthcheck::MZ_SOURCE_STATUS_HISTORY_DESC
• healthcheck::MZ_SQL_TEXT_DESC
• healthcheck::MZ_STATEMENT_EXECUTION_HISTORY_DESC
• healthcheck::REPLICA_METRICS_HISTORY_DESC
• healthcheck::REPLICA_STATUS_HISTORY_DESC
• healthcheck::WALLCLOCK_GLOBAL_LAG_HISTOGRAM_RAW_DESC
• healthcheck::WALLCLOCK_LAG_HISTORY_DESC
• statistics::MZ_SINK_STATISTICS_RAW_DESC
• statistics::MZ_SOURCE_STATISTICS_RAW_DESC

Constants

• client::proto_storage_server::SERVICE_NAME