Adds an expression to the list of general purpose predicates

Gets the observer for a given set of attributes if one has been registered by a call to `Metric::recorder` This is primarily useful for testing

Returns true if ths predicate evaluates to true for all rows

Stops all subsequent task executions, and waits for the worker thread to complete. Note this will shutdown all clones of this `DedicatedExecutor` as w

Return a reference to gRPC metadata included with each request

Return `self OR other`

Await the inner result, regardless of cache state. This method extracts the result from WasCached or awaits the future from AlreadyLoading/NewEntry s

Returns an iterator over the columns in this batch in no particular order

Create a test persister with InMemory object store and mock time provider

Specify the format, `json`, `csv`, `pretty`, or `parquet`

Embed a size hint within [`GetOptions`]. Use [`extract_size_hint`] to extract the size again.

Converts the provided lines of line protocol to a set of [`MutableBatch`] keyed by measurement name

Encode a record, stamp it with the batch's sequence, and append it.

Register a new `Metric` with the provided name and description ``` use ::metric::{Registry, Metric, U64Counter}; let registry = Registry::new(); let

Helper function to create test retry params with very short delays

Return a temporary directory that is deleted when the object is dropped

Register a timestamp column with full stats with the test chunk

Write the time typed column identified by `name` For each set bit in `valid_mask` an a value from `values` is inserted at the corresponding index in

Return min max of a ColumnStatistics with precise values

Add or re-use a field column. In [`FieldFamilyMode::Auto`], the field is placed in the shared auto field family. In [`FieldFamilyMode::Aware`], a `fa

Returns the number of values stored in the bitset

Create a new execution context, suitable for executing a new query or system task Note that this context (and all its clones) will be shut down once

The specified `feature` is not implemented.

Parse the string and return a `DateTime` using a fixed offset. Based on the [`ToTimeLiteral`] function. [`ToTimeLiteral`]: https://github.com/influx

Traverse the execution plan and build statistics min max for the given column

Create a single parquet, with a given ordering and using the statistics from the [`SortKeyRange`]

Create a new [`RootSnapshot`] from the provided state

Get the record type ID.

List the snapshot (if present) and log files. By default only logs after the snapshot are returned; set `include_pre_snapshot` to also include logs wr

Mock next result of [`Hook::fetched`]. If there are already unused mocks, then we attach this to the end. If no result is mocked, [`HookDecision::de

Human-readable string representation.

Create new instrumented semaphore.

Notify all notifiers

Given a Vec of prunable items, returns a possibly smaller set filtering those where the predicate can be proven to evaluate to `false` for every singl

Panics on duplicate `name` — one subscription per named component is the contract; duplicates should fail loudly at server startup.

Write the string field typed column identified by `name` For each set bit in `valid_mask` an a value from `values` is inserted at the corresponding i

Appends `count` boolean values from the slice of packed bits

Returns a reference to the [`CatalogCache`] of this server

Create an injected error

Returns the inner arithmetic [`Expr`].

Returns a DataFusion user defined aggregate function for computing the first(value, time) selector function, returning a struct: first(value, time) -

Returns a DataFusion user defined aggregate function for computing the last(value, time) selector function, returning a struct: last(value, time) ->

Returns a DataFusion user defined aggregate function for computing the max(value, time) selector function, returning a struct: max(value, time) -> st

Check if we should inject an error for this call

Get-or-create a table transaction handle.

Parse the incoming lines of line protocol using the v1 parser and update the transaction to the catalog if: A new table is being added New fields or

Returns an iterator to all values stored within the ring buffer Note: the order is not guaranteed

Writes the provided [`TableBatch`] to a [`MutableBatch`] on error any changes made to `batch` are reverted

Acquire `n` permits. See [`tokio::sync::Semaphore::acquire_many`] for details.