Jean-Gabriel Gill-Couture
ce7ad75dbf
- example_iot_load_test: simulates N devices (default 100 across 10 groups: 55 + 9×5) pushing DeploymentState every tick to NATS, no real podman. Applies one Deployment CR per group, runs for a bounded duration, verifies each CR's .status.aggregate counters sum to the target device count. - iot/scripts/load-test.sh: minimum harness — k3d cluster + NATS via NatsBasicScore + CRD + operator + load-test binary. No VM, no agent build. - operator: connect_with_retry() on startup. The NATS TCP probe that the smoke scripts do isn't enough to guarantee the protocol handshake is ready (k3d loadbalancer can accept SYNs before the pod is serving); the load harness hit this racing against a freshly-rebuilt operator binary. - drop unused rand dep from iot-agent-v0 Cargo.toml. 100-device run: 6002 state writes in 60s at a clean 100 writes/s, all 10 CR aggregates converge to target_devices.len() (e.g. group-00 → 55 = 45 Running + 9 Failed + 1 Pending).
25 lines
690 B
TOML
25 lines
690 B
TOML
[package]
|
|
name = "example_iot_load_test"
|
|
version.workspace = true
|
|
edition = "2024"
|
|
license.workspace = true
|
|
|
|
[[bin]]
|
|
name = "iot_load_test"
|
|
path = "src/main.rs"
|
|
|
|
[dependencies]
|
|
harmony-reconciler-contracts = { path = "../../harmony-reconciler-contracts" }
|
|
iot-operator-v0 = { path = "../../iot/iot-operator-v0" }
|
|
async-nats = { workspace = true }
|
|
chrono = { workspace = true }
|
|
kube = { workspace = true, features = ["runtime", "derive"] }
|
|
k8s-openapi.workspace = true
|
|
serde_json = { workspace = true }
|
|
tokio = { workspace = true }
|
|
tracing = { workspace = true }
|
|
tracing-subscriber = { workspace = true }
|
|
anyhow = { workspace = true }
|
|
clap = { workspace = true }
|
|
rand = { workspace = true }
|