Class InMemoryFlowStore

Namespace

FlowOrchestrator.InMemory

Assembly

FlowOrchestrator.InMemory.dll

In-memory implementation of IFlowStore that stores FlowDefinitionRecord instances in a thread-safe dictionary. All state is lost on process restart.

public sealed class InMemoryFlowStore : IFlowStore

Inheritance

object

InMemoryFlowStore

Implements

IFlowStore

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Methods

DeleteAsync(Guid)

Permanently deletes the flow definition with the given id.

public Task DeleteAsync(Guid id)

Parameters

id Guid

Returns

Task

GetAllAsync()

Returns all registered flow definitions, ordered by name.

public Task<IReadOnlyList<FlowDefinitionRecord>> GetAllAsync()

Returns

Task<IReadOnlyList<FlowDefinitionRecord>>

GetByIdAsync(Guid)

Returns the flow definition with the given id, or null if not found.

public Task<FlowDefinitionRecord?> GetByIdAsync(Guid id)

Parameters

id Guid

Returns

Task<FlowDefinitionRecord>

SaveAsync(FlowDefinitionRecord)

Inserts or updates the flow definition record (upsert by Id).

public Task<FlowDefinitionRecord> SaveAsync(FlowDefinitionRecord record)

Parameters

record FlowDefinitionRecord

Returns

Task<FlowDefinitionRecord>

The persisted record, including any server-set timestamps.

SetEnabledAsync(Guid, bool)

Enables or disables a flow without deleting it. Disabled flows are not triggered by the scheduler and are hidden from the active flow list.

public Task<FlowDefinitionRecord> SetEnabledAsync(Guid id, bool enabled)

Parameters

id Guid

enabled bool

Returns

Task<FlowDefinitionRecord>

The updated record.