preview-glide-rust 0.2.0

Valkey GLIDE — native Rust client for Valkey and Redis OSS, built on glide-core.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

// Copyright Valkey GLIDE Project Contributors - SPDX Identifier: Apache-2.0
//! Shared integration-test harness.
//!
//! Provides:
//! * [`TestServer`] — boots an ephemeral standalone `valkey-server` on a free
//!   port and tears it down on drop, with RESP2/RESP3 client helpers.
//! * [`ClusterHarness`] — boots a real 3-primary cluster and connects a
//!   [`glide::GlideClusterClient`]. The canonical tool for this is
//!   `valkey-glide/utils/cluster_manager.py`
//!   (`python3 cluster_manager.py start --cluster-mode`), which we document and
//!   prefer; however it requires `valkey-cli` on `PATH`. When that is not
//!   available we build the cluster natively from the `valkey-server` binary
//!   (`CLUSTER ADDSLOTSRANGE` + `CLUSTER MEET`), so cluster tests still run.
//!   When neither is feasible the harness returns `None` and tests SKIP.
//! * The [`resp_test!`] macro — expands a single test body into two
//!   `#[tokio::test]`s, one per RESP protocol version (the ~2x multiplier;
//!   combined with standalone the effective coverage mirrors Python's
//!   RESP2/RESP3 parametrization).
//! * [`assert_request_error!`] — asserts a result is a server `RequestError`.

// Each integration-test crate compiles this harness separately and uses a
// different subset of it, so unused-item/import lints are expected noise here.
#![allow(dead_code)]
#![allow(unused_imports)]

mod cluster;
mod helpers;
mod macros;
mod pubsub;
mod server;
mod timeout;

pub use cluster::{ClusterHarness, is_transient_cluster_error};
pub use helpers::{command_exists, key, server_version, tkey, version_below};
pub use pubsub::{wait_for_numpat, wait_for_numsub};
pub use server::{TestServer, free_port, server_binary};
pub use timeout::{test_timeout, with_test_timeout};