Removes all elements from this array

Remove all resources from the repository. This does not reset `next_id` — IDs are never reused.

closes the writer, flushing any remaining data and returning the written [`ParquetMetaData`]

Returns an iterator that for each chunk returns the [`Statistics`] for the provided `column` if any

Returns the [`DataType`] for `column`

Signal back to the [`ShutdownManager`] that the component that owns this token is finished cleaning up and it is safe for the process to exit # Imple

Computes the ranges where the sort key has the same values

Compute the SHA512 hash of a token string This is the canonical way to hash tokens across the codebase

Map an InfluxQL [`ConditionalExpression`] to a DataFusion [`Expr`].

Helper function for creation of a [`MemCachedObjectStore`] and [`MemCacheOracle`] that returns them as their `Arc<dyn _>` equivalent.

Create a new database with the supplied options.

Create a [LogicalPlan] that refers to the specified `table_name`. Normally, this functions will not return a `None`, as tables have been matched] by

Create a table definition with pre-populated columns

Helper function to create test CoreTableIndex

Computes the current catalog usage statistics.

Point-in-time catalog usage counts — non-deleted, non-internal databases and their non-deleted tables. Fed to [`CatalogLimiter`][super::usage::Catalog

Returns an iterator over the [`FieldViolation`] in the provided [`tonic::Status`]

Decodes a given header from the provided HeaderMap to a string - Returns Ok(None) if the header doesn't exist - Returns Err if the header fails to de

Tries to process `maybe_wrapped_fun` as an [`AggregateFunction`] which may be wrapped by a type which does not change its return type (e.g. [`Alias`];

Calculate the absolute difference of two numerical values.

Calculate the nanosecond time difference, scaled to the unit.

Calculate the nanosecond time difference, scaled to the unit.

Emits `lhs / rhs` but will result in `0` (instead of NULL) for devision by zero. The result is NULL if either operant is NULL.

Perform a lower level client read with the `ReadInfo`

Helper function to apply schema transformation to a plan and return the transformed plan

Simplifies an InfluxQL duration `expr` to a nanosecond interval represented as an `i64`.

Encode series keys into a base64 string with length-prefixed format. This encoding allows tag names to contain any characters, including '/' which is

Return a [`fmt::Display`] that renders string while escaping any characters in the `special_characters` array with a `\`

Returns the etag if any

Expand tables from `FROM` clause in metadata queries.

Attempt to extract LexicalRanges for the given sort keys and input plan Output will have N ranges where N is the number of output partitions Returns

Helper function to extract all components from CacheState for tests with early access data

Extract a token from an HTTP header or gRPC metadata value.

Try to convert type using TryInto calling [`FieldViolation::scope`] on any returned error

Returns the field columns for the specified field family, if it exists.

Find the index of the time column in the fields list. > **Note > > To match InfluxQL, the `time` column must not exist as part of a > complex express

Given a plan and a column, finds the predicates that use that column and return a range with expressions for upper and lower bounds.

Generates a vector of partition key strings, or an error. This function normalises the de-duplicated output of [`partition_keys()`], returning the la

Generate the default InfluxQL metadata map for producing a `Schema` for the `SHOW DATABASES` query.

Returns the value for `key` if it exists

Gets entry from the set, returns `None` if the key is NOT stored. Note that even when the key is NOT stored as an entry, it may be known as a "ghost"

Get current count.

Get a user by their username (looks up through login identity)

Output the records for a given cache as arrow [`RecordBatch`]es This method is meant for testing.

Helper to get checkpoint sequence numbers for a month (sorted newest first)

Returns an iterator over the [`protobuf::Any`] payloads in the provided [`tonic::Status`]

Figure out the database for this request by checking the "database=database_or_bucket_name" (preferred) or "bucket=database_or_bucket_name" or "bucket

Hard-delete a database.