Interface IJournalService

Namespace

Moongate.Persistence.Interfaces.Persistence

Assembly

Moongate.Persistence.dll

Appends and replays journal entries from durable storage.

public interface IJournalService

Methods

AppendAsync(JournalEntry, CancellationToken)

Appends one journal entry to durable storage.

ValueTask AppendAsync(JournalEntry entry, CancellationToken cancellationToken = default)

Parameters

entry JournalEntry

cancellationToken CancellationToken

Returns

ValueTask

ReadAllAsync(CancellationToken)

Reads all valid journal entries in persistence order.

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

Parameters

cancellationToken CancellationToken

Returns

ValueTask<IReadOnlyCollection<JournalEntry>>

ResetAsync(CancellationToken)

Clears the journal content after a successful snapshot.

ValueTask ResetAsync(CancellationToken cancellationToken = default)

Parameters

cancellationToken CancellationToken

Returns

ValueTask