List of all items

Structs

• client::PartitionedStorageState
• client::ProtoAllowCompaction
• client::ProtoCompaction
• client::ProtoCreateSources
• client::ProtoFrontierUppersKind
• client::ProtoRunIngestionCommand
• client::ProtoRunSinkCommand
• client::ProtoRunSinks
• client::ProtoStorageCommand
• client::ProtoStorageResponse
• client::ProtoTrace
• client::RunIngestionCommand
• client::RunSinkCommand
• client::StatusUpdate
• client::TimestamplessUpdate
• client::Update
• client::proto_storage_client::ProtoStorageClient
• client::proto_storage_command::ProtoCreateTimely
• client::proto_storage_response::ProtoDroppedIds
• client::proto_storage_response::ProtoStatisticsUpdates
• client::proto_storage_response::ProtoStatus
• client::proto_storage_response::ProtoStatusUpdate
• client::proto_storage_response::ProtoStatusUpdates
• client::proto_storage_server::ProtoStorageServer
• controller::CollectionDescription
• controller::ExportDescription
• controller::ExportState
• controller::MonotonicAppender
• controller::PersistEpoch
• controller::SnapshotCursor
• controller::StorageMetadata
• metrics::HistoryMetrics
• metrics::InstanceMetrics
• metrics::ReplicaMetrics
• metrics::ReplicaMetricsInner
• metrics::StorageControllerMetrics
• sink::TopicConfigs
• sink::progress_key::ProgressKey
• statistics::Boolean
• 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::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::proto_storage_command::Kind
• client::proto_storage_response::Kind
• client::proto_storage_response::proto_status::Kind
• controller::DataSource
• controller::IntrospectionType
• controller::Response
• controller::StorageWriteOp
• storage_collections::BackgroundCmd
• storage_collections::SinceHandleWrapper
• storage_collections::SnapshotStatsAsOf

Traits

• client::StorageClient
• client::proto_storage_server::ProtoStorage
• controller::StorageController
• controller::StorageTxn
• statistics::PackableStats
• statistics::StorageMetric
• 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_LAG_HISTORY_DESC
• statistics::MZ_SINK_STATISTICS_RAW_DESC
• statistics::MZ_SOURCE_STATISTICS_RAW_DESC