Interface PipelineBlock
public interface PipelineBlock
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic interfaceAPipelineBlock.BlockEvaluationContextis an "instance" for evaluating an incomingAlarmEventagainst aPipelineBlock's configuration. -
Method Summary
Modifier and TypeMethodDescriptionvoidinitialize(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.BlockEvaluationContextfor 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.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.
-