http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatusDTO.java deleted file mode 100644 index 387cce5..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ConnectionStatusDTO.java +++ /dev/null @@ -1,198 +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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; - -/** - * DTO for serializing the status of a connection. - */ -@XmlType(name = "connectionStatus") -public class ConnectionStatusDTO { - - private String id; - private String groupId; - private String name; - private String input; - private String queuedCount; - private String queuedSize; - private String queued; - private String output; - - private String sourceId; - private String sourceName; - private String destinationId; - private String destinationName; - - /* getters / setters */ - /** - * The id for the connection. - * - * @return The connection id - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The ID of the Process Group to which this processor belongs. - * - * @return the ID of the Process Group to which this processor belongs. - */ - public String getGroupId() { - return groupId; - } - - public void setGroupId(final String groupId) { - this.groupId = groupId; - } - - /** - * The name of this connection. - * - * @return - */ - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - /** - * The total count of flow files that are queued. - * - * @return - */ - public String getQueuedCount() { - return queuedCount; - } - - public void setQueuedCount(String queuedCount) { - this.queuedCount = queuedCount; - } - - /** - * The total size of flow files that are queued. - * - * @return - */ - public String getQueuedSize() { - return queuedSize; - } - - public void setQueuedSize(String queuedSize) { - this.queuedSize = queuedSize; - } - - /** - * The total count and size of flow files that are queued. - * - * @return The total count and size of queued flow files - */ - public String getQueued() { - return queued; - } - - public void setQueued(String queued) { - this.queued = queued; - } - - /** - * The id of the source of this connection. - * - * @return - */ - public String getSourceId() { - return sourceId; - } - - public void setSourceId(String sourceId) { - this.sourceId = sourceId; - } - - /** - * The name of the source of this connection. - * - * @return - */ - public String getSourceName() { - return sourceName; - } - - public void setSourceName(String sourceName) { - this.sourceName = sourceName; - } - - /** - * The id of the destination of this connection. - * - * @return - */ - public String getDestinationId() { - return destinationId; - } - - public void setDestinationId(String destinationId) { - this.destinationId = destinationId; - } - - /** - * The name of the destination of this connection. - * - * @return - */ - public String getDestinationName() { - return destinationName; - } - - public void setDestinationName(String destinationName) { - this.destinationName = destinationName; - } - - /** - * The input for this connection. - * - * @return - */ - public String getInput() { - return input; - } - - public void setInput(String input) { - this.input = input; - } - - /** - * The output for this connection. - * - * @return - */ - public String getOutput() { - return output; - } - - public void setOutput(String output) { - this.output = output; - } - -}
http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ControllerStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ControllerStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ControllerStatusDTO.java deleted file mode 100644 index 9e063e4..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ControllerStatusDTO.java +++ /dev/null @@ -1,187 +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.nifi.web.api.dto.status; - -import java.util.List; -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.BulletinDTO; - -/** - * The status of this NiFi controller. - */ -@XmlType(name = "controllerStatus") -public class ControllerStatusDTO { - - private Integer activeThreadCount; - private String queued; - private String connectedNodes; - private Boolean hasPendingAccounts; - - private Integer runningCount; - private Integer stoppedCount; - private Integer invalidCount; - private Integer disabledCount; - private Integer activeRemotePortCount; - private Integer inactiveRemotePortCount; - - private List<BulletinDTO> bulletins; - - /** - * The active thread count. - * - * @return The active thread count - */ - public Integer getActiveThreadCount() { - return activeThreadCount; - } - - public void setActiveThreadCount(Integer activeThreadCount) { - this.activeThreadCount = activeThreadCount; - } - - /** - * The queue for the controller. - * - * @return - */ - public String getQueued() { - return queued; - } - - public void setQueued(String queued) { - this.queued = queued; - } - - /** - * Used in clustering, will report the number of nodes connected vs the - * number of nodes in the cluster. - * - * @return - */ - public String getConnectedNodes() { - return connectedNodes; - } - - public void setConnectedNodes(String connectedNodes) { - this.connectedNodes = connectedNodes; - } - - /** - * System bulletins to be reported to the user. - * - * @return - */ - public List<BulletinDTO> getBulletins() { - return bulletins; - } - - public void setBulletins(List<BulletinDTO> bulletins) { - this.bulletins = bulletins; - } - - /** - * Whether or not there are pending user requests. - * - * @return - */ - public Boolean getHasPendingAccounts() { - return hasPendingAccounts; - } - - public void setHasPendingAccounts(Boolean hasPendingAccounts) { - this.hasPendingAccounts = hasPendingAccounts; - } - - /** - * The number of running components in this controller. - * - * @return - */ - public Integer getRunningCount() { - return runningCount; - } - - public void setRunningCount(Integer runningCount) { - this.runningCount = runningCount; - } - - /** - * The number of stopped components in this controller. - * - * @return - */ - public Integer getStoppedCount() { - return stoppedCount; - } - - public void setStoppedCount(Integer stoppedCount) { - this.stoppedCount = stoppedCount; - } - - /** - * The number of invalid components in this controller. - * - * @return - */ - public Integer getInvalidCount() { - return invalidCount; - } - - public void setInvalidCount(Integer invalidCount) { - this.invalidCount = invalidCount; - } - - /** - * The number of disabled components in this controller. - * - * @return - */ - public Integer getDisabledCount() { - return disabledCount; - } - - public void setDisabledCount(Integer disabledCount) { - this.disabledCount = disabledCount; - } - - /** - * The number of active remote ports in this controller. - * - * @return - */ - public Integer getActiveRemotePortCount() { - return activeRemotePortCount; - } - - public void setActiveRemotePortCount(Integer activeRemotePortCount) { - this.activeRemotePortCount = activeRemotePortCount; - } - - /** - * The number of inactive remote ports in this controller. - * - * @return - */ - public Integer getInactiveRemotePortCount() { - return inactiveRemotePortCount; - } - - public void setInactiveRemotePortCount(Integer inactiveRemotePortCount) { - this.inactiveRemotePortCount = inactiveRemotePortCount; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeConnectionStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeConnectionStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeConnectionStatusDTO.java deleted file mode 100644 index f7cba44..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeConnectionStatusDTO.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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the connection status for a particular node. - */ -@XmlType(name = "nodeConnectionStatus") -public class NodeConnectionStatusDTO { - - private NodeDTO node; - private ConnectionStatusDTO connectionStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The connection's status. - * - * @return - */ - public ConnectionStatusDTO getConnectionStatus() { - return connectionStatus; - } - - public void setConnectionStatus(ConnectionStatusDTO connectionStatus) { - this.connectionStatus = connectionStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodePortStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodePortStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodePortStatusDTO.java deleted file mode 100644 index 93d89ac..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodePortStatusDTO.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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the port status for a particular node. - */ -@XmlType(name = "nodePortStatus") -public class NodePortStatusDTO { - - private NodeDTO node; - private PortStatusDTO portStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The port's status. - * - * @return - */ - public PortStatusDTO getPortStatus() { - return portStatus; - } - - public void setPortStatus(PortStatusDTO portStatus) { - this.portStatus = portStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeProcessorStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeProcessorStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeProcessorStatusDTO.java deleted file mode 100644 index afff4b1..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeProcessorStatusDTO.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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the processor status for a particular node. - */ -@XmlType(name = "nodeProcessorStatus") -public class NodeProcessorStatusDTO { - - private NodeDTO node; - private ProcessorStatusDTO processorStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The processor's status. - * - * @return - */ - public ProcessorStatusDTO getProcessorStatus() { - return processorStatus; - } - - public void setProcessorStatus(ProcessorStatusDTO processorStatus) { - this.processorStatus = processorStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeRemoteProcessGroupStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeRemoteProcessGroupStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeRemoteProcessGroupStatusDTO.java deleted file mode 100644 index 03923bf..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeRemoteProcessGroupStatusDTO.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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the remote process group status for a particular node. - */ -@XmlType(name = "nodeRemoteProcessGroupStatus") -public class NodeRemoteProcessGroupStatusDTO { - - private NodeDTO node; - private RemoteProcessGroupStatusDTO remoteProcessGroupStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The remote process group's status. - * - * @return - */ - public RemoteProcessGroupStatusDTO getRemoteProcessGroupStatus() { - return remoteProcessGroupStatus; - } - - public void setRemoteProcessGroupStatus(RemoteProcessGroupStatusDTO remoteProcessGroupStatus) { - this.remoteProcessGroupStatus = remoteProcessGroupStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusDTO.java deleted file mode 100644 index 03647cd..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusDTO.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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the node status. - */ -@XmlType(name = "nodeStatus") -public class NodeStatusDTO { - - private NodeDTO node; - private ProcessGroupStatusDTO controllerStatus; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The controller status. - * - * @return - */ - public ProcessGroupStatusDTO getControllerStatus() { - return controllerStatus; - } - - public void setControllerStatus(ProcessGroupStatusDTO controllerStatus) { - this.controllerStatus = controllerStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusHistoryDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusHistoryDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusHistoryDTO.java deleted file mode 100644 index c8b05f3..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/NodeStatusHistoryDTO.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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.NodeDTO; - -/** - * DTO for serializing the status history for a particular node. - */ -@XmlType(name = "nodeStatusHistory") -public class NodeStatusHistoryDTO { - - private NodeDTO node; - private StatusHistoryDTO statusHistory; - - /** - * The node. - * - * @return - */ - public NodeDTO getNode() { - return node; - } - - public void setNode(NodeDTO node) { - this.node = node; - } - - /** - * The processor status history. - * - * @return - */ - public StatusHistoryDTO getStatusHistory() { - return statusHistory; - } - - public void setStatusHistory(StatusHistoryDTO statusHistory) { - this.statusHistory = statusHistory; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/PortStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/PortStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/PortStatusDTO.java deleted file mode 100644 index c32efdb..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/PortStatusDTO.java +++ /dev/null @@ -1,142 +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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; - -/** - * The status for a port in this NiFi. - */ -@XmlType(name = "portStatus") -public class PortStatusDTO extends StatusDTO { - - private String id; - private String groupId; - private String name; - private Integer activeThreadCount; - private String input; - private String output; - private Boolean transmitting; - private String runStatus; - - /** - * Whether this port has incoming or outgoing connections to a remote NiFi. - * - * @return - */ - public Boolean isTransmitting() { - return transmitting; - } - - public void setTransmitting(Boolean transmitting) { - this.transmitting = transmitting; - } - - /** - * The active thread count for this port. - * - * @return - */ - public Integer getActiveThreadCount() { - return activeThreadCount; - } - - public void setActiveThreadCount(Integer activeThreadCount) { - this.activeThreadCount = activeThreadCount; - } - - /** - * The id of this port. - * - * @return - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The id of the group this port resides in. - * - * @return - */ - public String getGroupId() { - return groupId; - } - - public void setGroupId(String groupId) { - this.groupId = groupId; - } - - /** - * The name of this port. - * - * @return - */ - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - /** - * The run status of this port. - * - * @return - */ - public String getRunStatus() { - return runStatus; - } - - public void setRunStatus(String runStatus) { - this.runStatus = runStatus; - } - - /** - * The total count and size of flow files that have been accepted in the - * last five minutes. - * - * @return The total processed - */ - public String getInput() { - return input; - } - - public void setInput(String input) { - this.input = input; - } - - /** - * The total count and size of flow files that have been processed in the - * last five minutes. - * - * @return The total output - */ - public String getOutput() { - return output; - } - - public void setOutput(String output) { - this.output = output; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ProcessGroupStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ProcessGroupStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ProcessGroupStatusDTO.java deleted file mode 100644 index 4fa2b64..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ProcessGroupStatusDTO.java +++ /dev/null @@ -1,244 +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.nifi.web.api.dto.status; - -import java.util.Collection; -import java.util.Date; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimeAdapter; - -/** - * The status for a process group in this NiFi. - */ -@XmlType(name = "processGroupStatus") -public class ProcessGroupStatusDTO extends StatusDTO { - - private String id; - private String name; - private Collection<ConnectionStatusDTO> connectionStatus; - private Collection<ProcessorStatusDTO> processorStatus; - private Collection<ProcessGroupStatusDTO> processGroupStatus; - private Collection<RemoteProcessGroupStatusDTO> remoteProcessGroupStatus; - private Collection<PortStatusDTO> inputPortStatus; - private Collection<PortStatusDTO> outputPortStatus; - - private String input; - private String queued; - private String read; - private String written; - private String output; - private Integer activeThreadCount; - private Date statsLastRefreshed; - - /** - * The id for the process group. - * - * @return The id for the process group - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The name of this process group. - * - * @return - */ - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - /** - * The active thread count for this process group. - * - * @return - */ - public Integer getActiveThreadCount() { - return activeThreadCount; - } - - public void setActiveThreadCount(Integer activeThreadCount) { - this.activeThreadCount = activeThreadCount; - } - - /** - * The status of all connections in this process group. - * - * @return The status of all connections - */ - public Collection<ConnectionStatusDTO> getConnectionStatus() { - return connectionStatus; - } - - public void setConnectionStatus(Collection<ConnectionStatusDTO> connectionStatus) { - this.connectionStatus = connectionStatus; - } - - /** - * The status of all process groups in this process group. - * - * @return The status of all process groups - */ - public Collection<ProcessGroupStatusDTO> getProcessGroupStatus() { - return processGroupStatus; - } - - public void setProcessGroupStatus(Collection<ProcessGroupStatusDTO> processGroupStatus) { - this.processGroupStatus = processGroupStatus; - } - - /** - * The status of all remote process groups in this process group. - * - * @return The status of all remote process groups - */ - public Collection<RemoteProcessGroupStatusDTO> getRemoteProcessGroupStatus() { - return remoteProcessGroupStatus; - } - - public void setRemoteProcessGroupStatus(final Collection<RemoteProcessGroupStatusDTO> remoteProcessGroupStatus) { - this.remoteProcessGroupStatus = remoteProcessGroupStatus; - } - - /** - * The status of all processors in this process group. - * - * @return The status of all processors - */ - public Collection<ProcessorStatusDTO> getProcessorStatus() { - return processorStatus; - } - - public void setProcessorStatus(Collection<ProcessorStatusDTO> processorStatus) { - this.processorStatus = processorStatus; - } - - /** - * The status of all input ports in this process group. - * - * @return The status of all input ports - */ - public Collection<PortStatusDTO> getInputPortStatus() { - return inputPortStatus; - } - - public void setInputPortStatus(Collection<PortStatusDTO> inputPortStatus) { - this.inputPortStatus = inputPortStatus; - } - - /** - * The status of all output ports in this process group. - * - * @return The status of all output ports - */ - public Collection<PortStatusDTO> getOutputPortStatus() { - return outputPortStatus; - } - - public void setOutputPortStatus(Collection<PortStatusDTO> outputPortStatus) { - this.outputPortStatus = outputPortStatus; - } - - /** - * The output stats for this process group. - * - * @return The output stats - */ - public String getOutput() { - return output; - } - - public void setOutput(String output) { - this.output = output; - } - - /** - * The queued stats for this process group. - * - * @return The queued stats - */ - public String getQueued() { - return queued; - } - - public void setQueued(String queued) { - this.queued = queued; - } - - /** - * The read stats for this process group. - * - * @return The read stats - */ - public String getRead() { - return read; - } - - public void setRead(String read) { - this.read = read; - } - - /** - * The written stats for this process group. - * - * @return The written stats - */ - public String getWritten() { - return written; - } - - public void setWritten(String written) { - this.written = written; - } - - /** - * The input stats for this process group. - * - * @return The input stats - */ - public String getInput() { - return input; - } - - public void setInput(String input) { - this.input = input; - } - - /** - * When the status for this process group was calculated. - * - * @return The the status was calculated - */ - @XmlJavaTypeAdapter(TimeAdapter.class) - public Date getStatsLastRefreshed() { - return statsLastRefreshed; - } - - public void setStatsLastRefreshed(Date statsLastRefreshed) { - this.statsLastRefreshed = statsLastRefreshed; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ProcessorStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ProcessorStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ProcessorStatusDTO.java deleted file mode 100644 index 334adad..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/ProcessorStatusDTO.java +++ /dev/null @@ -1,203 +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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; - -/** - * DTO for serializing the status of a processor. - */ -@XmlType(name = "processorStatus") -public class ProcessorStatusDTO extends StatusDTO { - - private String id; - private String groupId; - private String name; - private String type; - private String runStatus; - - private String read; - private String written; - - private String input; - private String output; - - private String tasks; - private String tasksDuration; - private Integer activeThreadCount; - - /* getters / setters */ - /** - * The id for the processor. - * - * @return The processor id - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The name of the processor. - * - * @return The processor name - */ - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - /** - * The type of the processor. - * - * @return The processor type - */ - public String getType() { - return type; - } - - public void setType(String type) { - this.type = type; - } - - /** - * The run status of this processor. - * - * @return - */ - public String getRunStatus() { - return runStatus; - } - - public void setRunStatus(String runStatus) { - this.runStatus = runStatus; - } - - /** - * The total count and size of flow files that have been accepted in the - * last five minutes. - * - * @return The total processed - */ - public String getInput() { - return input; - } - - public void setInput(String input) { - this.input = input; - } - - /** - * The number of bytes read. - * - * @return - */ - public String getRead() { - return read; - } - - public void setRead(String read) { - this.read = read; - } - - /** - * The number of bytes written. - * - * @return - */ - public String getWritten() { - return written; - } - - public void setWritten(String written) { - this.written = written; - } - - /** - * The ID of the Process Group to which this processor belongs. - * - * @return the ID of the Process Group to which this processor belongs. - */ - public String getGroupId() { - return groupId; - } - - public void setGroupId(final String groupId) { - this.groupId = groupId; - } - - /** - * The total count and size of flow files that have been processed in the - * last five minutes. - * - * @return The total output - */ - public String getOutput() { - return output; - } - - public void setOutput(String output) { - this.output = output; - } - - /** - * The number of threads currently running for this Processor - * - * @return - */ - public Integer getActiveThreadCount() { - return activeThreadCount; - } - - public void setActiveThreadCount(Integer threadCount) { - this.activeThreadCount = threadCount; - } - - /** - * The number of task this connectable has had over the last 5 minutes. - * - * @return - */ - public String getTasks() { - return tasks; - } - - public void setTasks(String tasks) { - this.tasks = tasks; - } - - /** - * The total duration of all tasks for this connectable over the last 5 - * minutes. - * - * @return - */ - public String getTasksDuration() { - return tasksDuration; - } - - public void setTasksDuration(String tasksDuration) { - this.tasksDuration = tasksDuration; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/RemotePortStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/RemotePortStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/RemotePortStatusDTO.java deleted file mode 100644 index a8fcc9f..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/RemotePortStatusDTO.java +++ /dev/null @@ -1,98 +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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; - -/** - * The status of a Port on a remote NiFi instance. - */ -@XmlType(name = "remotePortStatus") -public class RemotePortStatusDTO { - - private String id; - private String connectionId; - private String name; - private Boolean running; - private Boolean exists; - - /** - * The id of the connection this remote port is connected to. - * - * @return - */ - public String getConnectionId() { - return connectionId; - } - - public void setConnectionId(String connectionId) { - this.connectionId = connectionId; - } - - /** - * The id of the remote port. - * - * @return - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The name of the remote port. - * - * @return - */ - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - /** - * Whether or not the remote port exists. - * - * @return - */ - public Boolean getExists() { - return exists; - } - - public void setExists(Boolean exists) { - this.exists = exists; - } - - /** - * Whether or not the remote port is running. - * - * @return - */ - public Boolean getRunning() { - return running; - } - - public void setRunning(Boolean running) { - this.running = running; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/RemoteProcessGroupStatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/RemoteProcessGroupStatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/RemoteProcessGroupStatusDTO.java deleted file mode 100644 index 363d4da..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/RemoteProcessGroupStatusDTO.java +++ /dev/null @@ -1,159 +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.nifi.web.api.dto.status; - -import java.util.List; -import javax.xml.bind.annotation.XmlType; - -/** - * The status of a remote process group in this NiFi. - */ -@XmlType(name = "remoteProcessGroupStatus") -public class RemoteProcessGroupStatusDTO extends StatusDTO { - - private String id; - private String groupId; - private String name; - private String targetUri; - private String transmissionStatus; - private Integer activeThreadCount; - - private List<String> authorizationIssues; - - private String sent; - private String received; - - /** - * The id for the remote process group. - * - * @return The id for the remote process group - */ - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id; - } - - /** - * The id of the group this remote process group is in. - * - * @return - */ - public String getGroupId() { - return groupId; - } - - public void setGroupId(String groupId) { - this.groupId = groupId; - } - - /** - * The URI of the target system. - * - * @return - */ - public String getTargetUri() { - return targetUri; - } - - public void setTargetUri(String targetUri) { - this.targetUri = targetUri; - } - - /** - * The name of this remote process group. - * - * @return - */ - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - /** - * The transmission status of this remote process group. - * - * @return - */ - public String getTransmissionStatus() { - return transmissionStatus; - } - - public void setTransmissionStatus(String transmissionStatus) { - this.transmissionStatus = transmissionStatus; - } - - /** - * The number of active threads. - * - * @return - */ - public Integer getActiveThreadCount() { - return activeThreadCount; - } - - public void setActiveThreadCount(Integer activeThreadCount) { - this.activeThreadCount = activeThreadCount; - } - - /** - * Returns any remote authorization issues for this remote process group. - * - * @return - */ - public List<String> getAuthorizationIssues() { - return authorizationIssues; - } - - public void setAuthorizationIssues(List<String> authorizationIssues) { - this.authorizationIssues = authorizationIssues; - } - - /** - * Formatted description of the amount of data sent to this remote process - * group. - * - * @return - */ - public String getSent() { - return sent; - } - - public void setSent(String sent) { - this.sent = sent; - } - - /** - * Formatted description of the amount of data received from this remote - * process group. - * - * @return - */ - public String getReceived() { - return received; - } - - public void setReceived(String received) { - this.received = received; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusDTO.java deleted file mode 100644 index e4e7a45..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusDTO.java +++ /dev/null @@ -1,43 +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.nifi.web.api.dto.status; - -import java.util.List; -import javax.xml.bind.annotation.XmlType; -import org.apache.nifi.web.api.dto.BulletinDTO; - -/** - * The status of a component in this NiFi. - */ -@XmlType(name = "status") -public abstract class StatusDTO { - - private List<BulletinDTO> bulletins; - - /** - * Bulletins for this component. - * - * @return - */ - public List<BulletinDTO> getBulletins() { - return bulletins; - } - - public void setBulletins(List<BulletinDTO> bulletins) { - this.bulletins = bulletins; - } -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO.java deleted file mode 100644 index a203e10..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusDescriptorDTO.java +++ /dev/null @@ -1,101 +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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; - -/** - * DTO for serializing a status descriptor. - */ -@XmlType(name = "statusDescriptor") -public class StatusDescriptorDTO { - - public enum Formatter { - - COUNT, - DURATION, - DATA_SIZE - }; - - private String field; - private String label; - private String description; - private String formatter; - - public StatusDescriptorDTO() { - } - - public StatusDescriptorDTO(final String field, final String label, final String description, final String formatter) { - this.field = field; - this.label = label; - this.description = description; - this.formatter = formatter; - } - - /** - * The name of this status field. - * - * @return - */ - public String getField() { - return field; - } - - public void setField(String field) { - this.field = field; - } - - /** - * The label of this status field. - * - * @return - */ - public String getLabel() { - return label; - } - - public void setLabel(String label) { - this.label = label; - } - - /** - * The description of this status field. - * - * @return - */ - public String getDescription() { - return description; - } - - public void setDescription(String description) { - this.description = description; - } - - /** - * The formatter for this descriptor. - * - * @return - */ - public String getFormatter() { - return formatter; - } - - public void setFormatter(String formatter) { - this.formatter = formatter; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDTO.java deleted file mode 100644 index 5b97c16..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDTO.java +++ /dev/null @@ -1,92 +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.nifi.web.api.dto.status; - -import java.util.Date; -import java.util.LinkedHashMap; -import java.util.List; -import javax.xml.bind.annotation.XmlType; -import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter; -import org.apache.nifi.web.api.dto.util.TimeAdapter; - -/** - * History status for a component in this NiFi. - */ -@XmlType(name = "statusHistory") -public class StatusHistoryDTO { - - private Date generated; - - private LinkedHashMap<String, String> details; - - private List<StatusDescriptorDTO> fieldDescriptors; - private List<StatusSnapshotDTO> statusSnapshots; - - /** - * When this status history was generated. - * - * @return - */ - @XmlJavaTypeAdapter(TimeAdapter.class) - public Date getGenerated() { - return generated; - } - - public void setGenerated(Date generated) { - this.generated = generated; - } - - /** - * The component details for this status history. - * - * @return - */ - public LinkedHashMap<String, String> getDetails() { - return details; - } - - public void setDetails(LinkedHashMap<String, String> details) { - this.details = details; - } - - /** - * Descriptors for each supported status field. - * - * @return - */ - public List<StatusDescriptorDTO> getFieldDescriptors() { - return fieldDescriptors; - } - - public void setFieldDescriptors(List<StatusDescriptorDTO> fieldDescriptors) { - this.fieldDescriptors = fieldDescriptors; - } - - /** - * The status snapshots. - * - * @return - */ - public List<StatusSnapshotDTO> getStatusSnapshots() { - return statusSnapshots; - } - - public void setStatusSnapshots(List<StatusSnapshotDTO> statusSnapshots) { - this.statusSnapshots = statusSnapshots; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDetailDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDetailDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDetailDTO.java deleted file mode 100644 index b9d16bb..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusHistoryDetailDTO.java +++ /dev/null @@ -1,56 +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.nifi.web.api.dto.status; - -import javax.xml.bind.annotation.XmlType; - -/** - * Detail of a status history metric. - */ -@XmlType(name = "statusHistoryDetail") -public class StatusHistoryDetailDTO { - - private String label; - private String value; - - /** - * The label for this status detail. - * - * @return - */ - public String getLabel() { - return label; - } - - public void setLabel(String label) { - this.label = label; - } - - /** - * The value for this status detail. - * - * @return - */ - public String getValue() { - return value; - } - - public void setValue(String value) { - this.value = value; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusSnapshotDTO.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusSnapshotDTO.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusSnapshotDTO.java deleted file mode 100644 index cc6894a..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/status/StatusSnapshotDTO.java +++ /dev/null @@ -1,58 +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.nifi.web.api.dto.status; - -import java.util.Date; -import java.util.Map; -import javax.xml.bind.annotation.XmlType; - -/** - * A snapshot of the status at a given time. - */ -@XmlType(name = "statusSnapshot") -public class StatusSnapshotDTO { - - private Date timestamp; - private Map<String, Long> statusMetrics; - - /** - * The timestamp of this snapshot. - * - * @return - */ - public Date getTimestamp() { - return timestamp; - } - - public void setTimestamp(Date timestamp) { - this.timestamp = timestamp; - } - - /** - * The status metrics. - * - * @return - */ - public Map<String, Long> getStatusMetrics() { - return statusMetrics; - } - - public void setStatusMetrics(Map<String, Long> statusMetrics) { - this.statusMetrics = statusMetrics; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/DateTimeAdapter.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/DateTimeAdapter.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/DateTimeAdapter.java deleted file mode 100644 index 46ba674..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/DateTimeAdapter.java +++ /dev/null @@ -1,47 +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.nifi.web.api.dto.util; - -import java.text.SimpleDateFormat; -import java.util.Date; -import java.util.Locale; -import java.util.TimeZone; - -import javax.xml.bind.annotation.adapters.XmlAdapter; - -/** - * XmlAdapter for (un)marshalling a date/time. - */ -public class DateTimeAdapter extends XmlAdapter<String, Date> { - - public static final String DEFAULT_DATE_TIME_FORMAT = "MM/dd/yyyy HH:mm:ss z"; - - @Override - public String marshal(Date date) throws Exception { - final SimpleDateFormat formatter = new SimpleDateFormat(DEFAULT_DATE_TIME_FORMAT, Locale.US); - formatter.setTimeZone(TimeZone.getDefault()); - return formatter.format(date); - } - - @Override - public Date unmarshal(String date) throws Exception { - final SimpleDateFormat parser = new SimpleDateFormat(DEFAULT_DATE_TIME_FORMAT, Locale.US); - parser.setTimeZone(TimeZone.getDefault()); - return parser.parse(date); - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/TimeAdapter.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/TimeAdapter.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/TimeAdapter.java deleted file mode 100644 index 100d6c1..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/TimeAdapter.java +++ /dev/null @@ -1,47 +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.nifi.web.api.dto.util; - -import java.text.SimpleDateFormat; -import java.util.Date; -import java.util.Locale; -import java.util.TimeZone; - -import javax.xml.bind.annotation.adapters.XmlAdapter; - -/** - * XmlAdapter for (un)marshalling a time. - */ -public class TimeAdapter extends XmlAdapter<String, Date> { - - public static final String DEFAULT_TIME_FORMAT = "HH:mm:ss z"; - - @Override - public String marshal(Date date) throws Exception { - final SimpleDateFormat formatter = new SimpleDateFormat(DEFAULT_TIME_FORMAT, Locale.US); - formatter.setTimeZone(TimeZone.getDefault()); - return formatter.format(date); - } - - @Override - public Date unmarshal(String date) throws Exception { - final SimpleDateFormat parser = new SimpleDateFormat(DEFAULT_TIME_FORMAT, Locale.US); - parser.setTimeZone(TimeZone.getDefault()); - return parser.parse(date); - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/TimestampAdapter.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/TimestampAdapter.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/TimestampAdapter.java deleted file mode 100644 index d182cf3..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/dto/util/TimestampAdapter.java +++ /dev/null @@ -1,47 +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.nifi.web.api.dto.util; - -import java.text.SimpleDateFormat; -import java.util.Date; -import java.util.Locale; -import java.util.TimeZone; - -import javax.xml.bind.annotation.adapters.XmlAdapter; - -/** - * XmlAdapter for (un)marshalling a date/time. - */ -public class TimestampAdapter extends XmlAdapter<String, Date> { - - public static final String DEFAULT_DATE_TIME_FORMAT = "MM/dd/yyyy HH:mm:ss.SSS z"; - - @Override - public String marshal(Date date) throws Exception { - final SimpleDateFormat formatter = new SimpleDateFormat(DEFAULT_DATE_TIME_FORMAT, Locale.US); - formatter.setTimeZone(TimeZone.getDefault()); - return formatter.format(date); - } - - @Override - public Date unmarshal(String date) throws Exception { - final SimpleDateFormat parser = new SimpleDateFormat(DEFAULT_DATE_TIME_FORMAT, Locale.US); - parser.setTimeZone(TimeZone.getDefault()); - return parser.parse(date); - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/AboutEntity.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/AboutEntity.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/AboutEntity.java deleted file mode 100644 index 36fc163..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/AboutEntity.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.nifi.web.api.entity; - -import javax.xml.bind.annotation.XmlRootElement; -import org.apache.nifi.web.api.dto.AboutDTO; - -/** - * A serialized representation of this class can be placed in the entity body of - * a request or response to or from the API. This particular entity holds a - * reference to a AboutDTO. - */ -@XmlRootElement(name = "aboutEntity") -public class AboutEntity extends Entity { - - private AboutDTO about; - - /** - * The AboutDTO that is being serialized. - * - * @return The AboutDTO object - */ - public AboutDTO getAbout() { - return about; - } - - public void setAbout(AboutDTO about) { - this.about = about; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ActionEntity.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ActionEntity.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ActionEntity.java deleted file mode 100644 index 1b2c0b6..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ActionEntity.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.nifi.web.api.entity; - -import javax.xml.bind.annotation.XmlRootElement; -import org.apache.nifi.web.api.dto.action.ActionDTO; - -/** - * A serialized representation of this class can be placed in the entity body of - * a request or response to or from the API. This particular entity holds a - * reference to an ActionDTO. - */ -@XmlRootElement(name = "actionEntity") -public class ActionEntity extends Entity { - - private ActionDTO action; - - /** - * The ActionDTO that is being serialized. - * - * @return The ActionDTO object - */ - public ActionDTO getAction() { - return action; - } - - public void setAction(ActionDTO action) { - this.action = action; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/AuthorityEntity.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/AuthorityEntity.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/AuthorityEntity.java deleted file mode 100644 index eed1305..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/AuthorityEntity.java +++ /dev/null @@ -1,60 +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.nifi.web.api.entity; - -import java.util.Set; - -import javax.xml.bind.annotation.XmlRootElement; - -/** - * A serialized representation of this class can be placed in the entity body of - * a response to the API. This particular entity holds a set of user - * authorities. - */ -@XmlRootElement(name = "authoritiesEntity") -public class AuthorityEntity extends Entity { - - private String userId; - private Set<String> authorities; - - /** - * The current user id. - * - * @return - */ - public String getUserId() { - return userId; - } - - public void setUserId(String userId) { - this.userId = userId; - } - - /** - * The set of authorities that are being serialized. - * - * @return - */ - public Set<String> getAuthorities() { - return authorities; - } - - public void setAuthorities(Set<String> authorities) { - this.authorities = authorities; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/BannerEntity.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/BannerEntity.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/BannerEntity.java deleted file mode 100644 index 594707a..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/BannerEntity.java +++ /dev/null @@ -1,46 +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.nifi.web.api.entity; - -import javax.xml.bind.annotation.XmlRootElement; - -import org.apache.nifi.web.api.dto.BannerDTO; - -/** - * A serialized representation of this class can be placed in the entity body of - * a request or response to or from the API. This particular entity holds a - * reference to a BannerDTO. - */ -@XmlRootElement(name = "bannersEntity") -public class BannerEntity extends Entity { - - private BannerDTO banners; - - /** - * The BannerDTO that is being serialized. - * - * @return The BannerDTO object - */ - public BannerDTO getBanners() { - return banners; - } - - public void setBanners(BannerDTO about) { - this.banners = about; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/BulletinBoardEntity.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/BulletinBoardEntity.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/BulletinBoardEntity.java deleted file mode 100644 index 4287893..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/BulletinBoardEntity.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.nifi.web.api.entity; - -import javax.xml.bind.annotation.XmlRootElement; -import org.apache.nifi.web.api.dto.BulletinBoardDTO; - -/** - * A serialized representation of this class can be placed in the entity body of - * a request or response to or from the API. This particular entity holds a - * reference to a BulletinBoardDTO. - */ -@XmlRootElement(name = "bulletinBoardEntity") -public class BulletinBoardEntity extends Entity { - - private BulletinBoardDTO messages; - - /** - * The BulletinBoardDTO that is being serialized. - * - * @return The BulletinBoardDTO object - */ - public BulletinBoardDTO getBulletinBoard() { - return messages; - } - - public void setBulletinBoard(BulletinBoardDTO messages) { - this.messages = messages; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ClusterConnectionStatusEntity.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ClusterConnectionStatusEntity.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ClusterConnectionStatusEntity.java deleted file mode 100644 index 732a4b7..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ClusterConnectionStatusEntity.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.nifi.web.api.entity; - -import javax.xml.bind.annotation.XmlRootElement; -import org.apache.nifi.web.api.dto.status.ClusterConnectionStatusDTO; - -/** - * A serialized representation of this class can be placed in the entity body of - * a request or response to or from the API. This particular entity holds a - * reference to a ClusterConnectionStatusDTO. - */ -@XmlRootElement(name = "clusterConnectionStatusEntity") -public class ClusterConnectionStatusEntity extends Entity { - - private ClusterConnectionStatusDTO clusterConnectionStatus; - - /** - * The ClusterConnectionStatusDTO that is being serialized. - * - * @return The ClusterConnectionStatusDTO object - */ - public ClusterConnectionStatusDTO getClusterConnectionStatus() { - return clusterConnectionStatus; - } - - public void setClusterConnectionStatus(ClusterConnectionStatusDTO clusterConnectionStatus) { - this.clusterConnectionStatus = clusterConnectionStatus; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/f6d9354b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ClusterEntity.java ---------------------------------------------------------------------- diff --git a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ClusterEntity.java b/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ClusterEntity.java deleted file mode 100644 index 8306b0f..0000000 --- a/nifi/nar-bundles/framework-bundle/framework/client-dto/src/main/java/org/apache/nifi/web/api/entity/ClusterEntity.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.nifi.web.api.entity; - -import javax.xml.bind.annotation.XmlRootElement; -import org.apache.nifi.web.api.dto.ClusterDTO; - -/** - * A serialized representation of this class can be placed in the entity body of - * a request or response to or from the API. This particular entity holds a - * reference to a ClusterDTO. - */ -@XmlRootElement(name = "clusterEntity") -public class ClusterEntity extends Entity { - - private ClusterDTO cluster; - - /** - * The ClusterDTO that is being serialized. - * - * @return The ClusterDTO object - */ - public ClusterDTO getCluster() { - return cluster; - } - - public void setCluster(ClusterDTO cluster) { - this.cluster = cluster; - } - -}