Class PostgreSqlFlowScheduleStateStore

Namespace

FlowOrchestrator.PostgreSQL

Assembly

FlowOrchestrator.PostgreSQL.dll

PostgreSQL implementation of IFlowScheduleStateStore that persists cron overrides and pause state in the flow_schedule_states table using upsert semantics.

public sealed class PostgreSqlFlowScheduleStateStore : IFlowScheduleStateStore

Inheritance

object

PostgreSqlFlowScheduleStateStore

Implements

IFlowScheduleStateStore

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PostgreSqlFlowScheduleStateStore(string)

Initialises the store with the given Npgsql connection string.

public PostgreSqlFlowScheduleStateStore(string connectionString)

Parameters

connectionString string

PostgreSQL connection string for the FlowOrchestrator database.

Methods

DeleteAsync(string)

Removes the schedule state for the given job ID if it exists.

public Task DeleteAsync(string jobId)

Parameters

jobId string

Returns

Task

GetAllAsync()

Returns all persisted schedule states.

public Task<IReadOnlyList<FlowScheduleState>> GetAllAsync()

Returns

Task<IReadOnlyList<FlowScheduleState>>

GetAsync(string)

Returns the schedule state for the given Hangfire recurring job ID, or null if no override has been saved.

public Task<FlowScheduleState?> GetAsync(string jobId)

Parameters

jobId string

Returns

Task<FlowScheduleState>

SaveAsync(FlowScheduleState)

Inserts or replaces the schedule state for JobId.

public Task SaveAsync(FlowScheduleState state)

Parameters

state FlowScheduleState

Returns

Task