FlowSimulation

The type of the callback function.

Its input consists of the generated TaskInstance and the timestamp when it was completed. A Failure input corresponds to an exception happening or an aborted task.

Declare IDs of TaskInstances that need to be aborted.

Calls respective Callbacks with Failure.

Declares that the simulation has finished processing one or more completed TaskInstances.

Identifies the tasks via their UUID.

Manages a completed TaskInstance.

The simulation logic must react to this by either registering more tasks or finishing.

If new tasks are produced, the completed TaskInstance must be acknowledged via ack. Alternatively, if we do not want to ack all completed tasks, we can just call ready. Finally, if the simulation completes, we can use done, succeed or fail accordingly.

Calls the corresponding Callback in the tasks map and then removes the entry.

Declares that the simulation completed.

Declares that the simulation has failed or has been aborted.

Calculates an optional Lookahead structure for tasks that are expected in the future.

This is called via ready.

Declares that the simulation has finished calculating and is ready for virtual time to proceed.

Requests that the Manager waits for this simulation before it continues.

The simulation needs to either register more tasks and become ready or finish.

Declares that the simulation completed successfully.

Declare a new Task that needs to be sent to the Coordinator for simulation with a pre-determined ID.

The provided callback function will be called when the corresponding Task is completed.

When it finishes executing, it must notify the Coordinator either by acknowledging the completed task using ack or by completing the simulation using done, succeed or fail.

The ready method can also be called if there is no need to acknowledge completed tasks individually. This is unlikely in the current scenario where each task has its own callback, but it's still worth mentioning.

Declare a new Task that needs to be sent for simulation.

A map of TaskInstance IDs that have been sent to the Manager and the callback functions that need to be called when the tasks complete.

Initiates the execution of the simulation.

Creates a simple success callback from a function.

Does nothing on failure.

Stops/aborts the simuation.

Triggers all callbacks with a Failure.