Class PostgreSqlFlowOrchestratorMigrator

Namespace

FlowOrchestrator.PostgreSQL

Assembly

FlowOrchestrator.PostgreSQL.dll

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.

public sealed class PostgreSqlFlowOrchestratorMigrator : IHostedService

Inheritance

object

PostgreSqlFlowOrchestratorMigrator

Implements

IHostedService

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

PostgreSqlFlowOrchestratorMigrator(string, ILogger<PostgreSqlFlowOrchestratorMigrator>)

public PostgreSqlFlowOrchestratorMigrator(string connectionString, ILogger<PostgreSqlFlowOrchestratorMigrator> logger)

Parameters

connectionString string

logger ILogger<PostgreSqlFlowOrchestratorMigrator>

Methods

StartAsync(CancellationToken)

Triggered when the application host is ready to start the service.

public Task StartAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Indicates that the start process has been aborted.

Returns

Task

A Task that represents the asynchronous Start operation.

StopAsync(CancellationToken)

Triggered when the application host is performing a graceful shutdown.

public Task StopAsync(CancellationToken cancellationToken)

Parameters

cancellationToken CancellationToken

Indicates that the shutdown process should no longer be graceful.

Returns

Task

A Task that represents the asynchronous Stop operation.