Module mz_catalog::durable::persist

Structs

• CatalogStateInner 🔒
  Applies updates for an opened catalog.
• PersistHandle 🔒
  A handle for interacting with the persist catalog shard.
• UnopenedCatalogStateInner 🔒
  Applies updates for an unopened catalog.

Enums

• CompareAndAppendError 🔒
  An error that can occur while executing PersistHandle::compare_and_append.
• FenceableToken 🔒
  Enum representing the fenced state of the catalog.
• Mode 🔒
  Durable catalog mode that dictates the effect of mutable operations.

Constants

• BUILTIN_MIGRATION_SEED
  Seed used to generate the persist shard ID for builtin table migrations.
• CATALOG_SEED 🔒
  Seed used to generate the persist shard ID for the catalog.
• CATALOG_SHARD_NAME 🔒
  Human readable catalog shard name.
• EXPRESSION_CACHE_SEED
  Seed used to generate the persist shard ID for the expression cache.
• MIN_EPOCH 🔒
  The minimum value of an epoch.
• UPGRADE_SEED 🔒
  Seed used to generate the catalog upgrade shard ID.
• UPGRADE_SHARD_NAME 🔒
  Human readable catalog upgrade shard name.

Traits

• ApplyUpdate 🔒

Functions

• antichain_to_timestamp 🔒
  Convert an Antichain<Timestamp> to a Timestamp.
• as_of 🔒
  Generates a timestamp for reading from read_handle that is as fresh as possible, given upper.
• desc 🔒
  Returns the schema of the Rows/SourceDatas stored in the persist shard backing the catalog.
• fetch_catalog_upgrade_shard_version 🔒
  Fetch the persist version of the catalog upgrade shard, if one exists. A version will not exist if we are creating a brand-new environment.
• shard_id
  Deterministically generate a shard ID for the given organization_id and seed.
• snapshot_binary 🔒
  Generates an iterator of StateUpdate that contain all updates to the catalog state up to, and including, as_of.
• snapshot_binary_inner 🔒
  Generates an iterator of StateUpdate that contain all updates to the catalog state up to, and including, as_of.

Type Aliases

• PersistCatalogState 🔒
  A durable store of the catalog state using Persist as an implementation. The durable store can serve any catalog data and transactionally modify catalog data.
• Timestamp 🔒
  New-type used to represent timestamps in persist.
• UnopenedPersistCatalogState 🔒
  A Handle to an unopened catalog stored in persist. The unopened catalog can serve Config data, Setting data, or the current epoch. All other catalog data may be un-migrated and should not be read until the catalog has been opened. The UnopenedPersistCatalogState is responsible for opening the catalog, see OpenableDurableCatalogState::open for more details.