ConsumerDashboard (SSE)RedpandaSQLiteGo ServerLua agentShared buffer(/var/run/client2server/buffer)HotplugRouterConsumerDashboard (SSE)RedpandaSQLiteGo ServerLua agentShared buffer(/var/run/client2server/buffer)HotplugRouterHybrid delivery: instant hotplug + ≤1s luv state-diffBoth paths share one on-disk buffer for offline resiliencepar[Hotplug path (instant)][Lua state-diff (≤1s)]append NDJSON eventtouch wake filedetect (WAN/DHCP/state change)main loop polls wake fileread queued eventsWS frame: {type: event, ...}authenticate (legacy token or JWT)INSERT INTO eventspublish (fire-and-forget)SSE push to all subscribersconsume (any Kafka client)ACK