TriggeredTaskExecutor class

Responsible for handling the execution of a TriggeredTask.

This is an abstract class. For each specific type of Trigger, a corresponding implementation of a TriggeredTaskExecutor exists.

Inheritance

Constructors

TriggeredTaskExecutor(TriggeredTask triggeredTask, CAMSTrigger trigger, TaskDescriptor task)

Properties

data Stream<DataPoint>
Get the aggregated stream of DataPoint data sampled by all executors and probes in this triggered task executor. [...]
read-only, override
enabled bool
Is this probe enabled, i.e. available for collection of data using the resume method.
read-only, inherited
executors List<Probe>
read / write, inherited
hashCode int
The hash code for this object. [...]
read-only, inherited
measure Measure
The Measure that configures this probe.
read-only, inherited
name String
A printer-friendly name for this probe.
read-only, inherited
probes List<Probe>
Returns a list of the running probes in this TriggeredTaskExecutor. This is a combination of the running probes in all task executors.
read-only
runtimeType Type
A representation of the runtime type of the object.
read-only, inherited
state ProbeState
The runtime state of this probe.
read-only, inherited
stateEvents Stream<ProbeState>
The runtime state changes of this probe. [...]
read-only, inherited
task TaskDescriptor
read-only
trigger CAMSTrigger
read-only
triggeredTask TriggeredTask
read-only
type String
The type of this probe according to String.
read-only, inherited

Methods

error() → void
inherited
hasChanged(Measure measure) → void
Callback when this probe's measure has changed.
inherited
initialize(Measure measure) → void
Initialize the probe before starting it. [...]
inherited
mark() → void
Mark the latest sampling
@protected, inherited
marking() → void
Get the latest mark
@protected, inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a non-existent method or property is accessed. [...]
inherited
onInitialize(Measure measure) → void
Callback for initialization of probe. [...]
inherited
onPause() Future
Callback for pausing probe
inherited
onRestart({Measure measure}) Future
Callback for restarting probe
inherited
onResume() Future
Callback for resuming probe
inherited
onStop() Future
Callback for stopping probe
inherited
pause() → void
Pause the probe. The probe is paused until resume or restart is called.
inherited
restart() → void
Restart the probe. [...]
inherited
resume() → void
Resume the probe.
inherited
stop() → void
Stop the probe. Once a probe is stopped, it cannot be started again. If you need to restart a probe, use the restart or pause and resume methods.
inherited
toString() String
A string representation of this object. [...]
inherited
validNextState(ProbeState nextState) bool
Is ProbeState a valid next state for this probe? [...]
inherited

Operators

operator ==(Object other) bool
The equality operator. [...]
inherited