Update the statistics values to account for `num_nulls` additional null values

For caches that accept new fields, this is used when new fields are encountered and the cache schema needs to be updated.

Update the password hash for a user's login identity

Update the requires_password_reset flag for a user's login identity

Update the snapshot file on object store after it has been initialized.

Assumes the provided nanosecond i64 value is in UTC. Returns a datafusion expression in UTC, relying upon the datafusion engine to perform any castin

Set the `User-Agent` header sent by this client.

returns true if `arrow_type` can validly store this column type

Validate a line of line protocol against the given schema definition This is for scenarios where a write comes in for a table that exists, but may ha

Function validates a strftime format string for use in a NEW partition template. This is where newer restrictions are applied to reject the creation o

Validates a vec of lines for a database, returning any errors as strings.

Returns the variable-column byte capacity limit.

Maps an [`VarRefDataType`] to an [`InfluxColumnType`].

Map an InfluxQL variable reference to a DataFusion expression.

Get the `version` from the response

Wait for notification. If there was an OOM situation between this and the previous call, this will return immediately, so the caller will never miss

Returns the number of operations currently waiting to acquire a permit.

Perform a depth-first traversal of a mutable arithmetic or conditional expression tree.

If the job has completed, returns the total amount of wall clock time spent executing futures

If passed in env vars are set, then it writes to log along with what the user can switch to

Watches the output of a tokio task for an error. If the task errors, send an arror error to the channel. This pattern is used to run the operator log

Combine the `condition` and `time_range` into a single `WHERE` predicate.

Set the admin token file path for this [`TestServer`]

Builder-style override of the catalog snapshot observer.

Removes the timestamp range from this predicate, if the range is for the entire min/max valid range. This is used in certain cases to retain compatib

Merge the given delete predicates into this select predicate. Since we want to eliminate data filtered by the delete predicates, they are first conver

Disable log filter noise reduction for this [`TestServer`]

Set the documentation for this window function.

Set an environment variable on the spawned server process

Adds all expressions to the list of general purpose predicates

add a new extension to the session config

Set log_filter using a simple numeric "verbosity level". 0 means, keep existing `log_filter` value.

Override the default of sending 1MB of line protocol per request. If `Some` is specified, restricts the maximum amount of line protocol sent per reque

Set a query parameters from the given collection of pairs # Example ```no_run # use influxdb3_client::Client; # #[tokio::main] # async fn main() -> R

Set query-specific configuration options.

Add an ['Extension'] to the session config.

Reinitialise [`Self`] with a new key. Re-keying [`Self`] will change the mapping of inputs to output instances of `T`.

Specify whether or not to show deleted databases in the output

Register a tag column with stats with the test chunk

Set execution concurrency

Set whether to use tls 1.3 as the minimum or not for the [`TestServer`]

Adds a ValueExpr to the list of value expressons

Removes non-determinism by removing timestamps from the log lines. It supports the built-in tracing timestamp format and the logfmt timestamps.

Write `range` rows from the provided MutableBatch

Write bind params to the server. Returns an optionally updated prepared statement, or the old handle if the server did not provide a new one. Ignores

ALMOST Functionally equivalent to calling [`Self::write_f64`], but more performant when your values already exist in a slice that can be memcpy'd over

ALMOST Functionally equivalent to calling [`Self::write_i64`], but more performant when your values already exist in a slice that can be memcpy'd over

Writes the [`ParsedLine`] to the [`MutableBatch`], respecting the edge case semantics described in [`LinesConverter::write_lp()`].

Write line protocol data to the specified organization and bucket.

Writes the op into the buffer and waits until the WAL file is persisted. When this returns the operation is durable in the configured object store.