consulx — Consul KV CLI + Rust Client Library

consulx is a modern Rust toolkit for working with Consul KV, providing:

• 🔧 Interactive REPL (like redis-cli, but for Consul)
• 🗂️ Tree view, watch, prefix watch, edit, get-json, put-json
• ⚙️ Lightweight HTTP-only Consul client (no SDKs)
• 🌐 Integrations for Actix and Axum
• 🔁 First-class support for dynamic config & feature flags
• 🧩 Typed JSON prefix loading (kv_list_json)

Everything is implemented from scratch using reqwest.

✨ Features

🧵 REPL Interface

• Auto-completion (reedline)
• Commands: get, put, del, list, tree, get-json, put-json, edit, watch, watch-prefix

🗄️ JSON-aware KV APIs

• kv_get_json — load typed JSON config
• kv_put_json — write typed JSON
• kv_list_json — load multiple JSON configs under a prefix

🔁 Watches

• Watch individual keys
• Watch entire prefixes
• Efficient blocking queries (index + wait)

🌍 Actix & Axum Integrations

Drop ConsulXClient into your application state.

⚡ Pure HTTP client

No consulrs. No SDK. No hidden magic.

🚀 Installation

[dependencies]
consulx = "0.1.0"
tokio = { version = "1", features = ["full"] }
reqwest = { version = "0.12", features = ["rustls-tls", "json"] }
serde = { version = "1", features = ["derive"] }
serde_json = "1"

🔧 CLI Usage

cargo install consulx
consulx

Specify endpoint:

CONSUL_HTTP_ADDR=http://127.0.0.1:8500 consulx

🖥️ REPL Commands

🧩 JSON Prefix Loading (kv_list_json)

#[derive(Deserialize)]
struct FeatureFlag {
    enabled: bool,
}

let flags = consul.kv_list_json::<FeatureFlag>("app/features/").await?;

for (key, flag) in flags {
    println!("{key} => {:?}", flag);
}

📦 Library API Summary

// Client creation
ConsulXClient::new(url)          // Create client with explicit Consul URL
ConsulXClient::from_env()        // Uses CONSUL_HTTP_ADDR (default: http://127.0.0.1:8500)

// Raw KV operations
kv_get_raw(key)                  // -> Option<String>
kv_put(key, value)               // Store raw value
kv_delete(key)                   // Delete a key
kv_list(prefix)                  // List keys under a prefix

// JSON helpers (typed)
kv_get_json<T>(key)              // -> Option<T>
kv_put_json<T>(key, &T)          // Serialize & store JSON
kv_list_json<T>(prefix)          // Load JSON objects under prefix

// Watches (blocking queries)
kv_watch(key)                    // Watch a single key
kv_watch_prefix(prefix)          // Watch all keys under prefix

Made with ❤️ by the [Srotas Space] (https://srotas.space/open-source)

👥 Contributors

• Snm Maurya - Creator & Lead Developer LinkedIn

📄 License

This project is licensed under the MIT License - see the LICENSE file for details.