Class PostgreSqlFlowStore

Namespace

FlowOrchestrator.PostgreSQL

Assembly

FlowOrchestrator.PostgreSQL.dll

Dapper-based PostgreSQL implementation of IFlowStore. Uses explicit SQL queries against the flow_definitions table.

public sealed class PostgreSqlFlowStore : IFlowStore

Inheritance

object

PostgreSqlFlowStore

Implements

IFlowStore

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PostgreSqlFlowStore(string)

public PostgreSqlFlowStore(string connectionString)

Parameters

connectionString string

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.