Module 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

CATALOG_SEED 🔒

Seed used to generate the persist shard ID for the catalog.

CATALOG_SHARD_NAME 🔒

Human readable catalog shard name.

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.

_BUILTIN_MIGRATION_SEED

Legacy seed used to generate the persist shard ID for builtin table migrations. DO NOT REUSE.

_EXPRESSION_CACHE_SEED

Legacy seed used to generate the persist shard ID for the expression cache. DO NOT REUSE.

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.