qmp 0.1.1

QEMU QMP client library
Documentation 
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

# qmp

**QEMU QMP** client library.

Goals:

- **Pure Rust**, async-first.
- **Unix/TCP** socket support.
- Correct **greeting + `qmp_capabilities`** negotiation.
- JSON request/response encoding/decoding with **serde**.
- **Event stream** (subscribe, multi-consumer).
- Command calls with **timeout** and cooperative **cancellation**.
- Optional, higher-level **safe ops** layer:
  - allow-list policies (white-list)
  - per-command mutex / idempotency
  - retry/backoff with jitter
  - structured errors
  - (optional) `tracing` observability

## Quick start

### Low-level client

```rust
use qmp::{Client, Endpoint};

# async fn demo() -> qmp::Result<()> {
let client = Client::connect(Endpoint::unix("/var/run/qemu-server/100.qmp")).await?;

let status: serde_json::Value = client.execute("query-status", Option::<()>::None).await?;
println!("status = {status}");

let mut events = client.events();
while let Ok(ev) = events.recv().await {
    println!("event: {} data={}", ev.name, ev.data);
}
# Ok(()) }
```

### Safe ops layer

```rust
use qmp::{Client, Endpoint};
use qmp::ops::{OpsClient, Profile};

# async fn demo() -> qmp::Result<()> {
let client = Client::connect(Endpoint::unix("/var/run/qemu-server/100.qmp")).await?;

// Read-only allow-list by default.
let ops = OpsClient::from_profile(client, Profile::ReadOnly);

let v = ops.query_version().await?;
println!("qemu {}.{}.{} ({})", v.qemu.major, v.qemu.minor, v.qemu.micro, v.package);
# Ok(()) }
```