Module admin_util

Expand description

Shared admin/IO helpers used by replicator engine tasks.

All functions return Result<_, String> and map client errors with .map_err(|e| e.to_string()), so callers stay wire-error-agnostic.

Functions§

ensure_compacted_topic: Ensure a compacted topic exists with one partition and the default replica count.
ensure_compacted_topic_with_policy: Ensure a compacted topic using the deployment’s client resource policy.
ensure_compacted_topic_with_replication_factor: Ensure a compacted topic with an explicit replication factor.
ensure_topic: Ensure topic exists with the given parameters. An already-exists response counts as success.
ensure_topic_with_policy: Ensure a topic using the deployment’s client resource policy.
ensure_topic_with_replication_factor: Ensure a topic with an explicit replication factor.
read_all: Errors
read_all_with_policy: Drain a topic using the deployment’s client resource policy.
read_last_value_for_key: Return the value bytes of the last record whose key equals key.
read_last_value_for_key_with_policy: Read a key using the deployment’s client resource policy.

RawRecord: Drain all records from topic from the earliest offset. Returns (key, value) pairs in order.