MessageBus implementation in JavaScript

CQRS CommandBus, QueryBus, EventBus and project scaffolding for MyCLI

Simple CommandBus implementation

CommandBus, QueryBus, and EventBus

TypeScript port of swift-kernelee — core dispatch (KernelSymbol / Verb / KernelBuilder / Kernel / CommandBus) + pipes (Pipe / PipeBuilder / compose / run) + fork (parallel fan-out) + Buffer (observable state) + defineCallable (typed port factory, the @cal

CommandBus, QueryBus, and EventBus

This library is inspired by PHP library called SimpleBus (https://github.com/SimpleBus).

Simple Command Bus

Schema-typed command/query buses with validation, authorization, idempotency and tracing middleware.

Mediator for EventFabric: typed Command envelope, CommandBus, middleware framework (idempotency + logging), IdempotencyStore. Backend-agnostic — pair with @eventfabric/mediator-postgres for PG-backed idempotency and @eventfabric/mediator-opentelemetry for

PostgreSQL (@effect/sql-pg) adapters for @structure-ai/eventsourcing: event store, checkpoints, outbox, inbox; plus a durable @structure-ai/cqrs idempotency store.

OpenTelemetry adapter for @eventfabric/mediator: a CommandBus middleware that emits tracing spans + counters + duration histograms per command, plus observable gauges for the command idempotency table.

Declarative reactive runtime for Node.js: bootstrap, Redux-style RxJS store, Component lifecycle, class-based connect, and GraphRuntime.

Typed CQRS for Effect: command and query buses with per-message success and error types, an event bus whose subscriptions choose their consistency model, and process managers

Command Query Responsibility Segregation patterns

Command Bus

Command Query Responsibility Segregation (CQRS) primitives for separating read and write operations.

A small library to create, register and execute commands.

Distributed Command Bus library with Redis Streams transport, MessagePack serialization, and RPC via LPUSH/BRPOP for DragonflyDB

A modular, type-safe foundation for building expressive, maintainable applications. This package provides core abstractions for domain modeling, HTTP integration, authentication, state management, and more — designed to be framework-agnostic and highly ex