echd — Echo on Encore · E3
The Bus — EchoMQ Supersedes
The platform's events, schedules, and jobs ride one owned Valkey-native protocol — and any runtime that speaks it is a first-class peer.
echd speaks in the present tense over a build ladder. Every module, verb, key, and port named on this page is real; the composition into one standing platform is the vision the ladder builds.
The chapter
docs/echo_mq/specs — emq.1 · emq3.1–3.6 · emq.4 · emq.5The platform's events, schedules, and jobs ride one owned bus. EchoMQ is a Valkey-native protocol — the braced emq:{q}: keyspace, branded JOB ids, every Lua key declared, the server's clock wherever a lease is touched, the wire fenced at echomq:3.0.0 — organized as twelve command families: admission, scheduling, repeat, claim, retry, flows, groups, batches, locks, metrics, data, lifecycle. Because the protocol is Valkey commands and inline Lua, any runtime that speaks them is a first-class peer: the polyglot seam is proven by a non-BEAM reader standing in the same consumer group as the BEAM consumers, draining the same pending-entries list.
On this bus, Encore's closed primitives are superseded one by one. A topic becomes a retained, replayable stream; a cron entry becomes a registration whose every occurrence is a fresh branded mint, released by the promote pump on the server's clock; a task queue becomes an atomic claim with a lease and a fencing token, rotated fairly across groups by the Metronome — park, don't poll — and drained in bulk by batches. One primitive stays, and the chapter says so in amber: secrets remain platform-native. The workshop re-lands a topic, re-mints a cron, and declares the gap.
The keyspace
hover a surfaceemq:{q}: · hover to readXADD appends in mint order, consumer groups read with XREADGROUP, acknowledge with XACK, and the dead are reclaimed with XAUTOCLAIM. Retention is policy — trim by length or by minimum id — and deep history folds onward to the archive of E5.attempts counter as the fencing token; retry backs off; fair lanes rotate groups with the Metronome — park, don't poll; batches claim in bulk with a per-item verdict.echomq:3.0.0 fence — no runtime in the middle. The conformance suite proves the seam: a non-BEAM reader stands in the same consumer group and drains the same pending list.Hover or focus a surface to read it; click to pin. Without scripting, all five read in sequence.
The modules
E3.1–E3.4One Bus, Twelve Families
the-twelve-families · the-braced-keyspace · the-wire-fence
E3.2Streams Supersede PubSub
consumer-groups · at-least-once · the-polyglot-seam
E3.3Jobs Supersede Cron and Queues
a-fresh-mint-each-occurrence · fair-lanes-and-the-metronome · batches-and-locks
E3.4Workshop — Supersede a Primitive
the-topic-re-landed · the-cron-re-minted · the-gap-declared
Doors
the sibling coursesReferences
sources · relatedSources
- Valkey — Streamsthe log, the groups, and the pending-entries list the stream tier rides
- Valkey — ProgrammabilityEVALSHA and atomic scripts — the declared-keys discipline of the bus
Related
- EchoMQ — the protocol, in depththe far side of this chapter's door
- Redis Patterns, Appliedthe judgement layer beneath the verbs
- E4 — The Memorythe fourth switch: caches on EchoStore
- echd — the course homethe supersession switchboard