Namespace FlowOrchestrator.PostgreSQL

Classes

PostgreSqlFlowOrchestratorMigrator

Hosted service that runs idempotent PostgreSQL schema migrations at startup. Creates the flow_definitions, flow_runs, flow_steps, flow_step_attempts, flow_outputs, and related tables if they do not already exist. Safe to run on every startup — all statements use IF NOT EXISTS guards.

PostgreSqlFlowRunStore

Dapper-based PostgreSQL implementation of all run storage interfaces. Uses PostgreSQL's INSERT ... ON CONFLICT DO NOTHING for atomic step claim deduplication.

PostgreSqlFlowScheduleStateStore

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

PostgreSqlFlowSignalStore

Dapper-based PostgreSQL implementation of IFlowSignalStore. Persists waiters in the flow_signal_waiters table created by PostgreSqlFlowOrchestratorMigrator.

PostgreSqlFlowStore

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

PostgreSqlOutputsRepository

Dapper-based PostgreSQL implementation of IOutputsRepository and IFlowEventReader. Persists step inputs/outputs and trigger data to the flow_outputs table, and events to the flow_events table with a sequence generated by a PostgreSQL sequence object.

PostgreSqlServiceCollectionExtensions

DI registration helpers for the PostgreSQL FlowOrchestrator storage backend.

PostgreSqlWebhookRejectionStore

Dapper-based PostgreSQL implementation of IWebhookRejectionStore. Persists DLQ + accepted-delivery rows in the webhook_rejections table created by PostgreSqlFlowOrchestratorMigrator.

PostgreSqlWebhookReplayStore

Dapper-based PostgreSQL implementation of IWebhookReplayStore. Persists nonces in the webhook_replay_nonces table created by PostgreSqlFlowOrchestratorMigrator.