Yautbox.Postgres 1.0.1

Yautbox.Postgres

PostgreSQL infrastructure provider for Yautbox. It stores outbox messages in Postgres, applies schema migrations on startup, and supports distributed locks for sequential execution.

Features

• Postgres storage with schema migrations
• Advisory locks for ExecutionPolicy.Sequential
• Configurable schema name and JSON serialization
• Cleanup batching for safe-deleted records

Installation

NuGet (if published):

dotnet add package Yautbox.Postgres

From source:

dotnet add <your-app>.csproj reference src/Yautbox.Postgres/Yautbox.Postgres.csproj

Quick start

using Microsoft.Extensions.DependencyInjection;
using Yautbox.Extensions.Ioc;
using Yautbox.Postgres.Extensions;

services.AddOutbox(builder => builder.UsePostgres(
    connectionString: "Host=localhost;Database=yautbox;Username=postgres;Password=postgres"));

services.AddOutboxHandler<OrderPlaced, OrderPlacedHandler>();

Options

PostgresStoreOptions:

• SchemaName (default: "outbox")
• CleanupBatchSize (default: 1000)
• ConfigureJsonOptions (customize JsonSerializerOptions)

Example:

using System.Text.Json;
using Yautbox.Postgres.Extensions;
using Yautbox.Postgres.Extensions.Configurator;

services.AddOutbox(builder => builder.UsePostgres(
    connectionString: "...",
    options: new PostgresStoreOptions
    {
        SchemaName = "messaging",
        CleanupBatchSize = 2000,
        ConfigureJsonOptions = (json, _) => json.PropertyNamingPolicy = JsonNamingPolicy.CamelCase
    }));

Connection factory

If you need custom connection creation (for example, custom connection pooling), register your own factory and use the generic overload:

using Yautbox.Postgres.Extensions;
using Yautbox.Postgres.Infrastructure.Database;

public sealed class MyConnectionFactory : IOutboxConnectionFactory
{
    public string GetConnectionString() => "...";
    public Task<DbConnection> GetConnectionAsync(CancellationToken ct) => /* ... */;
}

services.AddOutbox(builder => builder.UsePostgres<MyConnectionFactory>());

Migrations and readiness

This provider runs FluentMigrator migrations on startup and waits for readiness before handlers begin polling. The database user must have permissions to create schemas, tables, and types.

Notes

• ExecutionPolicy.Sequential uses a Postgres advisory lock to ensure single active processing per identifier.
• DeletePolicy.Safe marks records as deleted; cleanup is performed by the background cleaner when BackupInterval is set.