rouffou 

Core of Mediarq: a lightweight, dependency-free CQRS mediator for .NET (commands, queries, notifications, pipeline behaviors, validation, Result, source generator). The Mediarq meta-package bundles this with... More information

Lean meta-package bundling Mediarq.Core and the lightweight extensions: ASP.NET Core, FluentValidation, DataAnnotations, Caching, Diagnostics and UnitOfWork. Heavy or opinionated integrations... More information

Unit of Work pipeline behavior for Mediarq: commit a unit of work around transactional commands.

Observability for Mediarq: an OpenTelemetry-compatible Activity (tracing) and System.Diagnostics.Metrics behavior per request.

Caching pipeline behaviors for Mediarq: memoize responses of ICacheableRequest via IMemoryCache (in-memory) or IDistributedCache (e.g. Redis).

FluentValidation adapter for Mediarq: run FluentValidation validators inside the Mediarq validation pipeline.

DataAnnotations adapter for Mediarq: validate requests with System.ComponentModel.DataAnnotations attributes in the Mediarq pipeline.

ASP.NET Core integration for Mediarq: map Result / ResultError to IResult and RFC 7807 ProblemDetails.

dotnet new templates for Mediarq. Includes 'mediarq-feature' (scaffolds a command, its handler and a validator) and 'mediarq-webapi' (a full CQRS ASP.NET Core Web API solution wired with Mediarq).

EF Core integration for Mediarq: an IUnitOfWork over a DbContext, so transactional commands are committed via SaveChanges.

Idempotency pipeline behavior for Mediarq: an IIdempotentRequest whose result is cached by idempotency key in an IDistributedCache, so retries return the stored result instead of re-running the handler.

Transactional outbox for Mediarq over EF Core: enqueue notifications into an outbox table in the same transaction as your data, then publish them reliably (at-least-once) from a background processor.

MassTransit integration for Mediarq: forward Mediarq notifications to a MassTransit bus so they are published out-of-process.

Resilience for Mediarq: apply a named Polly v8 ResiliencePipeline (retry, timeout, circuit breaker) to requests.

OpenTelemetry instrumentation for Mediarq: one-line AddMediarqInstrumentation() that subscribes the tracer and meter providers to the Mediarq activity source and metrics.

Roslyn analyzer and code fix that detect MediatR types (IRequest, IRequestHandler, INotification, IPipelineBehavior, …) and rewrite them to their Mediarq equivalents, to automate migration from MediatR.

EF Core-backed IDistributedCache for Mediarq.Idempotency: a persistent, queryable idempotency store over a DbContext, as an alternative to Redis or in-memory. Includes a background cleanup service for expired... More information

Optional MediatR compatibility shim for incremental migration to Mediarq: keep your existing MediatR.IRequest/IRequestHandler/INotification/INotificationHandler/IStreamRequest classes unchanged,... More information

gRPC transport for cross-service Mediarq notifications: forward a notification to another service's Mediarq.Grpc endpoint when it is published (IGrpcNotificationEvent), and receive it back into the real Mediarq... More information

Saga / process-manager primitives for Mediarq: persisted, correlated state across a sequence of notifications, via an ISagaStore<TState> and a SagaNotificationHandler<TEvent, TState> base class. Pair with... More information