org.trianacode.enactment.logging.stampede

Class StampedeLog

java.lang.Object

org.trianacode.enactment.logging.stampede.StampedeLog

public class StampedeLog
extends java.lang.Object

Created by IntelliJ IDEA. User: Ian Harvey Date: 14/03/2012 Time: 13:19 To change this template use File | Settings | File Templates.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StampedeLog.JobType

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	JOB_ID
static java.lang.String	JOB_INST_ID
static java.lang.String	PARENT_UUID_STRING
static java.lang.String	RUN_UUID_STRING
static java.lang.String	STAMPEDE_TASK_TYPE
java.util.HashMap<Task,java.lang.Integer>	taskMap

Constructor Summary

Constructors

Constructor and Description
StampedeLog(TaskGraph tgraph, java.util.UUID runUUID)

Method Summary

Methods

Modifier and Type	Method and Description
StampedeEvent	addBaseEventDetails(StampedeEvent stampedeEvent)
StampedeEvent	addBaseJobInstDetails(StampedeEvent stampedeEvent, Task task)
StampedeEvent	addSchedJobInstDetails(StampedeEvent stampedeEvent, Task task)
void	complete()
ExecutionListener	getExecutionLogger()
static java.lang.String	getHostname()
java.util.UUID	getRunUUID()
java.lang.Integer	getTaskNumber(Task task)
void	initExecutionProperties(java.util.HashMap<java.lang.String,java.lang.String> executionProperties)
boolean	isSubWorkflow()
void	logAllTasks(TaskGraph taskgraph)
void	logGraph(TaskGraph taskgraph)
void	logHost(RunnableTask runnableTask)
void	logInvocationEnd(Task runnableTask, java.lang.String args, long startTime, long duration)
void	logInvocationStart(Task runnableTask)
void	logJobInstStart(TaskGraph taskGraph)
void	logJobTerminate(RunnableTask runnableTask)
void	logPlanEvent(TaskGraph tgraph)
void	logStampedeEvent(StampedeEvent stampedeEvent)
void	logSubWf()
void	logTaskgraphCables(TaskGraph taskgraph)
void	logTaskgraphJob(TaskGraph taskgraph)
void	logTaskgraphJobs(TaskGraph taskgraph)
void	logTaskGraphTask(TaskGraph taskgraph)
void	mapTaskCablesToJobCables(TaskGraph taskgraph)
void	mapTasksTojobs(TaskGraph taskgraph)
void	recordSchedForRootTaskGraph(TaskGraph taskGraph)
void	reset(java.util.UUID uuid)
void	scheduleTask(Task task)
void	setRunUUID(java.util.UUID runUUID)
void	wakeTask(Task task)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

STAMPEDE_TASK_TYPE

public static final java.lang.String STAMPEDE_TASK_TYPE

See Also:

Constant Field Values

RUN_UUID_STRING

public static final java.lang.String RUN_UUID_STRING

See Also:

Constant Field Values

PARENT_UUID_STRING

public static final java.lang.String PARENT_UUID_STRING

See Also:

Constant Field Values

JOB_ID

public static final java.lang.String JOB_ID

See Also:

Constant Field Values

JOB_INST_ID

public static final java.lang.String JOB_INST_ID

See Also:

Constant Field Values

taskMap

public java.util.HashMap<Task,java.lang.Integer> taskMap

Constructor Detail

StampedeLog

public StampedeLog(TaskGraph tgraph,
           java.util.UUID runUUID)

Method Detail

isSubWorkflow

public boolean isSubWorkflow()

complete

public void complete()

reset

public void reset(java.util.UUID uuid)

logStampedeEvent

public void logStampedeEvent(StampedeEvent stampedeEvent)

logPlanEvent

public void logPlanEvent(TaskGraph tgraph)

logSubWf

public void logSubWf()

logTaskGraphTask

public void logTaskGraphTask(TaskGraph taskgraph)

logAllTasks

public void logAllTasks(TaskGraph taskgraph)

logTaskgraphCables

public void logTaskgraphCables(TaskGraph taskgraph)

logTaskgraphJob

public void logTaskgraphJob(TaskGraph taskgraph)

logTaskgraphJobs

public void logTaskgraphJobs(TaskGraph taskgraph)

mapTasksTojobs

public void mapTasksTojobs(TaskGraph taskgraph)

mapTaskCablesToJobCables

public void mapTaskCablesToJobCables(TaskGraph taskgraph)

logGraph

public void logGraph(TaskGraph taskgraph)

getTaskNumber

public java.lang.Integer getTaskNumber(Task task)

addBaseJobInstDetails

public StampedeEvent addBaseJobInstDetails(StampedeEvent stampedeEvent,
                                  Task task)

addBaseEventDetails

public StampedeEvent addBaseEventDetails(StampedeEvent stampedeEvent)

addSchedJobInstDetails

public StampedeEvent addSchedJobInstDetails(StampedeEvent stampedeEvent,
                                   Task task)

wakeTask

public void wakeTask(Task task)

recordSchedForRootTaskGraph

public void recordSchedForRootTaskGraph(TaskGraph taskGraph)

getHostname

public static java.lang.String getHostname()

scheduleTask

public void scheduleTask(Task task)

getExecutionLogger

public ExecutionListener getExecutionLogger()

setRunUUID

public void setRunUUID(java.util.UUID runUUID)

logInvocationStart

public void logInvocationStart(Task runnableTask)

logJobInstStart

public void logJobInstStart(TaskGraph taskGraph)

logJobTerminate

public void logJobTerminate(RunnableTask runnableTask)

logInvocationEnd

public void logInvocationEnd(Task runnableTask,
                    java.lang.String args,
                    long startTime,
                    long duration)

logHost

public void logHost(RunnableTask runnableTask)

initExecutionProperties

public void initExecutionProperties(java.util.HashMap<java.lang.String,java.lang.String> executionProperties)

getRunUUID

public java.util.UUID getRunUUID()