uns-framework — Topic Monitor

Subscribes to the entire UNS namespace and caches all topic data in Valkey.

LanguageGo
TypeMQTT subscriber
Scaffolded withfnkit go-mqtt
Depends onMQTT broker, Valkey

What It Does

Monitors the entire UNS by subscribing to v1.0/#. Every message cached in Valkey with current/previous tracking. The foundation — all other functions read from this cache.

Cache Key Layout

KeyTypeDescription
uns:topicsSETAll discovered topic paths
uns:data:*STRINGLatest payload (JSON)
uns:prev:*STRINGPrevious payload (JSON)
uns:meta:*STRINGlast_updated, count, first_seen

Quick Start

cd uns-framework && cp .env.example .env
docker compose up -d && docker logs -f uns-framework