Class BinaryJournalService
- Namespace
- Moongate.Persistence.Services.Persistence
- Assembly
- Moongate.Persistence.dll
Stores append-only journal entries in a binary file with checksum validation.
public sealed class BinaryJournalService : IJournalService
- Inheritance
-
BinaryJournalService
- Implements
- Inherited Members
Constructors
BinaryJournalService(string)
public BinaryJournalService(string journalFilePath)
Parameters
journalFilePathstring
Methods
AppendAsync(JournalEntry, CancellationToken)
Appends one journal entry to durable storage.
public ValueTask AppendAsync(JournalEntry entry, CancellationToken cancellationToken = default)
Parameters
entryJournalEntrycancellationTokenCancellationToken
Returns
ReadAllAsync(CancellationToken)
Reads all valid journal entries in persistence order.
public ValueTask<IReadOnlyCollection<JournalEntry>> ReadAllAsync(CancellationToken cancellationToken = default)
Parameters
cancellationTokenCancellationToken
Returns
ResetAsync(CancellationToken)
Clears the journal content after a successful snapshot.
public ValueTask ResetAsync(CancellationToken cancellationToken = default)
Parameters
cancellationTokenCancellationToken