Interface IFlowRetentionStore

Namespace

FlowOrchestrator.Core.Storage

Assembly

FlowOrchestrator.Core.dll

Data cleanup contract called periodically by FlowRetentionHostedService to remove runs, steps, outputs, and events older than the configured TTL.

public interface IFlowRetentionStore

Methods

CleanupAsync(DateTimeOffset, CancellationToken)

Deletes all run data (runs, steps, attempts, outputs, events) whose completion time is older than cutoffUtc.

Task CleanupAsync(DateTimeOffset cutoffUtc, CancellationToken cancellationToken)

Parameters

cutoffUtc DateTimeOffset

Runs completed before this timestamp are eligible for deletion.

cancellationToken CancellationToken

Propagates cancellation from the host shutdown signal.

Returns

Task