Interface PipelineBlock
public interface PipelineBlock
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic interface
APipelineBlock.BlockEvaluationContext
is an "instance" for evaluating an incomingAlarmEvent
against aPipelineBlock
's configuration. -
Method Summary
Modifier and TypeMethodDescriptionvoid
initialize
(Queue<PipelineBlock.BlockEvaluationContext> evalQueue, Map<UUID, PipelineBlock> blockMap) Hang onto the evalQueue instance and resolve any outgoing connections using blockMap.newEvaluationContext
(AlarmEvent alarmEvent, TrackingContext trackingContext) Create a newPipelineBlock.BlockEvaluationContext
for the givenAlarmEvent
.
-
Method Details
-
initialize
void initialize(Queue<PipelineBlock.BlockEvaluationContext> evalQueue, Map<UUID, PipelineBlock> blockMap) Hang onto the evalQueue instance and resolve any outgoing connections using blockMap.- Parameters:
evalQueue
- The evaluation queue to place the nextPipelineBlock.BlockEvaluationContext
when making a transition to the next block.blockMap
- AMap
to resolve output block ids to block instances.
-
newEvaluationContext
PipelineBlock.BlockEvaluationContext newEvaluationContext(AlarmEvent alarmEvent, TrackingContext trackingContext) Create a newPipelineBlock.BlockEvaluationContext
for the givenAlarmEvent
.- Parameters:
alarmEvent
- The inputAlarmEvent
.trackingContext
- TheTrackingContext
to update when evaluation occurs.TrackingContext.transition()
should already have been called.- Returns:
- A
PipelineBlock.BlockEvaluationContext
for the given input.
-