Interface IEventStoreMaintenance

Namespace

Opossum

Assembly

Opossum.dll

Additive-only maintenance operations for the event store. All operations are strictly additive — no existing data can be modified or removed.

public interface IEventStoreMaintenance

Methods

AddTagsAsync(string, Func<SequencedEvent, IReadOnlyList<Tag>>, CancellationToken)

Retroactively adds tags to all stored events of the specified eventType. Only tags whose key does not already exist on an event are written; existing tags are never modified or deleted.

Task<TagMigrationResult> AddTagsAsync(string eventType, Func<SequencedEvent, IReadOnlyList<Tag>> tagFactory, CancellationToken cancellationToken = default)

Parameters

eventType string

The event type name (matches EventType).

tagFactory Func<SequencedEvent, IReadOnlyList<Tag>>

A delegate invoked for each matching event. Return the tags that should be added; the framework discards any tag whose key already exists on the event.

cancellationToken CancellationToken

Token that can cancel the operation between events.

Returns

Task<TagMigrationResult>

A TagMigrationResult summarising how many tags were added and how many events were examined.