Comprehensive Architecture & Event-Driven Topology

Complete framework-neutral CQRS execution, pipeline behaviors, domain events and async BullMQ queues

Comprehensive Architecture & Event-Driven Topology Complete framework-neutral CQRS execution, pipeline behaviors, domain events and async BullMQ queues HTTP Clients · Browser / Mobile / APIs · Entry & Inbound Gateway HTTP Clients Browser / Mobile / APIs api HTTP Layer · Express & Fastify route table · Entry & Inbound Gateway · Dual Adapter api HTTP Layer Express & Fastify route table Dual Adapter @cqrs-ddd/cqrs · CommandBus & QueryBus · Architecture component · createCqrs() @cqrs-ddd/cqrs CommandBus & QueryBus createCqrs() @cqrs-ddd/pipeline · Behavior Pipeline Engine · Architecture component · createPipeline() @cqrs-ddd/pipeline Behavior Pipeline Engine createPipeline() @cqrs-ddd/pipeline-zod · Zod Validation & Mapper · Cross-Cutting Pipeline Behaviors @cqrs-ddd/pipeline-zod Zod Validation & Mapper @cqrs-ddd/pipeline-casl · CASL Authorizer (Fail-closed) · Cross-Cutting Pipeline Behaviors @cqrs-ddd/pipeline-casl CASL Authorizer (Fail-closed) @cqrs-ddd/pipeline-tenant · Tenant Context & Scoping · Cross-Cutting Pipeline Behaviors @cqrs-ddd/pipeline-tenant Tenant Context & Scoping @cqrs-ddd/pipeline-cache · Response Cache (CAS & Invalidation) · Cross-Cutting Pipeline Behaviors @cqrs-ddd/pipeline-cache Response Cache (CAS & Invalidation) @cqrs-ddd/pipeline-idempotency · Idempotency Store & Replay Guard · Cross-Cutting Pipeline Behaviors @cqrs-ddd/pipeline-idempotency Idempotency Store & Replay Guard @cqrs-ddd/pipeline-resilience · Retry, Circuit Breaker & Timeout · Cross-Cutting Pipeline Behaviors @cqrs-ddd/pipeline-resilience Retry, Circuit Breaker & Timeout Audit & Telemetry · Audit, Rate-Limit, OTel & DeadLetter · Cross-Cutting Pipeline Behaviors Audit & Telemetry Audit, Rate-Limit, OTel & DeadLetter @cqrs-ddd/core · AggregateRoot, Entities, Rules & Values · Domain Core & Persistence · Pure DDD @cqrs-ddd/core AggregateRoot, Entities, Rules & Values Pure DDD EventBus & Publisher · Buffered Aggregate Events · Event-Driven & Asynchronous Processing · @cqrs-ddd/cqrs EventBus & Publisher Buffered Aggregate Events @cqrs-ddd/cqrs BullMQ Job Queues · welcome-email & batch-update queues · Event-Driven & Asynchronous Processing · Async Jobs BullMQ Job Queues welcome-email & batch-update queues Async Jobs Job Processors · @InJobContext Restored Execution · Event-Driven & Asynchronous Processing Job Processors @InJobContext Restored Execution @cqrs-ddd/mikro-orm · AggregateRepository & Optimistic Locks · Domain Core & Persistence @cqrs-ddd/mikro-orm AggregateRepository & Optimistic Locks PostgreSQL & Redis · Multi-Tenant Schemas, Redis Cache & Queues · Domain Core & Persistence PostgreSQL & Redis Multi-Tenant Schemas, Redis Cache & Queues Utilities · uuidv7, safe-stringify, untyped · Domain Core & Persistence Utilities uuidv7, safe-stringify, untyped HTTP Request dispatch runs pipeline invokes handlers publishes buffered events withJobContext enqueues drains jobs persisted via SQL & KV Entry & Inbound Gateway Cross-Cutting Pipeline Behaviors Domain Core & Persistence Event-Driven & Asynchronous Processing Legend Backend Database Cloud Security Message bus External