Convert to protobuf v3 message.

Returns an RFC 3339 and ISO 8601 date and time string such as `1996-12-19T16:39:57+00:00`.

Convert this set of parsed and qualified lines into a set of rows This is useful for testing when you need to use the write validator to parse line p

Convert the parts of year to nanoseconds since the epoc UTC time. It mimics the combination of `time.Date` and `UnixNano`. It is used in place of Go

Transform a DataSourceExec with N files in various groupings, into a DataSourceExec into N groups each include one file. This singular file may actual

Transform the schema of a single [`LogicalPlan`] node by applying a function to its schema. This function applies the transformation function `f` to

Translates a reqwest response to an Error

Truncates the input slice to remove all whitespace from the beginning (left), including completely commented-out lines

Truncates the array to the given length

Downcast an ArrayRef to BooleanArray, returning an error if it's not a boolean array.

Return the InfluxDB data model type, if any, and underlying arrow schema field for the column at index `idx`. Panics if `idx` is greater than or equal

Return a value by applying the operation defined by the receiver or [`None`] if the operation is not supported.

Update the stats for the heap monitor

Specify the time-to-live (TTL) in seconds for entries in the cache

Pre-configured UDF parser.

Computes the union of `self` and `other`

Returns a `LogicalPlan` that combines the `FROM` clause as a `UNION ALL`.

Drop the subscription registered under `name`.

Drop the subscription registered under `name`.

Extract a gauge typed value. # Panics Panics if the value is not a gauge.

Update an existing resource in the repository

Update a Label

Merges parquet files from a [`PersistedSnapshot`] into the db/table hierarchy. Returns `(file_count_delta, removed_size_bytes, removed_row_count)`.

Updates these statistics so that that the total length of this column is `len` rows, padding it with trailing NULLs if necessary

Compose a request to the v1-compatible `GET /query` endpoint (InfluxQL). This is the endpoint that InfluxDB 1.x clients use. The database, query, and

Function validates a strftime format string for use in an existing partition template. This is more permissive, since we don't break existing (though

Validate each permission spec against the catalog and convert to the wire format used by [`CreateResourceScopedTokenOp`]. Each spec is checked for: -

An iterator visiting all parameter values as mutable references. Currently this will iterate in an arbitrary order, but specific ordering is subject t

The venv directory PipManager uses: an explicit `--virtual-env-location`, or `.venv` under the plugin dir.

wait for output to be done

Create a new [`WalContents`] with the provided arguments that will have a `persisted_timestamp_ns` of `0`.

Make a request to the `POST /api/v3/plugin_test/wal` API

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

The total number of window and aggregate functions observed.

This is the implementation of the `window_bounds` user defined function used in IOx to compute window boundaries when doing grouping by windows.

Calculate the difference between each value and the previous non-null value in an array. The output array will have NULL values where the input array

Set DataFusion [config option]. May be used to set [IOx-specific] option as well. [config option]: datafusion::common::config::ConfigOptions [IOx-s

Set the default catalog provider

Sets the etag

Prepares this chunk to return a specific record batch with five rows of non null data that look like, no duplicates within "+------+------+-----------

Prepares this chunk to return a specific record batch with four rows of non null data that look like, duplicates within "+------+------+-----------+--

Add notifiers for `get` requests so that async execution can be halted to synchronize other processes before the request is forwarded to the inner obj

When `true`, the request body is gzip-compressed and sent with a `Content-Encoding: gzip` header. The server transparently decodes it.

Set the log filter for this [`TestServer`]

Override the maximum value size to write

Prepares this chunk to return a specific record batch with a single tag, field and timestamp like

Add a `InfluxQlShowRetentionPolicies` to the handler This allows the implemention of `InfluxQlShowRetentionPolicies` to be added optionally so that s

Set the span context from which to create distributed tracing spans for this query

Annotate all spans emitted by this exporter with the specified static tags.

Try to set a query parameter value with the given `name` # Example ```no_run # use influxdb3_client::Client; # #[tokio::main] # async fn main() -> Re