Workflow Engine .NET

Assembly: OptimaJet.Workflow.PostgreSQL

Class WorkflowRuntime

OptimaJet.Workflow.PostgreSQL.Models.WorkflowRuntime

public class WorkflowRuntime : DbObject<RuntimeEntity>

Inheritance

  • System.Object
  • OptimaJet.Workflow.PostgreSQL.DbObject{OptimaJet.Workflow.Core.Entities.RuntimeEntity}

Constructors

public WorkflowRuntime(string schemaName, int commandTimeout) #

Parameters

Name
Type
Description
schemaName
String
commandTimeout
Int32

Methods

public Task<int> UpdateStatusAsync(NpgsqlConnection connection, WorkflowRuntimeModel status, Guid oldLock) #

Parameters

Name
Type
Description
connection
NpgsqlConnection
status
WorkflowRuntimeModel
oldLock
Guid

Returns

Type
Description
Task<Int32>
public Task<int> UpdateRestorerAsync(NpgsqlConnection connection, WorkflowRuntimeModel status, Guid oldLock) #

Parameters

Name
Type
Description
connection
NpgsqlConnection
status
WorkflowRuntimeModel
oldLock
Guid

Returns

Type
Description
Task<Int32>
public Task<bool> MultiServerRuntimesExistAsync(NpgsqlConnection connection) #

Parameters

Name
Type
Description
connection
NpgsqlConnection

Returns

Type
Description
Task<Boolean>
public Task<int> GetActiveMultiServerRuntimesCountAsync(NpgsqlConnection connection, string currentRuntimeId) #

Parameters

Name
Type
Description
connection
NpgsqlConnection
currentRuntimeId
String

Returns

Type
Description
Task<Int32>
public Task<WorkflowRuntimeModel> GetWorkflowRuntimeStatusAsync(NpgsqlConnection connection, string runtimeId) #

Parameters

Name
Type
Description
connection
NpgsqlConnection
runtimeId
String

Returns

Type
Description
Task<WorkflowRuntimeModel>
public Task<int> SendRuntimeLastAliveSignalAsync(NpgsqlConnection connection, string runtimeId, DateTime time) #

Parameters

Name
Type
Description
connection
NpgsqlConnection
runtimeId
String
time
DateTime

Returns

Type
Description
Task<Int32>
public Task<int> UpdateNextTimeAsync(NpgsqlConnection connection, string runtimeId, string nextTimeColumnName, DateTime time, NpgsqlTransaction transaction = null) #

Parameters

Name
Type
Description
connection
NpgsqlConnection
runtimeId
String
nextTimeColumnName
String
time
DateTime
transaction
NpgsqlTransaction

Returns

Type
Description
Task<Int32>
public Task<DateTime?> GetMaxNextTimeAsync(NpgsqlConnection connection, string runtimeId, string nextTimeColumnName) #

Parameters

Name
Type
Description
connection
NpgsqlConnection
runtimeId
String
nextTimeColumnName
String

Returns

Type
Description
Task<DateTime>