Package org.apache.nifi.util

Class MockEventAccess

java.lang.Object
org.apache.nifi.util.MockEventAccess
All Implemented Interfaces:
org.apache.nifi.reporting.EventAccess
public class MockEventAccess extends Object implements org.apache.nifi.reporting.EventAccess

  • Field Details

    • processGroupStatus

      private org.apache.nifi.controller.status.ProcessGroupStatus processGroupStatus

    • provenanceRecords

      private final List<org.apache.nifi.provenance.ProvenanceEventRecord> provenanceRecords

    • flowChanges

      private final List<org.apache.nifi.action.Action> flowChanges

    • processGroupStatusMap

      private final Map<String,org.apache.nifi.controller.status.ProcessGroupStatus> processGroupStatusMap

  • Constructor Details

    • MockEventAccess

      public MockEventAccess()

  • Method Details

    • setProcessGroupStatus

      public void setProcessGroupStatus(org.apache.nifi.controller.status.ProcessGroupStatus status)

    • setProcessGroupStatus

      public void setProcessGroupStatus(String groupId, org.apache.nifi.controller.status.ProcessGroupStatus status)

    • getControllerStatus

      public org.apache.nifi.controller.status.ProcessGroupStatus getControllerStatus()
      Specified by:
      getControllerStatus in interface org.apache.nifi.reporting.EventAccess

    • getGroupStatus

      public org.apache.nifi.controller.status.ProcessGroupStatus getGroupStatus(String groupId)
      Specified by:
      getGroupStatus in interface org.apache.nifi.reporting.EventAccess

    • getProvenanceEvents

      public List<org.apache.nifi.provenance.ProvenanceEventRecord> getProvenanceEvents(long firstEventId, int maxRecords) throws IOException
      Specified by:
      getProvenanceEvents in interface org.apache.nifi.reporting.EventAccess
      Throws:
      IOException

    • addProvenanceEvent

      public void addProvenanceEvent(org.apache.nifi.provenance.ProvenanceEventRecord record)

    • getProvenanceRepository

      public org.apache.nifi.provenance.ProvenanceEventRepository getProvenanceRepository()
      Specified by:
      getProvenanceRepository in interface org.apache.nifi.reporting.EventAccess

    • getFlowChanges

      public List<org.apache.nifi.action.Action> getFlowChanges(int firstActionId, int maxActions)
      Specified by:
      getFlowChanges in interface org.apache.nifi.reporting.EventAccess

    • addFlowChange

      public void addFlowChange(org.apache.nifi.action.Action action)

    • getTotalBytesRead

      public long getTotalBytesRead()
      Specified by:
      getTotalBytesRead in interface org.apache.nifi.reporting.EventAccess

    • getTotalBytesWritten

      public long getTotalBytesWritten()
      Specified by:
      getTotalBytesWritten in interface org.apache.nifi.reporting.EventAccess

    • getTotalBytesSent

      public long getTotalBytesSent()
      Specified by:
      getTotalBytesSent in interface org.apache.nifi.reporting.EventAccess

    • getTotalBytesReceived

      public long getTotalBytesReceived()
      Specified by:
      getTotalBytesReceived in interface org.apache.nifi.reporting.EventAccess

    • getProvenanceRepositoryStorageUsage

      public Map<String,org.apache.nifi.diagnostics.StorageUsage> getProvenanceRepositoryStorageUsage()
      Specified by:
      getProvenanceRepositoryStorageUsage in interface org.apache.nifi.reporting.EventAccess

    • getContentRepositoryStorageUsage

      public Map<String,org.apache.nifi.diagnostics.StorageUsage> getContentRepositoryStorageUsage()
      Specified by:
      getContentRepositoryStorageUsage in interface org.apache.nifi.reporting.EventAccess

    • getFlowFileRepositoryStorageUsage

      public org.apache.nifi.diagnostics.StorageUsage getFlowFileRepositoryStorageUsage()
      Specified by:
      getFlowFileRepositoryStorageUsage in interface org.apache.nifi.reporting.EventAccess