Push the given line - the timestamp in this line should already be rebased through [`Self::rebase_timestamp`]. Part of [`Self::write_lp`], but usable

Helper function to create a modified schema with different metadata

Add a file to the pending_removed_files collection.

Merges all files from a [`PersistedSnapshot`] into the persisted files hierarchy. Deduplicates incoming files. Called at runtime (not during initial

Make a request to the `POST /api/v3/configure/database` API

Compose a request to the `POST /api/v3/configure/last_cache` API # Example ```no_run # use influxdb3_client::Client; # use influxdb3_catalog::log::ve

Create a plugin file

Strategy for generating arbitrary Option<bool> values

Returns the content type as a string slice for the query format. Maps the `QueryFormat` variants to their corresponding MIME types as strings. This i

Borrow a string slice of the name.

Assert that the result of `f` converges against the given value;

Asserts two writes are equal

Assign a bucket for the provided `tag_value` using the [`BucketHasher`]s configuration.

Persist the catalog as a checkpoint in the background if we are at the _n_th sequence number.

Run the background task that periodically checks and enforces retention policies.

Periodic catch-up loop. Sleeps for `duration` between probes and, when a log file is present at the next-expected sequence, drains every contiguously

Build the output column.

Builds an array using the [`interleave`](arrow::compute::interleave) kernel to produce an aggregate output column, filling gaps with the previous valu

Convert part of a partition key into a [`ColumnValue`]. The partition key part MUST have been generated from the same [`TemplatePart`] used to constr

Builds a vector that can use the [`take`](take::take) kernel to produce a group column.

Create 5 parquet files, which are scanned in 8 partitioned file bits, and group into 4 starting file groups: [4.parquet:0..100000000, 8.parquet:0..250

Returns the number of bytes used by this bitset

Given a time value, calculates the (min, max) boundary of the `group by time(duration, offset)` interval that contains it.

Determine the possible maximum range for the named field in the ['ArrowSchema'] once the ['Expr'] has been applied.

Whether an incoming `RegisterNode` for this node may be accepted. Per-state policy: - `Stopped`: any `instance_id` may take over (new process replaci

Capture user-provided CLI parameters with sensitive values redacted This function takes user-provided parameters extracted from ArgMatches and return

Capture the current name of database `db_id` into any token permissions that reference it, so `show tokens` can still display the original name after

Build a Catalog backed by `store`, parameterized with the given time provider so the test can drive sleep wakeups deterministically.

Reject any non-`UPGRADE_SAFE` record whose ID exceeds `committed`.

Checks the saved error, and returns it if any, otherwise returns OK

Check if the given `level` already has a duration configuration; if it does and the existing value is the same as `duration`, returns `AlreadyExists`;

Check that the given [`Range`] is valid with respect to a given `object_size`.

Return column statstics of the given chunk but for the schema of this struct. Columns that are not part of the chunk are marked as unknown/absent.

gRPC indicates failure via a [special][1] header allowing it to signal an error at the end of an HTTP chunked stream as part of the [response trailer]

Remove the retention policy from an active database.

Returns a [`CatalogCacheClient`] for communicating with this server

Return a `Error::Client` variant with the specified message

closes the writer, flushing any remaining data and returning the written [`ParquetMetaData`]

Collects an [`ArrayRef`] containing the aggregate statistic corresponding to `aggregate` for each of the provided [`Statistics`]

Returns a reference to the specified column