Examples menu

🛰 NATS Visualizer

Four simulated microservices publish events over NATS. Watch Core pub/sub, JetStream persistence, and KV health heartbeats update in real time.

OpenSwoole-native NATS client — a thin coroutine-native TCP client replaces third-party NATS libraries that require incompatible event loops. The read loop runs in a dedicated coroutine and yields cooperatively on every recv().
Core pub/sub (best-effort) — Auth and Inventory subscribe via wildcard Core pub/sub (via.events.*). Fire-and-forget: if you kill one of these services its simulator stops and any events published while it is offline are gone forever.
Guaranteed delivery (JetStream durable consumers) — Orders and Payments subscribe via named durable push consumers with explicit ACK. Kill = pause the consumer: the simulator keeps publishing, JetStream buffers un-ACKed messages. Revive = re-subscribe: the burst of missed events arrives immediately.
JetStream persistence — the VIAEVENTS stream captures every message in memory. The durable consumer tracks its last-delivered sequence across subscribe/unsubscribe cycles — a revived subscriber never misses a message.
KV health heartbeats — each service publishes a heartbeat to $KV.viahealth.{service} every 2 s. Guaranteed services always heartbeat (only the consumer is paused); best-effort services stop heartbeating when killed. The health grid reads KV age.
Lazy init — the NATS connection is established on the first page load inside the HTTP coroutine, where coroutine APIs are always safe. A double-init guard (flag set before Coroutine::create()) prevents race conditions.
NATS Connected 118740 events logged
Services
📦
Orders 🔒
order.cancelled
29819 events
💳
Payments 🔒
payment.authorized
29803 events
🔐
Auth 📡
token.refresh
29481 events
📊
Inventory 📡
stock.restocked
29637 events
NATS
Core via.events.* auth, inventory
JetStream VIAEVENTS 118740 msgs
Durable ui-orders, ui-payments ACK guaranteed
KV viahealth heartbeats
Audit via.events.* 118740 ✓
Health (KV age)
📦 Orders 0.6s
📦 DOWN
💳 Payments 0.6s
💳 DOWN
🔐 Auth 0.6s
🔐 DOWN
📊 Inventory 0.6s
📊 DOWN
Event Stream
📦 order.cancelled $318 05:45:33.434
💳 payment.authorized $197 USD 05:45:31.392
💳 payment.refunded $247 USD 05:45:30.266
💳 payment.refunded $232 USD 05:45:29.136
💳 payment.failed $116 USD 05:45:28.319
📊 stock.restocked SKU-7C52 ×13 05:45:27.343
📊 stock.restocked SKU-E3C1 ×74 05:45:24.945
📦 order.shipped $473 05:45:24.095
📦 order.cancelled $471 05:45:22.658
📦 order.placed $385 05:45:21.109
🔐 token.refresh user81 05:45:18.916
📦 order.cancelled $48 05:45:17.918
🔐 login.success user81 05:45:15.842
🔐 token.refresh user73 05:45:13.872
📊 stock.restocked SKU-9C22 ×10 05:45:12.404
📦 order.shipped $495 05:45:09.923
🔐 token.refresh user18 05:45:09.025
📦 order.cancelled $49 05:45:07.593
💳 payment.failed $345 USD 05:45:05.779
📦 order.shipped $89 05:45:04.441
🔐 token.refresh user51 05:45:02.553
📦 order.cancelled $387 05:45:01.115
💳 payment.failed $105 USD 05:44:59.592
🔐 token.refresh user58 05:44:57.724
📦 order.cancelled $270 05:44:55.652
📦 order.placed $262 05:44:54.525
💳 payment.failed $31 USD 05:44:53.315
🔐 token.refresh user98 05:44:52.351
📦 order.placed $182 05:44:51.049
📦 order.shipped $264 05:44:50.148
Source Example handler .php → NatsClient .php → Template .twig →

🎯 Actions

kill-orders / kill-payments

Pauses the JetStream durable consumer (unsubscribes from the deliver inbox). Simulator keeps publishing; NATS buffers un-ACKed messages. Health tile stays green — the service is still alive, only the consumer is paused.

kill-auth / kill-inventory

Stops the event simulator entirely. Events are silently dropped — Core pub/sub has no persistence. Health tile flips to DOWN after 8 s of silence.

revive-{service} (×4)

Guaranteed services: re-subscribes to the deliver inbox; JetStream immediately delivers all buffered events in a burst. Best-effort: restarts the simulator and publishes a fresh KV heartbeat.

👁 Views

mission_control.html.twig

Flow diagram piping services → NATS → browser, service kill/revive cards with delivery-type badges, NATS topology with health tiles, and a live event stream.