Package io.nflow.engine.workflow.executor

Class WorkflowExecutor

java.lang.Object

io.nflow.engine.model.ModelObject

io.nflow.engine.workflow.executor.WorkflowExecutor

public class WorkflowExecutor
extends ModelObject

Describes one workflow executor.

Field Summary

Fields

Modifier and Type	Field	Description
final org.joda.time.DateTime	active	Time when the executor last updated that it is active.
final String	executorGroup	The executor group of the executor.
final org.joda.time.DateTime	expires	Time after which the executor is considered dead.
final String	host	The host name of the executor.
final int	id	Unique identifier of executor instance.
final int	pid	Process id of the executor.
final org.joda.time.DateTime	recovered	Time when the workflow instances of a dead node were recovered.
final org.joda.time.DateTime	started	Time when the executor was started.
final org.joda.time.DateTime	stopped	Time when the executor was stopped.

Constructor Summary

Constructors

Constructor	Description
WorkflowExecutor(int id, String host, int pid, String executorGroup, org.joda.time.DateTime started, org.joda.time.DateTime active, org.joda.time.DateTime expires, org.joda.time.DateTime stopped, org.joda.time.DateTime recovered)	Creates a new workflow executor description.

Method Summary

Methods inherited from class io.nflow.engine.model.ModelObject

equals, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

id

public final int id

Unique identifier of executor instance. Each time an executor is started it receives a new identifier.

host

public final String host

The host name of the executor.

pid

public final int pid

Process id of the executor.

executorGroup

public final String executorGroup

The executor group of the executor.

started

public final org.joda.time.DateTime started

Time when the executor was started.

active

public final org.joda.time.DateTime active

Time when the executor last updated that it is active.

expires

public final org.joda.time.DateTime expires

Time after which the executor is considered dead.

stopped

public final org.joda.time.DateTime stopped

Time when the executor was stopped.

recovered

public final org.joda.time.DateTime recovered

Time when the workflow instances of a dead node were recovered.

Constructor Details

WorkflowExecutor

public WorkflowExecutor(int id,
 String host,
 int pid,
 String executorGroup,
 org.joda.time.DateTime started,
 org.joda.time.DateTime active,
 org.joda.time.DateTime expires,
 org.joda.time.DateTime stopped,
 org.joda.time.DateTime recovered)

Creates a new workflow executor description.

Parameters:

id - Unique identifier of executor instance

host - The host name of the executor

pid - Process id of the executor

executorGroup - The executor group of the executor

started - Time when the executor was started

active - Time when the executor last updated that it is active

expires - Time after which the executor is considered dead

stopped - Time when the executor was stopped

recovered - Time when the workflow instances of a dead node were recovered