rheo 0.5.0
“Durable consumer-group semantics over searchable databases (MongoDB + ETS). Partitions, contiguous ACK frontier, and lag in v0.5.”
Near-zero recent downloads for registry packageRelease published within seven days
SHA-256de4fdfcc812bf8bb92e05c99112f4e3a55a7f180f14360fe11ba4e9859dbca16
MaleculeH₂(Cm₂Os)Md(Pa)
Evidence
5:28… Consumption records progress, leases, retries, and
6 dead-letters in separate consumer-group state. Delivery is **at-least-once**:
7 after a crash …
39:24… .lag("market-events", "risk")
40
41 Search history with `query` / `query_page` / `stream_query`. Replay without
42 copying events via `create_group` sta …
43:15… /3` (`confirm: true`). See `Rheo.Event.Lineage` for correlation
44 metadata and `Rheo.Partition` for routing helpers.
45
46 See also `Rheo.Consumer` for the OTP handler API and `Rheo.Backend` for adapters.
47 """
48
49 use Supervisor
50
51 alias Rheo.{Event, …
94:54… ult_backend_handle(rheo, backend_mod)
95 backend_opts = Keyword.put(backend_opts, :name, handle)
96
97 children = [
98 {Registry, keys: :unique, name: Rheo.Names.registry(rheo)},
99 backend_m …
165:30… quence}` map); group begins materializing after this
166 * `:start_at` — `DateTime`; begin at the first event at/after this time
167 * `:parti …
No evidence locations were recorded for this file. Raw result