Create a new, empty catalog.

Create a new [`TableDefinition`] Ensures the provided columns will be ordered before constructing the schema.

Create a new registration entry for a record type.

Create a new record header.

Create a new `LimitObjectStore` that limits the maximum number of outstanding concurrent requests to `max_permits`. Semaphore metrics (permits acquir

Creates a new WAL. This will replay files into the notifier and trigger any snapshots that exist in the WAL files that haven't been cleaned up yet.

Create a new `SnapshotTracker` with the given snapshot size and gen1 duration. The gen1 duration is the size of chunks in the write buffer that will b

Create statistics for a column that only has nulls up to now

Create a new [`TraceService`] for instrumenting a client

Constructs a new `MeasurementNameExpression` with the specified `name` and `database`.

Constructs a new `MeasurementNameExpression` with the specified `name`, `database` and `retention_policy`.

Create a new [`CacheValue`] with no data and the provided `generation`.

Create new empty `TableDefinition`

Create new empty `TableDefinition`

Create new empty `TableDefinition`

Start a new `NamespaceSchema` with empty `tables` but the rest of the information populated from the given `Namespace`.

Construct a `Catalog` for a node in an Enterprise cluster.

Initialize a [`DistinctCacheProvider`] from a [`Catalog`], populating the provider's `cache_map` from the definitions in the catalog.

Initialize a [`LastCacheProvider`] from a [`Catalog`]

Initialize a [`DistinctCacheProvider`] from a [`Catalog`], populating the provider's `cache_map` from the definitions in the catalog. This starts a ba

Initialize a [`LastCacheProvider`] from a [`Catalog`] and run a background process to evict expired entries from the cache

Create a new `PersistedFiles` from checkpoints and additional snapshots. This is the preferred method when checkpoints are available, as it reduces t

Create a new IQLSchema from a [`DataSourceSchema`] from the FROM clause of a query or subquery.

Create a new IQLSchema from a list of [`Field`]s on the SELECT list of a subquery.

Create a new client from an existing [`FlightClient`]

Create a new table definition from a catalog op

Create a new table definition from a catalog op

Create and validate a new Schema, creating metadata to represent the the various parts. This method is intended to be used only by the SchemaBuilder.

Create a new `PersistedFiles` from a list of persisted snapshots Accepts `Arc<Vec<PersistedSnapshot>>` to allow sharing the snapshot data between mul

Create new S3Fifo from a deserialized snapshot. This function deserializes a snapshot and creates a new S3Fifo instance with the restored state, incl

Create a new S3FifoCache from a snapshot. This function deserializes a snapshot and creates a new cache instance with the restored state. # Paramete

Create a new value buffer containing only the given `value`.

The chunk id is only effective in case the chunk's order is the same with another chunk. Hence collisions are safe in that context.

Validates the updates in the `CatalogBatch` are compatible with this schema. If everything is compatible and there are no updates to the existing sche

Validates the updates in the `CatalogBatch` are compatible with this schema. If everything is compatible and there are no updates to the existing sche

Create new `Catalog` that uses an in-memory object store. # Note This is intended as a convenience constructor for testing

Construct a `Catalog` backed by an in-memory object store and a `MockProvider` clock fixed at epoch. # Implementation Note This is intended for test

Create new `Catalog` that uses an in-memory object store with additional configuration arguments. # Note This is intended as a convenience construct

Create new `Catalog` that uses an in-memory object store with additional configuration arguments. # Note This is intended as a convenience construct

Create new `Catalog` that uses an in-memory object store with additional configuration arguments and limits for testing. # Note This is intended as