zenkey-fleet
The fleet engine for keyspace-v2 Zenoh
tooling — the shared core of zenctl and the future zengui explorer:
query— the RFC 05 §2.1 fan-in discipline (fleet_get: targetAll, consolidationNone, attribution by the reply's own key), in exactly one place. Answers carry zenoh's refcountedZBytes— no per-reply copies.registry—SliceSet: registry slices from the live bus (introspectfan-in) or localregistry/*.tomldirs, one type either way, with precedence-correct subject refinement (sharedzenkey::patternmatcher) and an on-disk cache.decode(featuredecode, default) — the RFC 08 §7 pipeline:SchemaStorelazily fetches each producer's serveddescribeschema set,decode_sampleturns wire bytes into named-field JSON with honest structural fallback; encoding resolution is sample > registry > sniff.decode-protobufadds dynamic protobuf via the served FileDescriptorSet.sub—Monitor: subscription multiplexing + liveliness watching (withhistory(true)— the roster arrives on join) into a bounded broadcast of events. Overflow surfaces as an explicitDropped(n); render loops pull the immutableKeyTreeSnapshoton the stats tick, so a hot bus cannot melt a UI.stats/tree— per-key rate/byte counters (EWMA, SourceInfo gap counting) and the chunk-grouped snapshot they build.roster/admin— the liveliness roster and raw@/**admin-space access.
Sessions opened here are deliberately un-namespaced (RFC 09 §5): an explorer sees the wire as it really is. Do not "fix" that.