Configuration class for KV Cache stores that reads from YAML config files.

General system errors.

Invalid argument errors.

Invalid configuration errors.

Empty marker type to represent ok result with no meaningful return value.

Result type that encapsulates either success or error. This follows the Result/Either pattern for explicit error handling.

Message deserialize failed errors.

Single operation result.

ETCD-related system errors in extension layer.

Create failed.

Global FS interceptor. It is intentionally process-wide, similar to pyfakefs.Patcher.

Typed outcome for a single MPMC GET attempt.

Mooncake related file error.

Producer closed errors.

Bind failed.

Channel closed errors.

Thin Python wrapper over Rust-backed MPSC producer. This class maintains the original constructor signature so that higher-level APIs (e.g. `

Network errors.

Invalid file range errors.

Thin Python wrapper over Rust-backed MPSC consumer. Keeps the original constructor signature, but only constructs the Rust-side MpscConsumerH

Store initialization failed errors.

Chan key cannot be found in client.

Shared shutdown controller for MQ components. Holds a close flag and an operation lock that can be used by producers/consumers and any intern

Raised when direct ready_channels access is detected.

Resource exhausted errors.

Backend not found errors.

Backend unavailable errors.

Internal system errors in extension layer.

MPMC Producer that can produce messages to multiple MPSC channels.

Test configuration.

API timeout errors.

ETCD transaction failed errors.

Key not found errors.

MPMC Consumer that binds to a specific MPSC channel.

MPMC Channel that manages multiple MPSC channels.

Holds MQ-related state for a benchmark node.

Minimal snapshot for KV cluster metrics. Only exposes `per_segment_size()` for now, which returns a mapping: { segment_name: (available_b

Mooncake implementation of the KV Cache Store interface.

Python wrapper around Rust MpscContext with shared kv backend state.

Message serialize failed errors.

Per-node performance metrics.

Request cannot be completed errors.

Storage write errors.

Thread pool based implementation of KvFuture.

Value too large errors.

File not found errors (extension layer).

Backend initialization failed errors.

Worker exits because the benchmark window is closed and useful work is exhausted.

Buffer overflow errors.

Message produce failed errors.

Lightweight container for test harness state.

Snapshot of MPMC cluster info for producer/consumer status checks.

Formatter that adds colors for different log levels.

Add colors for different log levels.

Consumed message with producer and channel information. Kept for compatibility with MPMC which wraps payloads with this type when acting as s

Consumer initialization failed errors.

coordinator server