NIFI-14176 Add runstate information to C2 FlowInfo

apache · Jan 20, 2025 · ab8a3c5 · ab8a3c5
1 parent 5cd52bb
commit ab8a3c5
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/...otocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/ProcessorStatus.java b/...otocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/ProcessorStatus.java
@@ -37,6 +37,7 @@ public class ProcessorStatus implements Serializable {
     private long processingNanos;
     private int activeThreadCount;
     private int terminatedThreadCount;
+    private String runState;
 
     @Schema(description = "The id of the processor")
     public String getId() {
@@ -145,4 +146,11 @@ public int getTerminatedThreadCount() {
     public void setTerminatedThreadCount(int terminatedThreadCount) {
         this.terminatedThreadCount = terminatedThreadCount;
     }
+
+    @Schema(description = "The state of the processor")
+    public String getRunState() { return runState; }
+
+    public void setRunState(String runState) {
+        this.runState = runState;
+    }
 }
diff --git a/...rk/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/C2NifiClientService.java b/...rk/minifi-framework-core/src/main/java/org/apache/nifi/minifi/c2/C2NifiClientService.java
@@ -406,6 +406,7 @@ private ProcessorStatus convertProcessorStatus(org.apache.nifi.controller.status
         result.setProcessingNanos(processorStatus.getProcessingNanos());
         result.setActiveThreadCount(processorStatus.getActiveThreadCount());
         result.setTerminatedThreadCount(processorStatus.getTerminatedThreadCount());
+        result.setRunState(processorStatus.getRunStatus().name());
         return result;
     }
 }