Interface PipelineBlock
-
public interface PipelineBlock
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfacePipelineBlock.BlockEvaluationContextAPipelineBlock.BlockEvaluationContextis an "instance" for evaluating an incomingAlarmEventagainst aPipelineBlock's configuration.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidinitialize(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.BlockEvaluationContextnewEvaluationContext(AlarmEvent alarmEvent, TrackingContext trackingContext)Create a newPipelineBlock.BlockEvaluationContextfor 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.BlockEvaluationContextwhen making a transition to the next block.blockMap- AMapto resolve output block ids to block instances.
-
newEvaluationContext
PipelineBlock.BlockEvaluationContext newEvaluationContext(AlarmEvent alarmEvent, TrackingContext trackingContext)
Create a newPipelineBlock.BlockEvaluationContextfor the givenAlarmEvent.- Parameters:
alarmEvent- The inputAlarmEvent.trackingContext- TheTrackingContextto update when evaluation occurs.TrackingContext.transition()should already have been called.- Returns:
- A
PipelineBlock.BlockEvaluationContextfor the given input.
-
-