Get the sort order defined for these tests.

Sort the output of this plan with the specified expressions

How much space is left. This is identical to the length of the [`tail`](Self::tail), but does not require a mutable reference to obtain.

Returns the current [`Span`] if any

Traverse `expr` and separate time range expressions from other predicates. # NOTE Combining relational operators like `time > now() - 5s` and equali

Split `input` into individual lines to be parsed, based on the rules of the line protocol format. This code is more or less a direct port of the [Go

Split a v2 soft-deleted resource name into its original name and the deletion timestamp encoded in the suffix. Soft-deleted database/tables are renam

Split [`TraceId`] into high and low part.

Plan a SQL statement, providing a list of parameter values to supply to `$placeholder` variables. This assumes that any tables referenced in the SQL h

Plan a SQL statement and convert it to an execution plan. This assumes that any tables referenced in the SQL have been registered with this context

Return the timestamp inclusive range's start.

Opt this receiver out of future broadcasts without closing the channel. Use during orderly shutdown to avoid broadcast errors from races with channel

Administratively stop a node. Records `Uuid::nil()` as the stopping process UUID to distinguish operator-driven stops from graceful-shutdown stops.

Responding with a stream of bytes, wrapping each frame in `Ok`. If you have a stream of `Result`s of `Bytes`, see [`stream_results_to_response_body`]

Get a [`SystemStatsReporter`] along with the path of the file it is generating as a `String`

Build a `comfy-table` from headers and string rows.

Branch to table subcommand

Deletion status of a table by ID within a database, or `None` if it exists and is not deleted.

Get a mutable reference to a [TableTransaction] for the given table name. If no table transaction exists and the table exists in the current `databas

Returns a tag column and a time column using the same algorithm as `tag_column` (so tag and time have the same values)

Take and return accumulated log lines. Returns an empty Vec for production loggers. Returns and clears the accumulated log lines for dry run loggers.

Helper to create a test catalog.

test chunk with time range and field1's value range and with a given chunk id

Execute the specified partition of the [ExecutionPlan] with a default [SessionContext] returning the resulting stream. # Panics If an an error occurs

Test a `min` and `max` time against this filter to check if the range they define overlaps with the range defined by the bounds in this filter.

Convert to an arrow with an optional null bitmask

Returns a field representation of this expression with its name, data type, and nullability. The field is derived from the underlying expression but

A helper function that calls [`to_parquet()`], serialising the parquet file into an in-memory buffer and returning the resulting bytes.

Get the token for the server

Returns the total number of rows (including nulls) in this column

Size of the entire buffer, including the initialized part and the uninitialized part. Also see [`space_left`](Self::space_left) and [`initialized_byt

Try to acquire `n` permits, returning [`tokio::sync::TryAcquireError::NoPermits`] immediately if there aren't enough permits left. See [`tokio::sync:

Extract `Option<bool>` from `ScalarValue::Boolean` with a descriptive error on type mismatch.

Take in 1 or more children, and returns a singular [`ExecutionPlan`]. If there are multiple children, it unions in order to return a singular executi

Provide unknown/absent statistics for all partitions in the plan.

Parse an unsigned InfluxQL integer. InfluxQL defines an integer as follows ```text INTEGER ::= [0-9]+ ```

Updates all table indices in the cache from object store. This method performs a comprehensive synchronization between the object store and the local

Update a cached index from the object store

Mark a node as stopped, recording the stopping process UUID. Used by a node's own graceful-shutdown path.

Update a table in the database. This fails if the table doesn't exist.

Check if a username already exists

Validate a database name A valid name: - Starts with a letter or a number - Is ASCII, not UTF-8 - Contains only letters, numbers, underscores, or hyp

Validate that a record's flags are appropriate for the given record ID. Returns an error if the record ID is unknown and the UPGRADE_SAFE flag is not

Specify the value columns for the cache

Perform a depth-first traversal of an expression tree.

Parse a wildcard expression. wildcard ::= "*" ( "::" ("field" | "tag")?

Calculate the partitioning for window functions.

Set the `Bearer` token that will be sent with each request to the server # Example ``` # use influxdb3_client::Client; # use influxdb3_client::Precis

If the given expression uses the given column with comparison operators, update this time range to reflect that.

Builder-style method to set the filled status for InfluxQL on the field.

specify a custom jaeger_debug_header_name For example, 'jaeger-debug-id'

Sets a [`CatalogCacheObserver`] for this [`CatalogCache`]

Set a query parameter value with the given `name` # Example ```no_run # use influxdb3_client::Client; # #[tokio::main] # async fn main() -> Result<()

Get the year component.

The time it took to acquire this permit.

Returns the active (not deleted) database schema and table definition for the given database and table names.

Adds a duration to a nanosecond timestamp Original: <https://github.com/influxdata/flux/blob/1e9bfd49f21c0e679b42acf6fc515ce05c6dec2b/values/time.go#

Add the columns to this [`TableDefinition`] This ensures that the resulting schema has its columns ordered