IJournalStorage

interface

Namespace: Orleans.Journaling

Provides journal storage.

public interface IJournalStorage

Properties

IsCompactionRequested Gets a value indicating whether compaction has been requested.

Methods

AppendAsync(ReadOnlySequence<byte>, CancellationToken) Appends the provided segment to the journal atomically.
CreateIfNotExistsAsync(IReadOnlyDictionary<string, string>, CancellationToken) Creates this journal storage instance if it does not already exist.
DeleteAsync(CancellationToken) Deletes the journal atomically.
GetMetadataAsync(CancellationToken) Gets metadata for this journal storage instance.
ReadAsync(IJournalStorageConsumer, CancellationToken) Reads all journal data belonging to this instance and sends it to consumer.
ReplaceAsync(ReadOnlySequence<byte>, CancellationToken) Replaces the journal with the provided value atomically.
UpdateMetadataAsync(IReadOnlyDictionary<string, string>, IEnumerable<string>, string?, CancellationToken) Conditionally updates caller-owned metadata properties.