A fast object-first data engine for applications and AI agents.
eventstream for the nexus client
Pure conversion between OpenAI Chat Completions and A2A SendMessageParams / Task / event-stream
Apache Kafka server destination for walkerOS (kafkajs, JSON serialization, GZIP compression)
Redis Streams server destination for walkerOS (ioredis, XADD, pipeline batching)
Deployable duplicate-filtering runtime for causal-order event streams.