Namespace Cephalon.EventSourcing.Nats

Namespaces

Cephalon.EventSourcing.Nats.Hosting

Classes

NatsEventEntry

Plain-object representation of a single event stored in a NATS JetStream KV entry.

NatsEventStore

NATS JetStream KV-backed implementation of . Each event is stored as a KV entry with key format {streamId}/{streamVersion:D20}. Zero-padding ensures correct lexicographic ordering of version keys. Optimistic concurrency is enforced via a pre-append version check and CreateAsync which throws if the key already exists.