Get ID.

Check if a resource exists in the repository by `id` # Panics This panics if the `id` is in the id-to-name map, but not in the actual repository map

Create `ID->name` map for columns.

Parse an identifier list, as expected by the `WITH KEY IN` clause.

Creates the Arrow schema for the influxdb_schema system table. The schema consists of three columns: - `measurement`: The table/measurement name (Str

Extract the inner future if present. Returns None for WasCached states, Some(future) for AlreadyLoading/NewEntry states. This allows tests to access

Install a global tracing/logging subscriber. Call this function when installing a subscriber instead of calling `tracing::subscriber::set_global_defa

Returns the indices and ids in `self` that are present in both `self` and `other` ``` # use data_types::{ColumnId, ColumnSet}; let a = ColumnSet::new

Consume `self` and return a [`HttpConnection`] (suitable for making calls to /api/v2 endpoints)

Convert this into the inner [`LinesParsed`] This is mainly used for testing

Convert into a logical plan builder.

Take the subject from the authorization.

Special purpose `Expr` rewrite rules for IOx DataFusion has many `Expr` rewrite / simplification rules that are generally useful. However, there are

Return the IOx schema view for the data provided by this provider

Return a [`SqlInfoData`] that describes IOx's capablities

Return `true` if the order by clause is ascending.

if we can rewrite this case statement

returns the column name for an expression like `IS NOT NULL(col)` or `NOT(IS NULL(col))`

returns the column name for an expression like `col = <lit>`

Returns true if this binary operator returns a boolean value

Returns true if this is the date_part function.

Returns true if the receiver is a data type that identifies as a field type.

Check if expression is a literal.

Return true if the error is recoverable and may be retried.

Check if a parameter name contains sensitive information

Is this a `SHOW DATABASES` statement

Is this a `SHOW RETENTION POLICIES` statement

Check the `stopped` state on this channel

Returns a function to validate keys for the specified `key_type` using the [is_valid] function.

Return an iterator of all [`SequenceNumber`] in this set.

Speciffy the key columns for the cache

List all Labels

Return the `(batch_idx, row_idx)` of the last buffered row.

Build a v2-shaped (`OrderedCatalogBatch`) JSON response for a cache-create operation, preserving the wire contract clients deserialize.

Senseless - there must always be >0 parts.

Returns an iterator of all keys currently in the [`S3Fifo`] cache. Note that the keys listed in the cache are those which have returned from the [`Ca

Loads all catalog files from object store to build the catalog

Reconstruct an [`InnerCatalog`] from the object store: load the snapshot, then discover and apply every subsequent log file. Log discovery uses `list

Load and parse a [`CatalogFile`] at an arbitrary object-store path, or `Ok(None)` if absent. Unlike [`Self::load_file`], the path is supplied directly

This is a test helper that sets a few test-friendly parameters such as disabled ANSI escape sequences on the provided builder. This helper then calls

Logically plan a SQL query against the catalogs registered with `ctx`, and return a DataFusion logical plan that runs on the query executor.

Returns the ID in self.dictionary that corresponds to `value`, if any.

Names of other columns

Build a complete catalog file from a pre-encoded payload, header counts, and flags. Shared by [`serialize_log_file`] and [`serialize_snapshot_file`],

Creates expression like: start <= time && time < end