List the contents of the remote cache Values larger than `max_value_size` will not be returned inline, with only the key and generation returned inst

Loads the most recently persisted N snapshot parquet file lists from object storage. This is intended to be used on server start.

Return the min (as [`Row`]) at the specified index

Return `self != other`

Notifier.

Returns the number of null rows in this column

Parse a signed [`Number`].

TODO port this upstream to datafusion (maybe as From<Option> for Precision) Maps `Option::Some(T)` to `Precision::Exact(T)` and `Option::None` to `Pre

Runs `overlap` on all permutations of the given `value_range`es and asserts that the result is the same. Returns that result

records an event by adding it to this event store

Format `timestamp` to the format spec provided during initialisation, writing the result to `out`.

Parse a `SHOW TAG VALUES` statement, starting from the `VALUES` token.

Splits the FileRange into two FileRanges at a given point, which will be the first point of the second FileRange. The split point is required to be wi

Parse a single InfluxQL statement.

Bounds the total amount of time a single client HTTP request take before being aborted. This timeout includes: - Establishing the TCP connection (se

Updates statistics from other if the same type, otherwise a noop

Set the object store dir for this [`TestServer`]

Sets the timestamp range

Iterate over all registered records.

Apply all records from a parsed [`CatalogFile`] to the catalog. Convenience wrapper over [`apply_records`] that extracts the sequence number from the

return the inner plan

Get builder.

Convert something that can be converted into a [`hyper::body::Bytes`] into a [`RequestBody`] that sends one chunk of bytes in full. Mostly useful whe

Check for a v2 catalog at `prefix` and migrate it to v3 if present. Idempotent: re-running after success returns [`MigrationResult::AlreadyMigrated`]

Returns a [`CatalogCacheClient`] for communicating with this server

Returns `Time` as a [`DateTime<Utc>`]

Atomically updates this gauge to `max(current, val)`. Returns the previous value.

Synchronously checkpoint the catalog at its current sequence. Skips the throttling that [`Self::maybe_background_checkpoint`] applies (slot acquisiti

Get all captured logs (stdout and stderr combined), if log capture was enabled

Parse a `GROUP BY` clause. ```text group_by_clause ::= dimension ( "," dimension ) ```

Create the snapshot file. Create-only so that racing initializers resolve to a single winner.

Input schema

Get the measurement name this series belongs to.

Extract the metric named `metric`, or panic. # Panics Panics if `metric` does not appear in the [`MetricSet`].

Return the name of the column.

Parse an InfluxQL `ORDER BY` clause. An `ORDER BY` in InfluxQL is limited when compared to the equivalent SQL definition. It is defined by the follow

Sanitize an InfluxQL regular expression and create a compiled [`regex::Regex`].

Remove the last wrote value and return it. This call does not panic when empty.

Set the precision

For [`ProjectionExec`](datafusion::physical_plan::projection::ProjectionExec), selectively cast schema projection on [`Statistics`]. This differs fro

Execute a SQL query on the server using [`CommandStatementQuery`] This involves two round trips Step 1: send a [`CommandStatementQuery`] message to

Return a value by applying the operation defined by the receiver.

Rewrite the expression tree and return a result or `NULL` if some of the operands are incompatible. Rewrite and coerce the expression tree to model t

Assigns row numbers to elements in an array, respecting partition boundaries. This function generates sequential row numbers for each element in the

The return conditions for this method are, - the original task output if it exits cleanly - the task itself runs into an error - the task gets aborted