---

⚡ Performance

BenchmarkDotNet on AMD Ryzen 7 5800H, .NET 9.0.8

Scenario	Latency	Memory	Throughput
Create Order (Command)	351 ns	104 B	2.8M ops/sec
Get Order (Query)	337 ns	80 B	2.9M ops/sec
Event (3 handlers)	352 ns	208 B	2.8M ops/sec
Complete Flow (Command + Event)	729 ns	312 B	1.4M ops/sec
E-Commerce (Order + Payment + Query)	923 ns	416 B	1.1M ops/sec
Batch 10 Flows	10.2 μs	4.2 KB	98K flows/sec
Concurrent 10 Flows	9.3 μs	4.3 KB	108K flows/sec
High-Throughput 20 Orders	5.8 μs	5.4 KB	172K ops/sec

---

✨ Features

• Zero Reflection - Source Generator, compile-time handler discovery
• Native AOT - Full support, trimming safe
• Distributed - Redis Streams, NATS JetStream
• Event Sourcing - Event Store, Snapshots, Projections, Time Travel
• Flow DSL - Distributed workflows, Sagas, ForEach parallel processing
• Reliability - Outbox/Inbox, Idempotency, Dead Letter Queue
• Observability - OpenTelemetry tracing, Metrics

---

🚀 Quick Start

dotnet add package Catga dotnet add package Catga.Transport.InMemory dotnet add package Catga.Persistence.InMemory dotnet add package Catga.Serialization.MemoryPack // Define command [MemoryPackable] public partial record CreateOrder(string ProductId, int Quantity) : IRequest<Order>; // Define handler public class CreateOrderHandler : IRequestHandler<CreateOrder, Order> { public ValueTask<CatgaResult<Order>> HandleAsync(CreateOrder cmd, CancellationToken ct = default) => new(CatgaResult<Order>.Success(new Order(cmd.ProductId, cmd.Quantity))); } // Configure builder.Services.AddCatga().UseMemoryPack(); builder.Services.AddInMemoryTransport(); builder.Services.AddInMemoryPersistence(); // Use var result = await mediator.SendAsync<CreateOrder, Order>(new("PROD-001", 5));

---

📦 Packages

Package	Description
Catga	Core framework
Catga.Transport.InMemory	In-memory transport
Catga.Transport.Redis	Redis Streams
Catga.Transport.Nats	NATS JetStream
Catga.Persistence.InMemory	In-memory persistence
Catga.Persistence.Redis	Redis persistence
Catga.Persistence.Nats	NATS persistence
Catga.Serialization.MemoryPack	Binary serialization
Catga.AspNetCore	ASP.NET Core integration

---

🛒 OrderSystem Example

A complete e-commerce system demonstrating best practices. Focus on your business logic, not framework boilerplate.

examples/OrderSystem/ ├── Commands/ # Command definitions ├── Queries/ # Query definitions ├── Events/ # Event definitions ├── Handlers/ # Business logic ├── Flows/ # Distributed workflows ├── Models/ # Domain models └── Program.cs # Minimal setup

Run

cd examples/OrderSystem dotnet run # Run tests .\test.ps1

Key Patterns

1. Commands & Queries - Clean separation of write/read operations

// Command - changes state public record CreateOrder(string CustomerId, List<OrderItem> Items) : IRequest<Order>; // Query - reads state public record GetOrder(string OrderId) : IRequest<Order>;

2. Event Sourcing - Full audit trail

public record OrderCreated(string OrderId, string CustomerId) : IEvent; public record OrderShipped(string OrderId, string TrackingNumber) : IEvent;

3. Flow DSL - Distributed workflows

public class OrderFlow : FlowConfig<OrderState> { protected override void Configure(IFlowBuilder<OrderState> flow) { flow.Send(s => new ReserveInventory(s.Items)) .IfFail(s => new ReleaseInventory(s.ReservationId)); flow.Send(s => new ProcessPayment(s.OrderId, s.Total)) .IfFail(s => new RefundPayment(s.PaymentId)); flow.Publish(s => new OrderCompleted(s.OrderId)); } }

---

🗄️ Event Sourcing

// Append events await eventStore.AppendAsync("Order-123", new[] { orderCreated, itemAdded }); // Read stream var stream = await eventStore.ReadAsync("Order-123"); // Snapshots await snapshotStore.SaveAsync("Order-123", aggregate, version); // Time Travel var stateAtV5 = await timeTravelService.GetStateAtVersionAsync("order-1", 5);

---

🔄 Flow DSL

public class ProcessOrderFlow : FlowConfig<OrderState> { protected override void Configure(IFlowBuilder<OrderState> flow) { // Sequential steps with compensation flow.Send(s => new ReserveInventory(s.OrderId)) .Into(s => s.ReservationId) .IfFail(s => new ReleaseInventory(s.ReservationId)); // Parallel processing flow.ForEach<OrderItem>(s => s.Items) .Configure((item, f) => f.Send(s => new ProcessItem(item.Id))) .WithParallelism(4) .ContinueOnFailure() .EndForEach(); // Conditional logic flow.If(s => s.AllItemsProcessed) .Send(s => new CompleteOrder(s.OrderId)) .EndIf(); } }

---

🔧 Configuration

// OpenTelemetry builder.Services.AddOpenTelemetry() .WithTracing(t => t.AddSource(CatgaOpenTelemetryExtensions.ActivitySourceName)) .WithMetrics(m => m.AddMeter(CatgaOpenTelemetryExtensions.MeterName)); // Resilience builder.Services.AddCatga() .UseResilience(o => o.TransportRetryCount = 3); // Reliability builder.Services.AddCatga() .UseInbox() .UseOutbox();

---

📚 Documentation

• Getting Started
• Flow DSL Guide
• Event Sourcing
• Architecture
• API Reference

---

📄 License

MIT