Table of Contents

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

journalFilePath string

Methods

AppendAsync(JournalEntry, CancellationToken)

Appends one journal entry to durable storage.

public ValueTask AppendAsync(JournalEntry entry, CancellationToken cancellationToken = default)

Parameters

entry JournalEntry
cancellationToken CancellationToken

Returns

ValueTask

ReadAllAsync(CancellationToken)

Reads all valid journal entries in persistence order.

public ValueTask<IReadOnlyCollection<JournalEntry>> ReadAllAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

ValueTask<IReadOnlyCollection<JournalEntry>>

ResetAsync(CancellationToken)

Clears the journal content after a successful snapshot.

public ValueTask ResetAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

ValueTask