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. 
 
 -