List of all items

Structs

• Diagnostics
• PersistClient
• PersistLocation
• ShardId
• async_runtime::IsolatedRuntime
• batch::Batch
• batch::BatchBuffer
• batch::BatchBuilder
• batch::BatchBuilderConfig
• batch::BatchBuilderInternal
• batch::BatchParts
• batch::PartDeletes
• batch::ProtoBatch
• batch::ProtoFetchBatchFilter
• batch::ProtoFetchBatchFilterListen
• batch::ProtoLease
• batch::ProtoLeasedBatchPart
• batch::UntrimmableColumns
• cache::LockingTypedState
• cache::PersistClientCache
• cache::RttLatencyTask
• cache::StateCache
• cfg::PersistConfig
• cfg::RetryParameters
• cli::admin::AdminArgs
• cli::admin::FinalizeArgs
• cli::admin::ForceCompactionArgs
• cli::admin::ForceGcArgs
• cli::admin::RestoreBlobArgs
• cli::args::ReadOnly
• cli::args::StateArgs
• cli::args::StoreArgs
• cli::bench::BenchArgs
• cli::bench::S3FetchArgs
• cli::inspect::BatchPartOutput
• cli::inspect::BatchPartUpdate
• cli::inspect::BlobArgs
• cli::inspect::BlobBatchPartArgs
• cli::inspect::BlobCounts
• cli::inspect::D
• cli::inspect::InspectArgs
• cli::inspect::K
• cli::inspect::O
• cli::inspect::PrettyBytes
• cli::inspect::StateRollupArgs
• cli::inspect::T
• cli::inspect::UnreferencedBlobs
• cli::inspect::V
• critical::CriticalReaderId
• critical::SinceHandle
• error::CodecConcreteType
• error::CodecMismatch
• error::CodecMismatchT
• error::UpperMismatch
• fetch::BatchFetcher
• fetch::BatchFetcherConfig
• fetch::Cursor
• fetch::EncodedPart
• fetch::FetchedBlob
• fetch::FetchedPart
• fetch::Lease
• fetch::LeasedBatchPart
• fetch::SerdeLeasedBatchPart
• fetch::ShardSourcePart
• internal::apply::Applier
• internal::apply::NextState
• internal::cache::BlobMemCache
• internal::cache::lru::Lru
• internal::cache::lru::Time
• internal::cache::lru::Weight
• internal::compact::CompactConfig
• internal::compact::CompactReq
• internal::compact::CompactRes
• internal::compact::Compactor
• internal::compact::Timings
• internal::encoding::InlinedDiffs
• internal::encoding::LazyInlineBatchPart
• internal::encoding::LazyPartStats
• internal::encoding::LazyProto
• internal::encoding::Rollup
• internal::encoding::Schemas
• internal::encoding::UntypedState
• internal::gc::GarbageCollector
• internal::gc::GcReq
• internal::gc::GcResults
• internal::gc::GcRollups
• internal::machine::ExpireFn
• internal::machine::Machine
• internal::maintenance::RoutineMaintenance
• internal::maintenance::WriterMaintenance
• internal::merge::MergeTree
• internal::metrics::AlertsMetrics
• internal::metrics::BatchPartReadMetrics
• internal::metrics::BatchPartVersionMetrics
• internal::metrics::BatchWriteMetrics
• internal::metrics::BlobMemCache
• internal::metrics::BlobMetrics
• internal::metrics::CmdMetrics
• internal::metrics::CmdsMetrics
• internal::metrics::CodecMetrics
• internal::metrics::CodecsMetrics
• internal::metrics::CompactionMetrics
• internal::metrics::CompactionSchemaSelection
• internal::metrics::CompactionStepTimings
• internal::metrics::ConsensusMetrics
• internal::metrics::ConsolidationMetrics
• internal::metrics::ExternalOpMetrics
• internal::metrics::GcMetrics
• internal::metrics::GcStepTimings
• internal::metrics::IncOnDrop
• internal::metrics::InlineMetrics
• internal::metrics::LeaseMetrics
• internal::metrics::LockMetrics
• internal::metrics::LocksMetrics
• internal::metrics::Metrics
• internal::metrics::MetricsBlob
• internal::metrics::MetricsConsensus
• internal::metrics::MetricsPermits
• internal::metrics::MetricsRetryStream
• internal::metrics::MetricsSemaphore
• internal::metrics::MetricsVecs
• internal::metrics::PubSubClientCallMetrics
• internal::metrics::PubSubClientMetrics
• internal::metrics::PubSubClientReceiverMetrics
• internal::metrics::PubSubClientSenderMetrics
• internal::metrics::PubSubGrpcClientConnectionMetrics
• internal::metrics::PubSubServerMetrics
• internal::metrics::PushdownMetrics
• internal::metrics::ReadMetrics
• internal::metrics::RetriesMetrics
• internal::metrics::RetryDeterminate
• internal::metrics::RetryExternal
• internal::metrics::RetryMetrics
• internal::metrics::SchemaCacheMetrics
• internal::metrics::SchemaMetrics
• internal::metrics::SemaphoreMetrics
• internal::metrics::ShardMetrics
• internal::metrics::ShardsMetrics
• internal::metrics::SinkMetrics
• internal::metrics::SinkWorkerMetrics
• internal::metrics::StateMetrics
• internal::metrics::TaskMetrics
• internal::metrics::TasksMetrics
• internal::metrics::UsageAuditMetrics
• internal::metrics::WatchMetrics
• internal::paths::BlobKey
• internal::paths::PartId
• internal::paths::PartialBatchKey
• internal::paths::PartialRollupKey
• internal::paths::RollupId
• internal::service::ProtoPubSubMessage
• internal::service::ProtoPushDiff
• internal::service::ProtoSubscribe
• internal::service::ProtoUnsubscribe
• internal::service::proto_persist_pub_sub_client::ProtoPersistPubSubClient
• internal::service::proto_persist_pub_sub_server::ProtoPersistPubSubServer
• internal::state::CriticalReaderState
• internal::state::EncodedSchemas
• internal::state::ExpiryMetrics
• internal::state::HandleDebugState
• internal::state::HollowBatch
• internal::state::HollowBatchPart
• internal::state::HollowRollup
• internal::state::HollowRun
• internal::state::HollowRunRef
• internal::state::IdempotencyToken
• internal::state::LeasedReaderState
• internal::state::MissingBlob
• internal::state::NoOpStateTransition
• internal::state::OpaqueState
• internal::state::ProtoCompaction
• internal::state::ProtoCriticalReaderState
• internal::state::ProtoEncodedSchemas
• internal::state::ProtoHandleDebugState
• internal::state::ProtoHollowBatch
• internal::state::ProtoHollowBatchPart
• internal::state::ProtoHollowRollup
• internal::state::ProtoHollowRun
• internal::state::ProtoHollowRunRef
• internal::state::ProtoIdHollowBatch
• internal::state::ProtoIdMerge
• internal::state::ProtoIdSpineBatch
• internal::state::ProtoInlineBatchPart
• internal::state::ProtoInlinedDiffs
• internal::state::ProtoLeasedReaderState
• internal::state::ProtoMerge
• internal::state::ProtoRollup
• internal::state::ProtoRunMeta
• internal::state::ProtoSpineBatch
• internal::state::ProtoSpineId
• internal::state::ProtoStateDiff
• internal::state::ProtoStateFieldDiffs
• internal::state::ProtoTrace
• internal::state::ProtoU64Antichain
• internal::state::ProtoU64Description
• internal::state::ProtoVersionedData
• internal::state::ProtoWriterState
• internal::state::RunMeta
• internal::state::Since
• internal::state::State
• internal::state::StateCollections
• internal::state::StateSizeMetrics
• internal::state::TypedState
• internal::state::Upper
• internal::state::WriterState
• internal::state_diff::ProtoStateFieldDiff
• internal::state_diff::ProtoStateFieldDiffsIter
• internal::state_diff::ProtoStateFieldDiffsWriter
• internal::state_diff::StateDiff
• internal::state_diff::StateFieldDiff
• internal::state_versions::AllLiveDiffs
• internal::state_versions::EncodedRollup
• internal::state_versions::RecentLiveDiffs
• internal::state_versions::ReferencedBlobValidator
• internal::state_versions::StateVersions
• internal::state_versions::StateVersionsIter
• internal::state_versions::UntypedStateVersionsIter
• internal::trace::ActiveCompaction
• internal::trace::FlatTrace
• internal::trace::FueledMergeReq
• internal::trace::FueledMergeRes
• internal::trace::FuelingMerge
• internal::trace::IdFuelingMerge
• internal::trace::IdHollowBatch
• internal::trace::MergeState
• internal::trace::Spine
• internal::trace::SpineBatch
• internal::trace::SpineId
• internal::trace::SpineMetrics
• internal::trace::ThinMerge
• internal::trace::ThinSpineBatch
• internal::trace::Trace
• internal::watch::StateWatch
• internal::watch::StateWatchNotifier
• iter::CodecSort
• iter::ConsolidatingIter
• iter::Consolidator
• iter::FetchData
• iter::PartIndices
• iter::PartRef
• iter::StructuredSort
• iter::StructuredUpdates
• metrics::Metrics
• metrics::SinkMetrics
• metrics::SinkWorkerMetrics
• operators::shard_source::LeaseManager
• read::Cursor
• read::LazyPartStats
• read::LeasedReaderId
• read::Listen
• read::ReadHandle
• read::Since
• read::Subscribe
• read::UnexpiredReadHandleState
• rpc::GrpcPubSubClient
• rpc::GrpcPubSubSender
• rpc::MetricsSameProcessPubSubSender
• rpc::NoopPubSubSender
• rpc::PersistGrpcPubSubServer
• rpc::PersistPubSubClientConfig
• rpc::PubSubClientConnection
• rpc::PubSubConnection
• rpc::PubSubState
• rpc::ShardSubscriptionToken
• rpc::SubscriptionTrackingSender
• schema::MigrationCacheMap
• schema::SchemaCache
• schema::SchemaCacheMap
• schema::SchemaCacheMaps
• stats::SnapshotPartStats
• stats::SnapshotPartsStats
• stats::SnapshotStats
• usage::BlobUsage
• usage::HumanBytes
• usage::ShardBlobUsage
• usage::ShardUsageAudit
• usage::ShardUsageCumulativeMaybeRacy
• usage::ShardUsageReferenced
• usage::ShardsUsageAudit
• usage::ShardsUsageReferenced
• usage::StorageUsageClient
• write::WriteHandle
• write::WriterId

Enums

• batch::Added
• batch::WritingRuns
• batch::proto_fetch_batch_filter::Kind
• cache::StateCacheInit
• cli::admin::Command
• cli::bench::Command
• cli::inspect::Command
• error::InvalidUsage
• fetch::FetchBatchFilter
• fetch::FetchedBlobBuf
• fetch::PartDecodeFormat
• internal::apply::ApplyCmdResult
• internal::machine::CompareAndAppendRes
• internal::merge::Pending
• internal::metrics::UpdateDelta
• internal::paths::BlobKeyPrefix
• internal::paths::PartialBlobKey
• internal::paths::WriterKey
• internal::service::proto_pub_sub_message::Message
• internal::state::BatchPart
• internal::state::CompareAndAppendBreak
• internal::state::HollowBlobRef
• internal::state::ProtoRunOrder
• internal::state::ProtoStateField
• internal::state::ProtoStateFieldDiffType
• internal::state::RunOrder
• internal::state::RunPart
• internal::state::SnapshotErr
• internal::state::proto_hollow_batch_part::Format
• internal::state::proto_hollow_batch_part::Kind
• internal::state_diff::StateFieldValDiff
• internal::state_versions::InspectDiff
• internal::trace::ApplyMergeResult
• internal::trace::SpineLog
• iter::ConsolidationPart
• metrics::UpdateDelta
• operators::shard_source::SnapshotMode
• project::ProjectionPushdown
• read::CursorConsolidator
• read::ListenEvent
• schema::CaESchema
• schema::PartMigration

Traits

• cache::DynState
• internal::service::proto_persist_pub_sub_server::ProtoPersistPubSub
• iter::RowSort
• rpc::PersistPubSubClient
• rpc::PubSubReceiver
• rpc::PubSubSender
• rpc::PubSubSenderInternal

Functions

• batch::diffs_sum
• batch::validate_schema
• batch::validate_truncate_batch
• cache::blob_rtt_latency_task
• cache::consensus_rtt_latency_task
• cfg::all_dyncfgs
• cfg::check_data_version
• cli::admin::dangerous_force_compaction_and_break_pushdown
• cli::admin::force_compaction
• cli::admin::force_gc
• cli::admin::info_log_non_zero_metrics
• cli::admin::make_machine
• cli::admin::make_typed_machine
• cli::admin::run
• cli::args::make_blob
• cli::args::make_consensus
• cli::bench::bench_s3
• cli::bench::run
• cli::inspect::blob_batch_part
• cli::inspect::blob_counts
• cli::inspect::blob_usage
• cli::inspect::consolidated_size
• cli::inspect::fetch_latest_state
• cli::inspect::fetch_state_diffs
• cli::inspect::fetch_state_rollup
• cli::inspect::fetch_state_rollups
• cli::inspect::run
• cli::inspect::shard_stats
• cli::inspect::unreferenced_blobs
• fetch::decode_batch_part_blob
• fetch::fetch_batch_part
• fetch::fetch_batch_part_blob
• fetch::fetch_leased_part
• internal::encoding::check_data_version
• internal::encoding::field_diff_into_proto
• internal::encoding::field_diff_into_rust
• internal::encoding::field_diffs_into_proto
• internal::encoding::parse_id
• internal::machine::next_listen_batch_retry_params
• internal::machine::retry_determinate
• internal::machine::retry_external
• internal::metrics::blob_key_shard_id
• internal::metrics::encode_ts_metric
• internal::paths::split_batch_key
• internal::restore::restore_blob
• internal::state::decode_structured_lower
• internal::state::serialize_diffs_sum
• internal::state::serialize_lazy_proto
• internal::state::serialize_part_bytes
• internal::state::serialize_part_stats
• internal::state_diff::apply_compaction_lenient
• internal::state_diff::apply_diff_map
• internal::state_diff::apply_diff_single
• internal::state_diff::apply_diffs_map
• internal::state_diff::apply_diffs_single
• internal::state_diff::apply_diffs_spine
• internal::state_diff::diff_field_single
• internal::state_diff::diff_field_sorted_iter
• internal::state_diff::force_apply_diff_single
• internal::state_diff::force_apply_diffs_single
• internal::state_diff::sniff_compaction
• internal::state_diff::sniff_insert
• internals_bench::trace_push_batch_one_iter
• iter::interleave_updates
• metrics::encode_ts_metric
• operators::shard_source::shard_source
• operators::shard_source::shard_source_descs
• operators::shard_source::shard_source_fetch
• project::error_free
• rpc::subscribe_state_cache_to_pubsub
• schema::is_atleast_as_nullable
• stats::encode_updates
• stats::untrimmable_columns

Type Aliases

• iter::FetchResult
• iter::Indices

Statics

• cli::inspect::FAKE_OPAQUE_CODEC
• cli::inspect::KVTD_CODECS

Constants

• BUILD_INFO
• batch::BATCH_COLUMNAR_FORMAT
• batch::BATCH_COLUMNAR_FORMAT_PERCENT
• batch::BATCH_DELETE_ENABLED
• batch::BLOB_TARGET_SIZE
• batch::ENCODING_COMPRESSION_FORMAT
• batch::ENCODING_ENABLE_DICTIONARY
• batch::INLINE_WRITES_SINGLE_MAX_BYTES
• batch::INLINE_WRITES_TOTAL_MAX_BYTES
• batch::MAX_RUNS
• batch::MAX_RUN_LEN
• batch::RECORD_SCHEMA_ID
• batch::STRUCTURED_KEY_LOWER_LEN
• batch::STRUCTURED_ORDER
• batch::STRUCTURED_ORDER_UNTIL_SHARD
• cfg::BATCH_BUILDER_MAX_OUTSTANDING_PARTS
• cfg::COMPACTION_HEURISTIC_MIN_INPUTS
• cfg::COMPACTION_HEURISTIC_MIN_PARTS
• cfg::COMPACTION_HEURISTIC_MIN_UPDATES
• cfg::COMPACTION_MEMORY_BOUND_BYTES
• cfg::CONSENSUS_CONNECTION_POOL_TTL
• cfg::CONSENSUS_CONNECTION_POOL_TTL_STAGGER
• cfg::CRDB_CONNECT_TIMEOUT
• cfg::CRDB_TCP_USER_TIMEOUT
• cfg::GC_BLOB_DELETE_CONCURRENCY_LIMIT
• cfg::MiB
• cfg::STATE_VERSIONS_RECENT_LIVE_DIFFS_LIMIT
• cfg::USAGE_STATE_FETCH_CONCURRENCY_LIMIT
• cfg::USE_CRITICAL_SINCE_CATALOG
• cfg::USE_CRITICAL_SINCE_SNAPSHOT
• cfg::USE_CRITICAL_SINCE_SOURCE
• cfg::USE_CRITICAL_SINCE_TXN
• cfg::USE_GLOBAL_TXN_CACHE_SOURCE
• cli::admin::CATALOG_FORCE_COMPACTION_FUEL
• cli::admin::CATALOG_FORCE_COMPACTION_WAIT
• cli::admin::EXPRESSION_CACHE_FORCE_COMPACTION_FUEL
• cli::admin::EXPRESSION_CACHE_FORCE_COMPACTION_WAIT
• cli::args::NO_COMMIT
• cli::args::READ_ALL_BUILD_INFO
• fetch::FETCH_SEMAPHORE_COST_ADJUSTMENT
• fetch::FETCH_SEMAPHORE_PERMIT_ADJUSTMENT
• fetch::PART_DECODE_FORMAT
• internal::cache::BLOB_CACHE_MEM_LIMIT_BYTES
• internal::compact::COMPACTION_CHECK_PROCESS_FLAG
• internal::compact::COMPACTION_MINIMUM_TIMEOUT
• internal::compact::COMPACTION_USE_MOST_RECENT_SCHEMA
• internal::machine::CLAIM_COMPACTION_MIN_VERSION
• internal::machine::CLAIM_COMPACTION_PERCENT
• internal::machine::CLAIM_UNCLAIMED_COMPACTIONS
• internal::machine::INFO_MIN_ATTEMPTS
• internal::machine::NEXT_LISTEN_BATCH_RETRYER_CLAMP
• internal::machine::NEXT_LISTEN_BATCH_RETRYER_FIXED_SLEEP
• internal::machine::NEXT_LISTEN_BATCH_RETRYER_INITIAL_BACKOFF
• internal::machine::NEXT_LISTEN_BATCH_RETRYER_MULTIPLIER
• internal::machine::RECORD_COMPACTIONS
• internal::state::ROLLUP_THRESHOLD
• internal::state::WRITE_DIFFS_SUM
• internal::trace::BATCHES_PER_LEVEL
• iter::MINIMUM_CONSOLIDATED_VERSION
• operators::STORAGE_SOURCE_DECODE_FUEL
• project::OPTIMIZE_IGNORED_DATA_DECODE
• project::OPTIMIZE_IGNORED_DATA_FETCH
• read::READER_LEASE_DURATION
• rpc::PERSIST_PUBSUB_CALLER_KEY
• rpc::PUBSUB_CLIENT_ENABLED
• rpc::PUBSUB_PUSH_DIFF_ENABLED
• rpc::PUBSUB_SAME_PROCESS_DELEGATE_ENABLED
• stats::STATS_AUDIT_PERCENT
• stats::STATS_BUDGET_BYTES
• stats::STATS_COLLECTION_ENABLED
• stats::STATS_FILTER_ENABLED
• stats::STATS_UNTRIMMABLE_COLUMNS_EQUALS
• stats::STATS_UNTRIMMABLE_COLUMNS_PREFIX
• stats::STATS_UNTRIMMABLE_COLUMNS_SUFFIX