List of all items

Structs

• CoreVersion
• common::CommitVersion
• encoded::encoded::EncodedValues
• encoded::key::EncodedKey
• encoded::key::EncodedKeyBuilder
• encoded::key::EncodedKeyRange
• encoded::schema::Inner
• encoded::schema::Schema
• encoded::schema::SchemaField
• encoded::schema::evolution::SchemaResolver
• encoded::schema::fingerprint::SchemaFingerprint
• event::EventBus
• event::flow::FlowOperatorLoadedEvent
• event::flow::OperatorColumnDef
• event::metric::CdcEntryDrop
• event::metric::CdcEntryStats
• event::metric::CdcStatsDroppedEvent
• event::metric::CdcStatsRecordedEvent
• event::metric::StorageDelete
• event::metric::StorageDrop
• event::metric::StorageStatsRecordedEvent
• event::metric::StorageWrite
• event::store::StatsProcessedEvent
• event::transaction::PostCommitEvent
• interface::catalog::column::ColumnDef
• interface::catalog::column::ColumnIndex
• interface::catalog::dictionary::DictionaryDef
• interface::catalog::flow::FlowDef
• interface::catalog::flow::FlowEdgeDef
• interface::catalog::flow::FlowEdgeId
• interface::catalog::flow::FlowId
• interface::catalog::flow::FlowNodeDef
• interface::catalog::flow::FlowNodeId
• interface::catalog::id::ColumnId
• interface::catalog::id::ColumnPolicyId
• interface::catalog::id::NamespaceId
• interface::catalog::id::PrimaryKeyId
• interface::catalog::id::RingBufferId
• interface::catalog::id::SequenceId
• interface::catalog::id::SubscriptionColumnId
• interface::catalog::id::SubscriptionId
• interface::catalog::id::TableId
• interface::catalog::id::ViewId
• interface::catalog::key::PrimaryKeyDef
• interface::catalog::namespace::NamespaceDef
• interface::catalog::policy::ColumnPolicy
• interface::catalog::ringbuffer::RingBufferDef
• interface::catalog::ringbuffer::RingBufferMetadata
• interface::catalog::subscription::SubscriptionColumnDef
• interface::catalog::subscription::SubscriptionDef
• interface::catalog::sumtype::FieldDef
• interface::catalog::sumtype::SumTypeDef
• interface::catalog::sumtype::VariantDef
• interface::catalog::table::TableDef
• interface::catalog::view::ViewDef
• interface::catalog::vtable::VTableDef
• interface::catalog::vtable::VTableId
• interface::cdc::Cdc
• interface::cdc::CdcBatch
• interface::cdc::CdcConsumerId
• interface::cdc::ConsumerState
• interface::change::Change
• interface::flow::FlowLagRow
• interface::identifier::ColumnIdentifier
• interface::resolved::FunctionDef
• interface::resolved::IndexDef
• interface::resolved::ResolvedColumn
• interface::resolved::ResolvedDeferredView
• interface::resolved::ResolvedDictionary
• interface::resolved::ResolvedFlow
• interface::resolved::ResolvedFunction
• interface::resolved::ResolvedIndex
• interface::resolved::ResolvedNamespace
• interface::resolved::ResolvedRingBuffer
• interface::resolved::ResolvedSequence
• interface::resolved::ResolvedSubscription
• interface::resolved::ResolvedTable
• interface::resolved::ResolvedTableVirtual
• interface::resolved::ResolvedTransactionalView
• interface::resolved::ResolvedView
• interface::resolved::SequenceDef
• interface::store::MultiVersionBatch
• interface::store::MultiVersionValues
• interface::store::SingleVersionBatch
• interface::store::SingleVersionValues
• interface::version::SystemVersion
• key::cdc_consumer::CdcConsumerKey
• key::cdc_consumer::CdcConsumerKeyRange
• key::column::ColumnKey
• key::column_policy::ColumnPolicyKey
• key::column_sequence::ColumnSequenceKey
• key::columns::ColumnsKey
• key::dictionary::DictionaryEntryIndexKey
• key::dictionary::DictionaryEntryIndexKeyRange
• key::dictionary::DictionaryEntryKey
• key::dictionary::DictionaryKey
• key::dictionary::DictionarySequenceKey
• key::flow::FlowKey
• key::flow_edge::FlowEdgeByFlowKey
• key::flow_edge::FlowEdgeKey
• key::flow_node::FlowNodeByFlowKey
• key::flow_node::FlowNodeKey
• key::flow_node_internal_state::FlowNodeInternalStateKey
• key::flow_node_internal_state::FlowNodeInternalStateKeyRange
• key::flow_node_state::FlowNodeStateKey
• key::flow_node_state::FlowNodeStateKeyRange
• key::flow_version::FlowVersionKey
• key::index::IndexKey
• key::index::PrimitiveIndexKeyRange
• key::index_entry::IndexEntryKey
• key::index_entry::IndexEntryKeyRange
• key::namespace::NamespaceKey
• key::namespace_dictionary::NamespaceDictionaryKey
• key::namespace_flow::NamespaceFlowKey
• key::namespace_ringbuffer::NamespaceRingBufferKey
• key::namespace_sumtype::NamespaceSumTypeKey
• key::namespace_table::NamespaceTableKey
• key::namespace_view::NamespaceViewKey
• key::primary_key::PrimaryKeyKey
• key::retention_policy::OperatorRetentionPolicyKey
• key::retention_policy::OperatorRetentionPolicyKeyRange
• key::retention_policy::PrimitiveRetentionPolicyKey
• key::retention_policy::PrimitiveRetentionPolicyKeyRange
• key::ringbuffer::RingBufferKey
• key::ringbuffer::RingBufferMetadataKey
• key::row::RowKey
• key::row::RowKeyRange
• key::row_sequence::RowSequenceKey
• key::schema::SchemaFieldKey
• key::schema::SchemaKey
• key::subscription::SubscriptionKey
• key::subscription_column::SubscriptionColumnKey
• key::subscription_row::SubscriptionRowKey
• key::subscription_row::SubscriptionRowKeyRange
• key::sumtype::SumTypeKey
• key::system_sequence::SystemSequenceKey
• key::system_version::SystemVersionKey
• key::table::TableKey
• key::transaction_version::TransactionVersionKey
• key::view::ViewKey
• row::Row
• sort::SortKey
• util::bloom::BloomFilter
• util::bloom::BloomFilterBuilder
• util::colored::ColoredString
• util::encoding::format::raw::Raw
• util::encoding::keycode::deserializer::KeyDeserializer
• util::encoding::keycode::serializer::KeySerializer
• util::ioc::IocContainer
• util::ioc::resolve_arc::LazyResolveArc
• util::ioc::resolve_rc::LazyResolveRc
• util::lru::LruCache
• util::multi::MultiVersionContainer
• util::wait_group::WaitGroup
• value::batch::lazy::LazyBatch
• value::batch::lazy::LazyColumnMeta
• value::column::Column
• value::column::columns::Columns
• value::column::compressed::CompressedColumn
• value::column::headers::ColumnHeaders
• value::column::pool::Pools
• value::column::pool::PoolsInner
• value::column::pool::allocator::StdPoolAllocator
• value::column::pool::config::PoolConfig
• value::column::pool::guard::PooledGuard
• value::column::pool::scoped::ScopedPools
• value::column::pool::stats::PoolStats
• value::frame::render::FrameRenderer
• value::index::encoded::EncodedIndexKey
• value::index::layout::EncodedIndexLayout
• value::index::layout::EncodedIndexLayoutInner
• value::index::layout::IndexField
• value::index::range::EncodedIndexKeyRange

Enums

• common::IndexType
• common::JoinType
• common::WindowSize
• common::WindowSlide
• common::WindowTimeMode
• common::WindowType
• delta::Delta
• encoded::schema::evolution::FieldMapping
• interface::auth::Identity
• interface::catalog::flow::FlowStatus
• interface::catalog::id::IndexId
• interface::catalog::policy::ColumnPolicyKind
• interface::catalog::policy::ColumnSaturationPolicy
• interface::catalog::primitive::PrimitiveDef
• interface::catalog::primitive::PrimitiveId
• interface::catalog::view::ViewKind
• interface::cdc::SystemChange
• interface::change::ChangeOrigin
• interface::change::Diff
• interface::evaluate::TargetColumn
• interface::identifier::ColumnPrimitive
• interface::resolved::ResolvedPrimitive
• interface::version::ComponentType
• key::Key
• key::kind::KeyKind
• key::system_version::SystemVersion
• retention::CleanupAction
• retention::CleanupMode
• retention::RetentionPolicy
• sort::SortDirection
• util::colored::Color
• util::either::Either
• util::retry::RetryError
• value::batch::Batch
• value::column::compressed::CompressionType
• value::column::data::ColumnData

Traits

• encoded::encoded::EncodedValuesIterator
• encoded::key::IntoEncodedKey
• event::Event
• event::EventListener
• interface::WithEventBus
• interface::catalog::change::CatalogTrackChangeOperations
• interface::catalog::change::CatalogTrackDictionaryChangeOperations
• interface::catalog::change::CatalogTrackFlowChangeOperations
• interface::catalog::change::CatalogTrackNamespaceChangeOperations
• interface::catalog::change::CatalogTrackRingBufferChangeOperations
• interface::catalog::change::CatalogTrackSubscriptionChangeOperations
• interface::catalog::change::CatalogTrackSumTypeChangeOperations
• interface::catalog::change::CatalogTrackTableChangeOperations
• interface::catalog::change::CatalogTrackViewChangeOperations
• interface::catalog::layout::GetSchema
• interface::flow::FlowLagsProvider
• interface::store::MultiVersionCommit
• interface::store::MultiVersionContains
• interface::store::MultiVersionGet
• interface::store::MultiVersionGetPrevious
• interface::store::MultiVersionStore
• interface::store::SingleVersionCommit
• interface::store::SingleVersionContains
• interface::store::SingleVersionGet
• interface::store::SingleVersionRange
• interface::store::SingleVersionRangeRev
• interface::store::SingleVersionRemove
• interface::store::SingleVersionSet
• interface::store::SingleVersionStore
• interface::version::HasVersion
• key::EncodableKey
• key::EncodableKeyRange
• key::cdc_consumer::ToConsumerKey
• util::colored::Colorize
• util::encoding::format::Formatter
• value::column::data::get::FromColumnData
• value::column::data::slice::AsSlice
• value::column::pool::allocator::PoolAllocator
• value::column::pool::capacity::ContainerCapacity
• value::column::pool::guard::Releasable
• value::column::push::Push
• value::index::encoded::EncodedIndexKeyIterator

Macros

• define_event
• internal
• internal_err
• internal_error
• key_prefix
• return_internal_error

Functions

• encoded::schema::consolidate::consolidate_schemas
• encoded::schema::consolidate::widen_type
• encoded::schema::fingerprint::compute_fingerprint
• error::diagnostic::catalog::auto_increment_invalid_type
• error::diagnostic::catalog::cannot_delete_already_deleted_namespace
• error::diagnostic::catalog::cannot_delete_already_deleted_table
• error::diagnostic::catalog::cannot_delete_already_deleted_view
• error::diagnostic::catalog::cannot_update_deleted_namespace
• error::diagnostic::catalog::cannot_update_deleted_table
• error::diagnostic::catalog::cannot_update_deleted_view
• error::diagnostic::catalog::dictionary_already_exists
• error::diagnostic::catalog::dictionary_not_found
• error::diagnostic::catalog::dictionary_type_mismatch
• error::diagnostic::catalog::flow_already_exists
• error::diagnostic::catalog::flow_not_found
• error::diagnostic::catalog::index_types_directions_mismatch
• error::diagnostic::catalog::index_variable_length_not_supported
• error::diagnostic::catalog::namespace_already_exists
• error::diagnostic::catalog::namespace_already_pending_in_transaction
• error::diagnostic::catalog::namespace_not_found
• error::diagnostic::catalog::primary_key_column_not_found
• error::diagnostic::catalog::primary_key_empty
• error::diagnostic::catalog::ringbuffer_already_exists
• error::diagnostic::catalog::ringbuffer_not_found
• error::diagnostic::catalog::subscription_already_exists
• error::diagnostic::catalog::subscription_not_found
• error::diagnostic::catalog::sumtype_already_exists
• error::diagnostic::catalog::sumtype_not_found
• error::diagnostic::catalog::table_already_exists
• error::diagnostic::catalog::table_already_pending_in_transaction
• error::diagnostic::catalog::table_column_already_exists
• error::diagnostic::catalog::table_column_policy_already_exists
• error::diagnostic::catalog::table_not_found
• error::diagnostic::catalog::view_already_exists
• error::diagnostic::catalog::view_already_pending_in_transaction
• error::diagnostic::catalog::view_column_already_exists
• error::diagnostic::catalog::view_not_found
• error::diagnostic::catalog::virtual_table_already_exists
• error::diagnostic::catalog::virtual_table_not_found
• error::diagnostic::engine::frame_error
• error::diagnostic::engine::invalid_parameter_reference
• error::diagnostic::engine::invalid_row_number_values
• error::diagnostic::engine::missing_row_number_column
• error::diagnostic::engine::parameter_not_found
• error::diagnostic::engine::saturation_error
• error::diagnostic::flow::flow_already_registered
• error::diagnostic::flow::flow_backfill_timeout
• error::diagnostic::flow::flow_dispatcher_unavailable
• error::diagnostic::flow::flow_error
• error::diagnostic::flow::flow_transaction_keyspace_overlap
• error::diagnostic::flow::flow_version_corrupted
• error::diagnostic::index::primary_key_violation
• error::diagnostic::index::unique_index_violation
• error::diagnostic::internal::internal
• error::diagnostic::internal::internal_with_context
• error::diagnostic::internal::shutdown
• error::diagnostic::operation::aggregate_by_missing_braces
• error::diagnostic::operation::aggregate_missing_braces
• error::diagnostic::operation::aggregate_multiple_by_without_braces
• error::diagnostic::operation::aggregate_multiple_map_without_braces
• error::diagnostic::operation::apply_missing_braces
• error::diagnostic::operation::apply_multiple_arguments_without_braces
• error::diagnostic::operation::delete_missing_filter_clause
• error::diagnostic::operation::delete_missing_target
• error::diagnostic::operation::distinct_missing_braces
• error::diagnostic::operation::distinct_multiple_columns_without_braces
• error::diagnostic::operation::extend_missing_braces
• error::diagnostic::operation::extend_multiple_expressions_without_braces
• error::diagnostic::operation::filter_missing_braces
• error::diagnostic::operation::insert_missing_source
• error::diagnostic::operation::insert_missing_target
• error::diagnostic::operation::insert_mixed_row_types
• error::diagnostic::operation::insert_positional_wrong_length
• error::diagnostic::operation::map_missing_braces
• error::diagnostic::operation::map_multiple_expressions_without_braces
• error::diagnostic::operation::missing_aggregate_map_block
• error::diagnostic::operation::patch_missing_braces
• error::diagnostic::operation::select_missing_braces
• error::diagnostic::operation::select_multiple_expressions_without_braces
• error::diagnostic::operation::sort_missing_braces
• error::diagnostic::operation::take_missing_braces
• error::diagnostic::operation::take_negative_value
• error::diagnostic::operation::update_empty_assignments_block
• error::diagnostic::operation::update_missing_assignments_block
• error::diagnostic::operation::update_missing_filter_clause
• error::diagnostic::operation::window_incompatible_slide_type
• error::diagnostic::operation::window_incompatible_type_size
• error::diagnostic::operation::window_missing_slide_parameter
• error::diagnostic::operation::window_missing_type_or_size
• error::diagnostic::operation::window_slide_too_large
• error::diagnostic::operation::window_tumbling_with_slide
• error::diagnostic::query::column_not_found
• error::diagnostic::query::extend_duplicate_column
• error::diagnostic::query::join_column_alias_error
• error::diagnostic::query::unsupported_source_qualification
• error::diagnostic::sequence::can_not_alter_not_auto_increment
• error::diagnostic::sequence::sequence_exhausted
• error::diagnostic::subsystem::address_unavailable
• error::diagnostic::subsystem::bind_failed
• error::diagnostic::subsystem::feature_disabled
• error::diagnostic::subsystem::init_failed
• error::diagnostic::subsystem::shutdown_failed
• error::diagnostic::subsystem::socket_config_failed
• error::diagnostic::transaction::commit_failed
• error::diagnostic::transaction::key_out_of_scope
• error::diagnostic::transaction::transaction_already_committed
• error::diagnostic::transaction::transaction_already_rolled_back
• error::diagnostic::transaction::transaction_conflict
• error::diagnostic::transaction::transaction_rolled_back
• error::diagnostic::transaction::transaction_too_large
• interface::catalog::subscription::subscription_flow_name
• interface::catalog::subscription::subscription_flow_namespace
• interface::resolved::resolved_column_to_number_descriptor
• key::cdc_exclude::should_exclude_from_cdc
• util::encoding::binary::decode_binary
• util::encoding::keycode::catalog::deserialize_index_id
• util::encoding::keycode::catalog::deserialize_primitive_id
• util::encoding::keycode::catalog::serialize_index_id
• util::encoding::keycode::catalog::serialize_primitive_id
• util::encoding::keycode::deserialize
• util::encoding::keycode::encode_bool
• util::encoding::keycode::encode_bytes
• util::encoding::keycode::encode_f32
• util::encoding::keycode::encode_f64
• util::encoding::keycode::encode_i128
• util::encoding::keycode::encode_i16
• util::encoding::keycode::encode_i32
• util::encoding::keycode::encode_i64
• util::encoding::keycode::encode_i8
• util::encoding::keycode::encode_u128
• util::encoding::keycode::encode_u16
• util::encoding::keycode::encode_u32
• util::encoding::keycode::encode_u64
• util::encoding::keycode::encode_u8
• util::encoding::keycode::serialize
• util::ioc::resolve_arc::resolver
• util::retry::retry
• value::column::pool::config::init_default_thread_pools
• value::column::pool::config::init_development_pools
• value::column::pool::config::init_production_pools
• value::column::pool::config::init_test_pools
• value::column::pool::config::init_thread_pools
• value::column::pool::lazy::ensure_thread_pools
• value::column::pool::lazy::get_default_pool_config
• value::column::pool::lazy::get_or_init_pools
• value::column::pool::lazy::set_default_pool_config
• value::column::pool::lazy::thread_pools_lazy
• value::column::pool::scoped::with_default_pools
• value::column::pool::scoped::with_scoped_pools
• value::column::pool::scoped::with_test_pools
• value::column::pool::thread_local::clear_thread_pools
• value::column::pool::thread_local::get_thread_pools
• value::column::pool::thread_local::has_thread_pools
• value::column::pool::thread_local::set_thread_pools
• value::column::pool::thread_local::thread_pools
• value::column::pool::thread_local::with_temporary_pools
• value::column::pool::thread_local::with_thread_pools

Type Aliases

• encoded::encoded::EncodedValuesIter
• interface::auth::IdentityId
• value::column::view::group_by::GroupByView
• value::column::view::group_by::GroupKey
• value::index::encoded::EncodedIndexKeyIter

Constants

• encoded::encoded::SCHEMA_HEADER_SIZE
• encoded::schema::SCHEMA_HEADER_SIZE
• interface::catalog::policy::DEFAULT_COLUMN_SATURATION_POLICY
• interface::catalog::subscription::IMPLICIT_COLUMN_OP
• key::cdc_consumer::VERSION_BYTE