Interface PipelineBlock
-
public interface PipelineBlock
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
PipelineBlock.BlockEvaluationContext
APipelineBlock.BlockEvaluationContext
is an "instance" for evaluating an incomingAlarmEvent
against aPipelineBlock
's configuration.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
initialize(java.util.Queue<PipelineBlock.BlockEvaluationContext> evalQueue, java.util.Map<java.util.UUID,PipelineBlock> blockMap)
Hang onto the evalQueue instance and resolve any outgoing connections using blockMap.PipelineBlock.BlockEvaluationContext
newEvaluationContext(AlarmEvent alarmEvent, TrackingContext trackingContext)
Create a newPipelineBlock.BlockEvaluationContext
for the givenAlarmEvent
.
-
-
-
Method Detail
-
initialize
void initialize(java.util.Queue<PipelineBlock.BlockEvaluationContext> evalQueue, java.util.Map<java.util.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.
-
-