Interface AlarmPipeline
public interface AlarmPipeline
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionvoidevaluate(AlarmEvent alarmEvent, TrackingContext trackingContext) Evaluate analarmEvent.getName()Get the name of this pipeline.voidretire(AlarmPipeline.RetiredCallback callback) Retire this pipeline.voidstart()Start this pipeline.voidstop()Stop this pipeline and everything running in it immediately.
-
Method Details
-
start
void start()Start this pipeline. A pipeline will always be started before any calls toevaluate(AlarmEvent, TrackingContext)happen.Set MDC keys before coming here.
-
stop
void stop()Stop this pipeline and everything running in it immediately.Set MDC keys before coming here.
-
retire
Retire this pipeline. This differs from stopping a pipeline in that allAlarmEvents currently evaluating inside the pipeline should be allowed to finish. Upon completion of the last event,callbackwill be notified.Set MDC keys before coming here.
- Parameters:
callback- The callback to notify once the pipeline is empty and has finished running.
-
evaluate
Evaluate analarmEvent.Set MDC keys before coming here.
- Parameters:
alarmEvent- TheAlarmEventto evaluate, not nulltrackingContext- TheTrackingContextforalarmEvent. Update the context on transitions and when the event is finished being evaluated, not null
-
getName
Get the name of this pipeline. Used mainly to set MDC log keys- Returns:
- the pipeline name, not null
-