Pure-Rust Aave V3 domain crate: the updater chunk-loop (transactional apply of decoded Aave events under one rusqlite Transaction) + the position-analysis math…
Typed Rust SDK for the pi coding agent (earendil-works/pi): serde models of the `pi --mode json` event stream and the `pi --mode rpc` stdin/stdout command…
Data-driven core of the Wickra Radar: a serde RadarSpec folded over a perp universe (open interest, funding, order-book and liquidation events) into a…
The Windows WMI (CIM) repository for forensics: namespaces, classes and instances read from OBJECTS.DATA, INDEX.BTR and the MAPPING files, and the event…
Stateful streaming operators for FusionVault Streams: event-time tumbling and sliding windows with keyed incremental aggregation, session windows, stream…
Core building blocks for event-driven Rust microservices: pluggable event streams (local or NATS), caching (Moka or Redis), and Postgres-backed infrastructure.
Opt-in Kafka building blocks for Mercury: publish events to topics (simple.kafka.notification) and route topics into Event Script flows, with externalized…
The FusionVault Streams standalone runner: run a stream pipeline defined in one TOML file against Kafka or Redpanda with no control plane, including the…
Reference command-line radar over the Wickra wickra-radar-core: load a spec and a perp event stream, scan for cascade signals, print the report as text or JSON.
The per-community VGI bridge: holds the community's forge credentials, takes git-ns/bridge jobs from its VTC over TSP or DIDComm, runs the forge adapters,…