emitdotnet 

Abstraction contracts for the Emit transactional outbox library. Contains interfaces, models, and base classes referenced by providers and persistence implementations.

Transactional outbox pattern library for .NET. Provides reliable message delivery by persisting operations in an outbox within your database transaction.

Kafka outbox provider for Emit. Enables reliable Kafka message production through the transactional outbox pattern.

MongoDB persistence provider for Emit. Stores outbox entries in MongoDB with support for sharding and atomic sequence generation.

OpenTelemetry instrumentation for the Emit library. Provides AddEmitInstrumentation() for registering Emit meters with OpenTelemetry and configuring static tag enrichment.

JSON Schema serializer/deserializer extensions for Emit.Kafka. Adds convenience methods for schema-registry-backed JSON serialization.

In-process mediator pattern for the Emit library. Provides request-response dispatching through IRequestHandler with a unified middleware pipeline.

Avro serializer/deserializer extensions for Emit.Kafka. Adds convenience methods for schema-registry-backed Avro serialization.

Entity Framework Core persistence provider for Emit. Stores outbox entries using Entity Framework Core with support for PostgreSQL via Npgsql.

Test utilities for the Emit library. Provides MessageSink and SinkConsumer for capturing consumed messages in integration and functional tests.

Protobuf serializer/deserializer extensions for Emit.Kafka. Adds convenience methods for schema-registry-backed Protobuf serialization.

ASP.NET Core health check for Emit's Kafka provider. Registers a broker connectivity probe that can be wired into Kubernetes liveness and readiness endpoints.

ASP.NET Core health check for Emit's MongoDB persistence provider. Registers a ping probe that can be wired into Kubernetes liveness and readiness endpoints.

ASP.NET Core health check for Emit's Entity Framework Core persistence provider. Registers a database connectivity probe that can be wired into Kubernetes liveness and readiness endpoints.

FluentValidation integration for Emit. Bridges FluentValidation validators into the Emit consumer validation pipeline.