diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/commons/NotificationResult.java b/ems-core/control-service/src/main/java/eu/melodic/models/commons/NotificationResult.java deleted file mode 100644 index 0f3b945..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/commons/NotificationResult.java +++ /dev/null @@ -1,42 +0,0 @@ -package eu.melodic.models.commons; - -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import java.lang.Object; -import java.lang.String; -import java.util.Map; - -@JsonDeserialize( - as = NotificationResultImpl.class -) -public interface NotificationResult { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - StatusType getStatus(); - - void setStatus(StatusType status); - - String getErrorCode(); - - void setErrorCode(String errorCode); - - String getErrorDescription(); - - void setErrorDescription(String errorDescription); - - enum StatusType { - @JsonProperty("SUCCESS") - SUCCESS("SUCCESS"), - - @JsonProperty("ERROR") - ERROR("ERROR"); - - private String name; - - StatusType(String name) { - this.name = name; - } - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/commons/NotificationResultImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/commons/NotificationResultImpl.java deleted file mode 100644 index 6fd5272..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/commons/NotificationResultImpl.java +++ /dev/null @@ -1,72 +0,0 @@ -package eu.melodic.models.commons; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "status", - "errorCode", - "errorDescription" -}) -public class NotificationResultImpl implements NotificationResult { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("status") - private StatusType status; - - @JsonProperty("errorCode") - private String errorCode; - - @JsonProperty("errorDescription") - private String errorDescription; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("status") - public StatusType getStatus() { - return this.status; - } - - @JsonProperty("status") - public void setStatus(StatusType status) { - this.status = status; - } - - @JsonProperty("errorCode") - public String getErrorCode() { - return this.errorCode; - } - - @JsonProperty("errorCode") - public void setErrorCode(String errorCode) { - this.errorCode = errorCode; - } - - @JsonProperty("errorDescription") - public String getErrorDescription() { - return this.errorDescription; - } - - @JsonProperty("errorDescription") - public void setErrorDescription(String errorDescription) { - this.errorDescription = errorDescription; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/commons/Watermark.java b/ems-core/control-service/src/main/java/eu/melodic/models/commons/Watermark.java deleted file mode 100644 index 4a69788..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/commons/Watermark.java +++ /dev/null @@ -1,32 +0,0 @@ -package eu.melodic.models.commons; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import java.lang.Object; -import java.lang.String; -import java.util.Date; -import java.util.Map; - -@JsonDeserialize( - as = WatermarkImpl.class -) -public interface Watermark { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - String getUser(); - - void setUser(String user); - - String getSystem(); - - void setSystem(String system); - - Date getDate(); - - void setDate(Date date); - - String getUuid(); - - void setUuid(String uuid); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/commons/WatermarkImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/commons/WatermarkImpl.java deleted file mode 100644 index 35e39eb..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/commons/WatermarkImpl.java +++ /dev/null @@ -1,92 +0,0 @@ -package eu.melodic.models.commons; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonFormat; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import java.lang.Object; -import java.lang.String; -import java.util.Date; -import java.util.HashMap; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "user", - "system", - "date", - "uuid" -}) -public class WatermarkImpl implements Watermark { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("user") - private String user; - - @JsonProperty("system") - private String system; - - @JsonProperty("date") - @JsonFormat( - shape = JsonFormat.Shape.STRING, - pattern = "yyyy-MM-dd'T'HH:mm:ssZ" - ) - private Date date; - - @JsonProperty("uuid") - private String uuid; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("user") - public String getUser() { - return this.user; - } - - @JsonProperty("user") - public void setUser(String user) { - this.user = user; - } - - @JsonProperty("system") - public String getSystem() { - return this.system; - } - - @JsonProperty("system") - public void setSystem(String system) { - this.system = system; - } - - @JsonProperty("date") - public Date getDate() { - return this.date; - } - - @JsonProperty("date") - public void setDate(Date date) { - this.date = date; - } - - @JsonProperty("uuid") - public String getUuid() { - return this.uuid; - } - - @JsonProperty("uuid") - public void setUuid(String uuid) { - this.uuid = uuid; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/CamelModelRequest.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/CamelModelRequest.java deleted file mode 100644 index 6f4bd01..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/CamelModelRequest.java +++ /dev/null @@ -1,29 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import eu.melodic.models.commons.Watermark; - -import java.lang.Object; -import java.lang.String; -import java.util.Map; - -@JsonDeserialize( - as = CamelModelRequestImpl.class -) -public interface CamelModelRequest { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - String getApplicationId(); - - void setApplicationId(String applicationId); - - String getNotificationURI(); - - void setNotificationURI(String notificationURI); - - Watermark getWatermark(); - - void setWatermark(Watermark watermark); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/CamelModelRequestImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/CamelModelRequestImpl.java deleted file mode 100644 index 50a9ea2..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/CamelModelRequestImpl.java +++ /dev/null @@ -1,74 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import eu.melodic.models.commons.Watermark; - -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "applicationId", - "notificationURI", - "watermark" -}) -public class CamelModelRequestImpl implements CamelModelRequest { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("applicationId") - private String applicationId; - - @JsonProperty("notificationURI") - private String notificationURI; - - @JsonProperty("watermark") - private Watermark watermark; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("applicationId") - public String getApplicationId() { - return this.applicationId; - } - - @JsonProperty("applicationId") - public void setApplicationId(String applicationId) { - this.applicationId = applicationId; - } - - @JsonProperty("notificationURI") - public String getNotificationURI() { - return this.notificationURI; - } - - @JsonProperty("notificationURI") - public void setNotificationURI(String notificationURI) { - this.notificationURI = notificationURI; - } - - @JsonProperty("watermark") - public Watermark getWatermark() { - return this.watermark; - } - - @JsonProperty("watermark") - public void setWatermark(Watermark watermark) { - this.watermark = watermark; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Interval.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Interval.java deleted file mode 100644 index 97e376e..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Interval.java +++ /dev/null @@ -1,53 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import java.lang.Object; -import java.lang.String; -import java.util.Map; - -@JsonDeserialize( - as = IntervalImpl.class -) -public interface Interval { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - UnitType getUnit(); - - void setUnit(UnitType unit); - - int getPeriod(); - - void setPeriod(int period); - - enum UnitType { - @JsonProperty("DAYS") - DAYS("DAYS"), - - @JsonProperty("HOURS") - HOURS("HOURS"), - - @JsonProperty("MICROSECONDS") - MICROSECONDS("MICROSECONDS"), - - @JsonProperty("MILLISECONDS") - MILLISECONDS("MILLISECONDS"), - - @JsonProperty("MINUTES") - MINUTES("MINUTES"), - - @JsonProperty("NANOSECONDS") - NANOSECONDS("NANOSECONDS"), - - @JsonProperty("SECONDS") - SECONDS("SECONDS"); - - private String name; - - UnitType(String name) { - this.name = name; - } - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/IntervalImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/IntervalImpl.java deleted file mode 100644 index ef4aceb..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/IntervalImpl.java +++ /dev/null @@ -1,58 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "unit", - "period" -}) -public class IntervalImpl implements Interval { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("unit") - private UnitType unit; - - @JsonProperty("period") - private int period; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("unit") - public UnitType getUnit() { - return this.unit; - } - - @JsonProperty("unit") - public void setUnit(UnitType unit) { - this.unit = unit; - } - - @JsonProperty("period") - public int getPeriod() { - return this.period; - } - - @JsonProperty("period") - public void setPeriod(int period) { - this.period = period; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/KeyValuePair.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/KeyValuePair.java deleted file mode 100644 index d6cab79..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/KeyValuePair.java +++ /dev/null @@ -1,23 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import java.lang.Object; -import java.lang.String; -import java.util.Map; - -@JsonDeserialize( - as = KeyValuePairImpl.class -) -public interface KeyValuePair { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - String getKey(); - - void setKey(String key); - - String getValue(); - - void setValue(String value); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/KeyValuePairImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/KeyValuePairImpl.java deleted file mode 100644 index 2f88607..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/KeyValuePairImpl.java +++ /dev/null @@ -1,58 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "key", - "value" -}) -public class KeyValuePairImpl implements KeyValuePair { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("key") - private String key; - - @JsonProperty("value") - private String value; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("key") - public String getKey() { - return this.key; - } - - @JsonProperty("key") - public void setKey(String key) { - this.key = key; - } - - @JsonProperty("value") - public String getValue() { - return this.value; - } - - @JsonProperty("value") - public void setValue(String value) { - this.value = value; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Monitor.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Monitor.java deleted file mode 100644 index cf07aee..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Monitor.java +++ /dev/null @@ -1,37 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; - -import java.lang.Object; -import java.lang.String; -import java.util.List; -import java.util.Map; - -@JsonDeserialize( - as = MonitorImpl.class -) -public interface Monitor { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - String getMetric(); - - void setMetric(String metric); - - String getComponent(); - - void setComponent(String component); - - Sensor getSensor(); - - void setSensor(Sensor sensor); - - List getSinks(); - - void setSinks(List sinks); - - List getTags(); - - void setTags(List tags); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorImpl.java deleted file mode 100644 index 405ab8f..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorImpl.java +++ /dev/null @@ -1,102 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; - -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "metric", - "component", - "sensor", - "sinks", - "tags" -}) -public class MonitorImpl implements Monitor { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("metric") - private String metric; - - @JsonProperty("component") - private String component; - - @JsonProperty("sensor") - private Sensor sensor; - - @JsonProperty("sinks") - private List sinks; - - @JsonProperty("tags") - private List tags; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("metric") - public String getMetric() { - return this.metric; - } - - @JsonProperty("metric") - public void setMetric(String metric) { - this.metric = metric; - } - - @JsonProperty("component") - public String getComponent() { - return this.component; - } - - @JsonProperty("component") - public void setComponent(String component) { - this.component = component; - } - - @JsonProperty("sensor") - public Sensor getSensor() { - return this.sensor; - } - - @JsonProperty("sensor") - public void setSensor(Sensor sensor) { - this.sensor = sensor; - } - - @JsonProperty("sinks") - public List getSinks() { - return this.sinks; - } - - @JsonProperty("sinks") - public void setSinks(List sinks) { - this.sinks = sinks; - } - - @JsonProperty("tags") - public List getTags() { - return this.tags; - } - - @JsonProperty("tags") - public void setTags(List tags) { - this.tags = tags; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataRequest.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataRequest.java deleted file mode 100644 index 9ef094d..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataRequest.java +++ /dev/null @@ -1,25 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import eu.melodic.models.commons.Watermark; - -import java.lang.Object; -import java.lang.String; -import java.util.Map; - -@JsonDeserialize( - as = MonitorsDataRequestImpl.class -) -public interface MonitorsDataRequest { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - String getApplicationId(); - - void setApplicationId(String applicationId); - - Watermark getWatermark(); - - void setWatermark(Watermark watermark); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataRequestImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataRequestImpl.java deleted file mode 100644 index 522e346..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataRequestImpl.java +++ /dev/null @@ -1,60 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import eu.melodic.models.commons.Watermark; - -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "applicationId", - "watermark" -}) -public class MonitorsDataRequestImpl implements MonitorsDataRequest { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("applicationId") - private String applicationId; - - @JsonProperty("watermark") - private Watermark watermark; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("applicationId") - public String getApplicationId() { - return this.applicationId; - } - - @JsonProperty("applicationId") - public void setApplicationId(String applicationId) { - this.applicationId = applicationId; - } - - @JsonProperty("watermark") - public Watermark getWatermark() { - return this.watermark; - } - - @JsonProperty("watermark") - public void setWatermark(Watermark watermark) { - this.watermark = watermark; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataResponse.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataResponse.java deleted file mode 100644 index 1b874f6..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataResponse.java +++ /dev/null @@ -1,26 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import eu.melodic.models.commons.Watermark; - -import java.lang.Object; -import java.lang.String; -import java.util.List; -import java.util.Map; - -@JsonDeserialize( - as = MonitorsDataResponseImpl.class -) -public interface MonitorsDataResponse { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - List getMonitors(); - - void setMonitors(List monitors); - - Watermark getWatermark(); - - void setWatermark(Watermark watermark); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataResponseImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataResponseImpl.java deleted file mode 100644 index b03b76a..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/MonitorsDataResponseImpl.java +++ /dev/null @@ -1,61 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import eu.melodic.models.commons.Watermark; - -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "monitors", - "watermark" -}) -public class MonitorsDataResponseImpl implements MonitorsDataResponse { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("monitors") - private List monitors; - - @JsonProperty("watermark") - private Watermark watermark; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("monitors") - public List getMonitors() { - return this.monitors; - } - - @JsonProperty("monitors") - public void setMonitors(List monitors) { - this.monitors = monitors; - } - - @JsonProperty("watermark") - public Watermark getWatermark() { - return this.watermark; - } - - @JsonProperty("watermark") - public void setWatermark(Watermark watermark) { - this.watermark = watermark; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PullSensor.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PullSensor.java deleted file mode 100644 index addaac7..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PullSensor.java +++ /dev/null @@ -1,29 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; - -import java.lang.Object; -import java.lang.String; -import java.util.List; -import java.util.Map; - -@JsonDeserialize( - as = PullSensorImpl.class -) -public interface PullSensor { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - String getClassName(); - - void setClassName(String className); - - List getConfiguration(); - - void setConfiguration(List configuration); - - Interval getInterval(); - - void setInterval(Interval interval); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PullSensorImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PullSensorImpl.java deleted file mode 100644 index edaf90b..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PullSensorImpl.java +++ /dev/null @@ -1,73 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "className", - "configuration", - "interval" -}) -public class PullSensorImpl implements PullSensor { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("className") - private String className; - - @JsonProperty("configuration") - private List configuration; - - @JsonProperty("interval") - private Interval interval; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("className") - public String getClassName() { - return this.className; - } - - @JsonProperty("className") - public void setClassName(String className) { - this.className = className; - } - - @JsonProperty("configuration") - public List getConfiguration() { - return this.configuration; - } - - @JsonProperty("configuration") - public void setConfiguration(List configuration) { - this.configuration = configuration; - } - - @JsonProperty("interval") - public Interval getInterval() { - return this.interval; - } - - @JsonProperty("interval") - public void setInterval(Interval interval) { - this.interval = interval; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PushSensor.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PushSensor.java deleted file mode 100644 index 909d324..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PushSensor.java +++ /dev/null @@ -1,19 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import java.lang.Object; -import java.lang.String; -import java.util.Map; - -@JsonDeserialize( - as = PushSensorImpl.class -) -public interface PushSensor { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - int getPort(); - - void setPort(int port); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PushSensorImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PushSensorImpl.java deleted file mode 100644 index 2c08ff7..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/PushSensorImpl.java +++ /dev/null @@ -1,42 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder("port") -public class PushSensorImpl implements PushSensor { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("port") - private int port; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("port") - public int getPort() { - return this.port; - } - - @JsonProperty("port") - public void setPort(int port) { - this.port = port; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Sensor.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Sensor.java deleted file mode 100644 index 7eb8ec5..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Sensor.java +++ /dev/null @@ -1,49 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import com.fasterxml.jackson.databind.annotation.JsonSerialize; -import eu.melodic.models.resources.SensorDeserializer; -import eu.melodic.models.resources.SensorSerializer; - -import java.lang.IllegalStateException; -import java.lang.Object; - -@JsonDeserialize( - using = SensorDeserializer.class -) -@JsonSerialize( - using = SensorSerializer.class -) -public class Sensor { - private Object anyType; - - private Sensor() { - this.anyType = null; - } - - public Sensor(PushSensor pushSensor) { - this.anyType = pushSensor; - } - - public Sensor(PullSensor pullSensor) { - this.anyType = pullSensor; - } - - public PushSensor getPushSensor() { - if ( !(anyType instanceof PushSensor)) throw new IllegalStateException("fetching wrong type out of the union: PushSensor"); - return (PushSensor) anyType; - } - - public boolean isPushSensor() { - return anyType instanceof PushSensor; - } - - public PullSensor getPullSensor() { - if ( !(anyType instanceof PullSensor)) throw new IllegalStateException("fetching wrong type out of the union: PullSensor"); - return (PullSensor) anyType; - } - - public boolean isPullSensor() { - return anyType instanceof PullSensor; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Sink.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Sink.java deleted file mode 100644 index 8ff0dba..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/Sink.java +++ /dev/null @@ -1,46 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; - -import java.lang.Object; -import java.lang.String; -import java.util.List; -import java.util.Map; - -@JsonDeserialize( - as = SinkImpl.class -) -public interface Sink { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - TypeType getType(); - - void setType(TypeType type); - - List getConfiguration(); - - void setConfiguration(List configuration); - - enum TypeType { - @JsonProperty("KAIROS_DB") - KAIROSDB("KAIROS_DB"), - - @JsonProperty("INFLUX") - INFLUX("INFLUX"), - - @JsonProperty("JMS") - JMS("JMS"), - - @JsonProperty("CLI") - CLI("CLI"); - - private String name; - - TypeType(String name) { - this.name = name; - } - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/SinkImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/SinkImpl.java deleted file mode 100644 index 092b1f3..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/interfaces/SinkImpl.java +++ /dev/null @@ -1,60 +0,0 @@ -package eu.melodic.models.interfaces; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; - -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.List; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "type", - "configuration" -}) -public class SinkImpl implements Sink { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("type") - private TypeType type; - - @JsonProperty("configuration") - private List configuration; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("type") - public TypeType getType() { - return this.type; - } - - @JsonProperty("type") - public void setType(TypeType type) { - this.type = type; - } - - @JsonProperty("configuration") - public List getConfiguration() { - return this.configuration; - } - - @JsonProperty("configuration") - public void setConfiguration(List configuration) { - this.configuration = configuration; - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/resources/SensorDeserializer.java b/ems-core/control-service/src/main/java/eu/melodic/models/resources/SensorDeserializer.java deleted file mode 100644 index c6ad6db..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/resources/SensorDeserializer.java +++ /dev/null @@ -1,36 +0,0 @@ -package eu.melodic.models.resources; - -import com.fasterxml.jackson.core.JsonParser; -import com.fasterxml.jackson.databind.DeserializationContext; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.deser.std.StdDeserializer; -import gr.iccs.imu.ems.util.StrUtil; -import eu.melodic.models.interfaces.PullSensor; -import eu.melodic.models.interfaces.PushSensor; -import eu.melodic.models.interfaces.Sensor; -import java.io.IOException; -import java.lang.Object; -import java.lang.String; -import java.util.Arrays; -import java.util.Map; - -public class SensorDeserializer extends StdDeserializer { - public SensorDeserializer() { - super(Sensor.class);} - - private boolean looksLikePushSensor(Map map) { - return map.keySet().containsAll(Arrays.asList("port")); - } - - private boolean looksLikePullSensor(Map map) { - return map.keySet().containsAll(Arrays.asList("className","configuration","interval")); - } - - public Sensor deserialize(JsonParser jsonParser, DeserializationContext jsonContext) throws IOException { - ObjectMapper mapper = new ObjectMapper(); - Map map = StrUtil.castToMapStringObject( mapper.readValue(jsonParser, Map.class) ); - if ( looksLikePushSensor(map) ) return new Sensor(mapper.convertValue(map, PushSensor.class)); - if ( looksLikePullSensor(map) ) return new Sensor(mapper.convertValue(map, PullSensor.class)); - throw new IOException("Can't figure out type of object" + map); - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/resources/SensorSerializer.java b/ems-core/control-service/src/main/java/eu/melodic/models/resources/SensorSerializer.java deleted file mode 100644 index a5c8e18..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/resources/SensorSerializer.java +++ /dev/null @@ -1,25 +0,0 @@ -package eu.melodic.models.resources; - -import com.fasterxml.jackson.core.JsonGenerator; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.SerializerProvider; -import com.fasterxml.jackson.databind.ser.std.StdSerializer; -import eu.melodic.models.interfaces.Sensor; -import java.io.IOException; - -public class SensorSerializer extends StdSerializer { - public SensorSerializer() { - super(Sensor.class);} - - public void serialize(Sensor object, JsonGenerator jsonGenerator, SerializerProvider jsonSerializerProvider) throws IOException, JsonProcessingException { - if ( object.isPushSensor()) { - jsonGenerator.writeObject(object.getPushSensor()); - return; - } - if ( object.isPullSensor()) { - jsonGenerator.writeObject(object.getPullSensor()); - return; - } - throw new IOException("Can't figure out type of object" + object); - } -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/services/CamelModelNotificationRequest.java b/ems-core/control-service/src/main/java/eu/melodic/models/services/CamelModelNotificationRequest.java deleted file mode 100644 index 25c35d7..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/services/CamelModelNotificationRequest.java +++ /dev/null @@ -1,30 +0,0 @@ -package eu.melodic.models.services; - -import com.fasterxml.jackson.databind.annotation.JsonDeserialize; -import eu.melodic.models.commons.NotificationResult; -import eu.melodic.models.commons.Watermark; - -import java.lang.Object; -import java.lang.String; -import java.util.Map; - -@JsonDeserialize( - as = CamelModelNotificationRequestImpl.class -) -public interface CamelModelNotificationRequest { - Map getAdditionalProperties(); - - void setAdditionalProperties(Map additionalProperties); - - String getApplicationId(); - - void setApplicationId(String applicationId); - - NotificationResult getResult(); - - void setResult(NotificationResult result); - - Watermark getWatermark(); - - void setWatermark(Watermark watermark); -} diff --git a/ems-core/control-service/src/main/java/eu/melodic/models/services/CamelModelNotificationRequestImpl.java b/ems-core/control-service/src/main/java/eu/melodic/models/services/CamelModelNotificationRequestImpl.java deleted file mode 100644 index fdb0b36..0000000 --- a/ems-core/control-service/src/main/java/eu/melodic/models/services/CamelModelNotificationRequestImpl.java +++ /dev/null @@ -1,75 +0,0 @@ -package eu.melodic.models.services; - -import com.fasterxml.jackson.annotation.JsonAnyGetter; -import com.fasterxml.jackson.annotation.JsonAnySetter; -import com.fasterxml.jackson.annotation.JsonIgnore; -import com.fasterxml.jackson.annotation.JsonInclude; -import com.fasterxml.jackson.annotation.JsonProperty; -import com.fasterxml.jackson.annotation.JsonPropertyOrder; -import eu.melodic.models.commons.NotificationResult; -import eu.melodic.models.commons.Watermark; - -import java.lang.Object; -import java.lang.String; -import java.util.HashMap; -import java.util.Map; - -@JsonInclude(JsonInclude.Include.NON_NULL) -@JsonPropertyOrder({ - "applicationId", - "result", - "watermark" -}) -public class CamelModelNotificationRequestImpl implements CamelModelNotificationRequest { - @JsonIgnore - private Map additionalProperties = new HashMap(); - - @JsonProperty("applicationId") - private String applicationId; - - @JsonProperty("result") - private NotificationResult result; - - @JsonProperty("watermark") - private Watermark watermark; - - @JsonAnyGetter - public Map getAdditionalProperties() { - return additionalProperties; - } - - @JsonAnySetter - public void setAdditionalProperties(Map additionalProperties) { - this.additionalProperties = additionalProperties; - } - - @JsonProperty("applicationId") - public String getApplicationId() { - return this.applicationId; - } - - @JsonProperty("applicationId") - public void setApplicationId(String applicationId) { - this.applicationId = applicationId; - } - - @JsonProperty("result") - public NotificationResult getResult() { - return this.result; - } - - @JsonProperty("result") - public void setResult(NotificationResult result) { - this.result = result; - } - - @JsonProperty("watermark") - public Watermark getWatermark() { - return this.watermark; - } - - @JsonProperty("watermark") - public void setWatermark(Watermark watermark) { - this.watermark = watermark; - } -}