You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2024/03/28 14:59:53 UTC
(streampipes) branch dev updated: refactor: remove unused monitoring package (#2668)
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 6c2d23051f refactor: remove unused monitoring package (#2668)
6c2d23051f is described below
commit 6c2d23051f040df949119f32e8c89eb7a7ec2d10
Author: Tim <50...@users.noreply.github.com>
AuthorDate: Thu Mar 28 15:59:48 2024 +0100
refactor: remove unused monitoring package (#2668)
---
.../model/client/monitoring/JobReport.java | 64 -------------
.../model/client/monitoring/TaskReport.java | 57 ------------
.../monitoring/pipeline/AbstractBurrowInfo.java | 49 ----------
.../pipeline/BurrowConsumerGroupStatus.java | 100 ---------------------
.../pipeline/BurrowConsumerGroupStatusInfo.java | 39 --------
.../monitoring/pipeline/BurrowConsumerInfo.java | 45 ----------
.../monitoring/pipeline/BurrowTopicInfo.java | 40 ---------
.../pipeline/PipelineExecutionStatus.java | 25 ------
8 files changed, 419 deletions(-)
diff --git a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/JobReport.java b/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/JobReport.java
deleted file mode 100644
index 7abadf9ed3..0000000000
--- a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/JobReport.java
+++ /dev/null
@@ -1,64 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.client.monitoring;
-
-import java.util.Date;
-import java.util.List;
-
-public class JobReport {
-
- // contains report of a single job
- // TODO needed?
-
- //TODO store in database and create queries
-
- private String elementId;
- private Date generationDate;
- private List<TaskReport> taskReports;
-
- public JobReport(String elementId, Date generationDate, List<TaskReport> taskResults) {
- this.generationDate = generationDate;
- this.taskReports = taskResults;
- this.elementId = elementId;
- }
-
- public Date getGenerationDate() {
- return generationDate;
- }
-
- public void setGenerationDate(Date generationDate) {
- this.generationDate = generationDate;
- }
-
- public List<TaskReport> getTaskReports() {
- return taskReports;
- }
-
- public void setTaskReports(List<TaskReport> taskReports) {
- this.taskReports = taskReports;
- }
-
- public String getElementId() {
- return elementId;
- }
-
- public void setElementId(String elementId) {
- this.elementId = elementId;
- }
-}
diff --git a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/TaskReport.java b/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/TaskReport.java
deleted file mode 100644
index a2daae7399..0000000000
--- a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/TaskReport.java
+++ /dev/null
@@ -1,57 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.client.monitoring;
-
-import java.util.Date;
-
-public class TaskReport {
- //contains report of an individual task
- private Date executionDate;
- private boolean success;
- private String taskName;
-
- private String optionalMessage;
-
- public TaskReport(String taskName, Date executionDate, boolean success,
- String optinalMessage) {
- super();
- this.executionDate = executionDate;
- this.success = success;
- this.optionalMessage = optinalMessage;
- this.taskName = taskName;
- }
-
- public Date getExecutionDate() {
- return executionDate;
- }
-
- public boolean isSuccess() {
- return success;
- }
-
- public String getOptionalMessage() {
- return optionalMessage;
- }
-
- @Override
- public String toString() {
- return "{ \nTask Execution: " + taskName + "\nDate: " + executionDate.toString() + "\nSuccess: " + success
- + "\nMessage: " + optionalMessage + "}";
- }
-}
diff --git a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/AbstractBurrowInfo.java b/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/AbstractBurrowInfo.java
deleted file mode 100644
index d2277698c4..0000000000
--- a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/AbstractBurrowInfo.java
+++ /dev/null
@@ -1,49 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.client.monitoring.pipeline;
-
-public abstract class AbstractBurrowInfo {
-
- protected String error;
- protected String message;
-
- public AbstractBurrowInfo(String error, String message) {
- this.error = error;
- this.message = message;
- }
-
- public AbstractBurrowInfo() {
- }
-
- public String getError() {
- return error;
- }
-
- public void setError(String error) {
- this.error = error;
- }
-
- public String getMessage() {
- return message;
- }
-
- public void setMessage(String message) {
- this.message = message;
- }
-}
diff --git a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerGroupStatus.java b/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerGroupStatus.java
deleted file mode 100644
index dfd5b90b59..0000000000
--- a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerGroupStatus.java
+++ /dev/null
@@ -1,100 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.client.monitoring.pipeline;
-
-public class BurrowConsumerGroupStatus {
-
- private String cluster;
- private String group;
- private String status;
- private boolean complete;
- private String[] partitions;
-
- private Integer partitionCount;
- private Integer maxlag;
- private Integer totallag;
-
- public BurrowConsumerGroupStatus() {
-
- }
-
- public String getCluster() {
- return cluster;
- }
-
- public void setCluster(String cluster) {
- this.cluster = cluster;
- }
-
- public String getGroup() {
- return group;
- }
-
- public void setGroup(String group) {
- this.group = group;
- }
-
- public String getStatus() {
- return status;
- }
-
- public void setStatus(String status) {
- this.status = status;
- }
-
- public boolean isComplete() {
- return complete;
- }
-
- public void setComplete(boolean complete) {
- this.complete = complete;
- }
-
- public String[] getPartitions() {
- return partitions;
- }
-
- public void setPartitions(String[] partitions) {
- this.partitions = partitions;
- }
-
- public Integer getPartitionCount() {
- return partitionCount;
- }
-
- public void setPartitionCount(Integer partitionCount) {
- this.partitionCount = partitionCount;
- }
-
- public Integer getMaxlag() {
- return maxlag;
- }
-
- public void setMaxlag(Integer maxlag) {
- this.maxlag = maxlag;
- }
-
- public Integer getTotallag() {
- return totallag;
- }
-
- public void setTotallag(Integer totallag) {
- this.totallag = totallag;
- }
-}
diff --git a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerGroupStatusInfo.java b/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerGroupStatusInfo.java
deleted file mode 100644
index 7841092138..0000000000
--- a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerGroupStatusInfo.java
+++ /dev/null
@@ -1,39 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.client.monitoring.pipeline;
-
-public class BurrowConsumerGroupStatusInfo extends AbstractBurrowInfo {
-
- private BurrowConsumerGroupStatus status;
-
- public BurrowConsumerGroupStatusInfo(String error, String message) {
- super(error, message);
- }
-
- public BurrowConsumerGroupStatusInfo() {
- }
-
- public BurrowConsumerGroupStatus getStatus() {
- return status;
- }
-
- public void setStatus(BurrowConsumerGroupStatus status) {
- this.status = status;
- }
-}
diff --git a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerInfo.java b/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerInfo.java
deleted file mode 100644
index d345beb63b..0000000000
--- a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowConsumerInfo.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.client.monitoring.pipeline;
-
-public class BurrowConsumerInfo extends AbstractBurrowInfo {
-
- private String[] consumers;
-
- public BurrowConsumerInfo(String error, String message, String[] consumers) {
- super(error, message);
- this.consumers = consumers;
- }
-
- public BurrowConsumerInfo(String[] consumers) {
- this.consumers = consumers;
- }
-
- public BurrowConsumerInfo() {
-
- }
-
- public String[] getConsumers() {
- return consumers;
- }
-
- public void setConsumers(String[] consumers) {
- this.consumers = consumers;
- }
-}
diff --git a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowTopicInfo.java b/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowTopicInfo.java
deleted file mode 100644
index 4a69e15dcc..0000000000
--- a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/BurrowTopicInfo.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.client.monitoring.pipeline;
-
-public class BurrowTopicInfo extends AbstractBurrowInfo {
-
- private Long[] offsets;
-
- public BurrowTopicInfo(String error, String message, Long[] offsets) {
- super(error, message);
- this.offsets = offsets;
- }
-
- public BurrowTopicInfo() {
- }
-
- public Long[] getOffsets() {
- return offsets;
- }
-
- public void setOffsets(Long[] offsets) {
- this.offsets = offsets;
- }
-}
diff --git a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/PipelineExecutionStatus.java b/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/PipelineExecutionStatus.java
deleted file mode 100644
index 0ad6928c80..0000000000
--- a/streampipes-model-client/src/main/java/org/apache/streampipes/model/client/monitoring/pipeline/PipelineExecutionStatus.java
+++ /dev/null
@@ -1,25 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.model.client.monitoring.pipeline;
-
-public class PipelineExecutionStatus {
-
- private String pipelineId;
- private String test;
-}