Workflow Engine .NET

Assembly: OptimaJet.Workflow.SQLite

Class WorkflowRuntime

OptimaJet.Workflow.SQLite.Models.WorkflowRuntime

public class WorkflowRuntime : DbObject<RuntimeEntity>

Inheritance

  • System.Object
  • OptimaJet.Workflow.SQLite.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(SqliteConnection connection, WorkflowRuntimeModel status, Guid oldLock) #

Parameters

Name
Type
Description
connection
SqliteConnection
status
WorkflowRuntimeModel
oldLock
Guid

Returns

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

Parameters

Name
Type
Description
connection
SqliteConnection
status
WorkflowRuntimeModel
oldLock
Guid

Returns

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

Parameters

Name
Type
Description
connection
SqliteConnection

Returns

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

Parameters

Name
Type
Description
connection
SqliteConnection
currentRuntimeId
String

Returns

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

Parameters

Name
Type
Description
connection
SqliteConnection
runtimeId
String

Returns

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

Parameters

Name
Type
Description
connection
SqliteConnection
runtimeId
String
time
DateTime

Returns

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

Parameters

Name
Type
Description
connection
SqliteConnection
runtimeId
String
nextTimeColumnName
String
time
DateTime
transaction
SqliteTransaction

Returns

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

Parameters

Name
Type
Description
connection
SqliteConnection
runtimeId
String
nextTimeColumnName
String

Returns

Type
Description
Task<DateTime>