Loading src/policy/src/main/java/eu/teraflow/policy/PolicyServiceImpl.java +8 −2 Original line number Diff line number Diff line Loading @@ -198,7 +198,9 @@ public class PolicyServiceImpl implements PolicyService { return policyRuleState; } contextService.setPolicyRule(policyRule).subscribe().with(x -> {}); LOGGER.infof("THIS IS A TEST! 1"); setPolicyRuleServiceToContext(policyRuleService, VALIDATED_POLICYRULE_STATE); LOGGER.infof("THIS IS A TEST! 2"); noAlarms = 0; // Create an alarmIds list that contains the promised ids returned from setKpiAlarm Loading @@ -208,7 +210,8 @@ public class PolicyServiceImpl implements PolicyService { LOGGER.infof(alarmDescriptor.toString()); alarmIds.add(monitoringService.setKpiAlarm(alarmDescriptor)); } LOGGER.infof("THIS IS A TEST!"); LOGGER.infof("%s", alarmIds); // Transform the alarmIds into promised alarms returned from the // getAlarmResponseStream List<Multi<AlarmResponse>> alarmResponseStreamList = new ArrayList<>(); Loading Loading @@ -725,7 +728,8 @@ public class PolicyServiceImpl implements PolicyService { // TODO: Temp fix for AlarmDescriptor object AlarmDescriptor alarmDescriptor = new AlarmDescriptor( "alarmId-" + gen(), //"alarmId-" + gen(), null, "alarmDescription", "alarmName-" + gen(), policyRuleCondition.getKpiId(), Loading Loading @@ -770,6 +774,7 @@ public class PolicyServiceImpl implements PolicyService { final var kpiValueRange = convertPolicyRuleConditionToKpiValueRange(policyRuleCondition); return new AlarmDescriptor( //"alarmId-" + gen(), "alarmId-" + gen(), "alarmDescription", "alarmName-" + gen(), Loading Loading @@ -800,6 +805,7 @@ public class PolicyServiceImpl implements PolicyService { } return new AlarmDescriptor( //"alarmId-" + gen(), "alarmId-" + gen(), "alarmDescription", "alarmName-" + gen(), Loading src/policy/src/main/resources/application.yml +10 −7 Original line number Diff line number Diff line Loading @@ -23,6 +23,9 @@ quarkus: context: host: ${quarkus.kubernetes.env.vars.context-service-host} port: 1010 context_policy: host: ${quarkus.kubernetes.env.vars.context-service-host} port: 1010 monitoring: host: ${quarkus.kubernetes.env.vars.monitoring-service-host} port: 7070 Loading Loading @@ -60,11 +63,11 @@ quarkus: context-service-host: "contextservice" monitoring-service-host: "monitoringservice" service-service-host: "serviceservice" resources: requests: cpu: 50m memory: 512Mi limits: cpu: 500m memory: 2048Mi # resources: # requests: # cpu: 50m # memory: 512Mi # limits: # cpu: 500m # memory: 2048Mi Loading
src/policy/src/main/java/eu/teraflow/policy/PolicyServiceImpl.java +8 −2 Original line number Diff line number Diff line Loading @@ -198,7 +198,9 @@ public class PolicyServiceImpl implements PolicyService { return policyRuleState; } contextService.setPolicyRule(policyRule).subscribe().with(x -> {}); LOGGER.infof("THIS IS A TEST! 1"); setPolicyRuleServiceToContext(policyRuleService, VALIDATED_POLICYRULE_STATE); LOGGER.infof("THIS IS A TEST! 2"); noAlarms = 0; // Create an alarmIds list that contains the promised ids returned from setKpiAlarm Loading @@ -208,7 +210,8 @@ public class PolicyServiceImpl implements PolicyService { LOGGER.infof(alarmDescriptor.toString()); alarmIds.add(monitoringService.setKpiAlarm(alarmDescriptor)); } LOGGER.infof("THIS IS A TEST!"); LOGGER.infof("%s", alarmIds); // Transform the alarmIds into promised alarms returned from the // getAlarmResponseStream List<Multi<AlarmResponse>> alarmResponseStreamList = new ArrayList<>(); Loading Loading @@ -725,7 +728,8 @@ public class PolicyServiceImpl implements PolicyService { // TODO: Temp fix for AlarmDescriptor object AlarmDescriptor alarmDescriptor = new AlarmDescriptor( "alarmId-" + gen(), //"alarmId-" + gen(), null, "alarmDescription", "alarmName-" + gen(), policyRuleCondition.getKpiId(), Loading Loading @@ -770,6 +774,7 @@ public class PolicyServiceImpl implements PolicyService { final var kpiValueRange = convertPolicyRuleConditionToKpiValueRange(policyRuleCondition); return new AlarmDescriptor( //"alarmId-" + gen(), "alarmId-" + gen(), "alarmDescription", "alarmName-" + gen(), Loading Loading @@ -800,6 +805,7 @@ public class PolicyServiceImpl implements PolicyService { } return new AlarmDescriptor( //"alarmId-" + gen(), "alarmId-" + gen(), "alarmDescription", "alarmName-" + gen(), Loading
src/policy/src/main/resources/application.yml +10 −7 Original line number Diff line number Diff line Loading @@ -23,6 +23,9 @@ quarkus: context: host: ${quarkus.kubernetes.env.vars.context-service-host} port: 1010 context_policy: host: ${quarkus.kubernetes.env.vars.context-service-host} port: 1010 monitoring: host: ${quarkus.kubernetes.env.vars.monitoring-service-host} port: 7070 Loading Loading @@ -60,11 +63,11 @@ quarkus: context-service-host: "contextservice" monitoring-service-host: "monitoringservice" service-service-host: "serviceservice" resources: requests: cpu: 50m memory: 512Mi limits: cpu: 500m memory: 2048Mi # resources: # requests: # cpu: 50m # memory: 512Mi # limits: # cpu: 500m # memory: 2048Mi