Creates a new `DedicatedExecutor` with a dedicated tokio executor that is separate from the threadpool created via `[tokio::main]` or similar. See th

Creates a new SingleTenantRequestParser

Create a new value wrapping the element at `row` in the `arr` array.

Initialise a [`JumpHash`] that consistently maps keys to one of `shards`. # Correctness Changing the number of, or order of, the elements in `shards

Construct a new [`RoundRobin`] sharder that maps requests to each of `shards`.

Constructs a [`ColumnValuesBuilder`] from an iterator of [`TemplatePart`]s. The returned builder contains prepared state that can be used to reverse

Create a new, valid NamespaceName.

Create a new [`HashBucketsEncoder`] # Panics Panics if capacity >= u32::MAX

Create a new instance sorted by the ID of the items, which `MessageList` relies on for its implementation of `get_by_id`.

Creates a new [`LineProtocolBuilder`] with an empty buffer.

Create new, empty interner.

Create new span with given context and name.

Create a new tower [`Layer`] for tracing

Create a new span context parser with default Jaeger trace header name

Create a new [`InfluxRpcPredicate`]

Create a new [`FieldProjectionRewriter`] targeting the given schema

Create a new empty batch

Create a [`Writer`] for inserting `to_insert` rows to the provided `batch` If the writer is dropped without calling commit all changes will be rolled

Create a new [`LinesConverter`]

Create a new logfmt Layer to pass into tracing_subscriber Note this layer simply formats and writes to the specified writer. It does not do any filte

Private constructor. It is pointless / a potential bug to construct this type outside this crate, because it will NOT be hooked up into the layer.

Create a new [`Client`] # Arguments `base_url` - The base URL for the InfluxDB 3 server `ca_cert` - Optional path to a CA certificate file for TLS ve

Create a new `Planner`

Create a new [`DistinctCache`] Must pass a non-empty set of [`ColumnIdentifier`]s which correspond to valid columns in the provided [`TableDefinition

Create a new [`LastCache`] The uses the provided `TableDefinition` to build an arrow schema for the cache. This will validate the given arguments and

Create a [`ShutdownManager`] Accepts a [`CancellationToken`] which the `ShutdownManager` will signal cancellation to after the backend has cleanly sh

Create a new empty metrics object.

Create a new [`LoadConfig`]

Create a new TestObjectStore wrapping the given store

Construct a fresh, shared [`ObjectStoreHealth`]. All fields start unset; [`is_ok`](Self::is_ok) returns `false` until the first success is recorded.

Create a new `CatalogUpdateMessage`