nebulous/slo-violation-detector
Code Issues Proposed changes

Fix of a bug related to lost devices and change listening port

Browse Source 
Improved the code to allow the component to correctly publish messages related to the loss of a device

Change-Id: I94a6fdb4612de192c24511445f1236cdce94b404
This commit is contained in:
Andreas Tsagkaropoulos 2024-05-29 15:22:35 +03:00
parent 246fcc68ae
commit 63d66b73b4
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
slo-violation-detector/src/main/java/slo_violation_detector_engine/detector/DetectorSubcomponent.java
View File

@ -63,7 +63,7 @@ public class DetectorSubcomponent extends SLOViolationDetectorSubcomponent {
detector_name = "detector_"+application_name+"_"+current_detector_id; detector_name = "detector_"+application_name+"_"+current_detector_id;
} }
for (String metric_string : unbounded_metric_strings) { for (String metric_string : unbounded_metric_strings) {
subcomponent_state.getMonitoring_attributes_bounds_representation().put(metric_string.split(";")[0], metric_string.split(";", 2)[1]); //TODO delete once this information is successfully received from the AMQP broker subcomponent_state.getMonitoring_attributes_bounds_representation().put(metric_string.split(";")[0], metric_string.split(";", 2)[1]); //TODO delete once this information is successfully received from the AMQP broker - this is alternative functionality to receiving the metrics list containing the metric boundaries
} }
if (characterized_thread_run_mode.equals(attached)) { if (characterized_thread_run_mode.equals(attached)) {
DetectorSubcomponentUtilities.run_slo_violation_detection_engine(this); DetectorSubcomponentUtilities.run_slo_violation_detection_engine(this);

2
slo-violation-detector/src/main/java/slo_violation_detector_engine/director/DirectorSubcomponent.java
View File

@ -117,7 +117,7 @@ public class DirectorSubcomponent extends SLOViolationDetectorSubcomponent {
BrokerSubscriber device_lost_subscriber = new BrokerSubscriber(topic_for_lost_device_announcement, broker_ip, broker_port, broker_username, broker_password, amq_library_configuration_location,EMPTY); BrokerSubscriber device_lost_subscriber = new BrokerSubscriber(topic_for_lost_device_announcement, broker_ip, broker_port, broker_username, broker_password, amq_library_configuration_location,EMPTY);
BiFunction<BrokerSubscriptionDetails, String, String> device_lost_subscriber_function = (broker_details, message) -> { BiFunction<BrokerSubscriptionDetails, String, String> device_lost_subscriber_function = (broker_details, message) -> {
BrokerPublisher persistent_publisher = new BrokerPublisher(topic_for_severity_announcement, broker_ip, broker_port, broker_username, broker_password, amq_library_configuration_location); BrokerPublisher persistent_publisher = new BrokerPublisher(topic_for_severity_announcement, broker_ip, broker_port, broker_username, broker_password, amq_library_configuration_location, true);
Clock clock = Clock.systemUTC(); Clock clock = Clock.systemUTC();
Long current_time_seconds = (long) Math.floor(clock.millis()/1000.0); Long current_time_seconds = (long) Math.floor(clock.millis()/1000.0);

3
slo-violation-detector/src/main/resources/application.properties
View File

@ -1,4 +1,5 @@
spring.profiles.active=production spring.profiles.active=production
spring.mvc.view.prefix=/src/main/webapp/WEB-INF/jsp/ spring.mvc.view.prefix=/src/main/webapp/WEB-INF/jsp/
spring.mvc.view.suffix=.jsp spring.mvc.view.suffix=.jsp
logging.level.org.springframework.web.servlet.view.InternalResourceViewResolver=DEBUG logging.level.org.springframework.web.servlet.view.InternalResourceViewResolver=DEBUG
server.port: 8010