pswamp.coordination.alarm_handling

Attributes

config

Classes

`AlarmSender`	Application for sending alarms, based on status of running WAMPAC apps
`AlarmMonitor`

Module Contents

class pswamp.coordination.alarm_handling.AlarmSender(kafka_kwargs, input_topic='application.status', alarm_topic='alarms', alarm_time_threshold=15)

Application for sending alarms, based on status of running WAMPAC apps

Consumes messages from the

input_topic = 'application.status'

alarm_topic = 'alarms'

kafka_kwargs

input_stream

output_stream

app_status

alarm_time_threshold = 15

t_1

_is_stopped = False

start()

stop()

run()

class pswamp.coordination.alarm_handling.AlarmMonitor(kafka_kwargs, alarm_topic='alarms')

input_stream

alarm_data

alarm_events

t_1

start()

run_alarm_consumer()

pswamp.coordination.alarm_handling.config