Package org.nuxeo.ecm.core.bulk.introspection

Class StreamIntrospectionConverter

java.lang.Object
org.nuxeo.ecm.core.bulk.introspection.StreamIntrospectionConverter
public class StreamIntrospectionConverter extends Object
Since:
11.5

  • Field Details

    • OBJECT_MAPPER

      protected static final com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER

    • ACTIVE_THRESHOLD_SECONDS

      protected static final long ACTIVE_THRESHOLD_SECONDS
      See Also:

    • ETA_THRESHOLD_SECONDS

      protected static final int ETA_THRESHOLD_SECONDS
      See Also:

    • BEST_ETA_THRESHOLD_SECONDS

      protected static final int BEST_ETA_THRESHOLD_SECONDS
      See Also:

    • EMPTY_JSON_ARRAY

      protected static final String EMPTY_JSON_ARRAY
      See Also:

    • json

      protected final String json

    • root

      protected final com.fasterxml.jackson.databind.JsonNode root

  • Constructor Details

    • StreamIntrospectionConverter

      public StreamIntrospectionConverter(String json)

  • Method Details

    • getStreams

      public String getStreams()

    • getConsumers

      public String getConsumers(String stream)

    • getPuml

      public String getPuml()

    • getD2

      public String getD2()

    • getD2

      public String getD2(List<String> excludePatterns, boolean excludeInactive)
      Gets the D2 diagram format with filtering options.
      Parameters:
      excludePatterns - list of patterns to exclude (e.g., Arrays.asList("work/", "bulk/"))
      excludeInactive - whether to exclude inactive computations (computation-idle class) and empty streams (stream-empty class)
      Returns:
      the D2 diagram as a string

    • getActivity

      public String getActivity()

    • getActivity

      public String getActivity(long atTimestamp)

    • getScaleMetrics

      protected com.fasterxml.jackson.databind.JsonNode getScaleMetrics(int workerCount, com.fasterxml.jackson.databind.node.ArrayNode computations)

    • getActiveComputations

      protected com.fasterxml.jackson.databind.JsonNode getActiveComputations(long atTimestamp)

    • initComputation

      protected com.fasterxml.jackson.databind.node.ObjectNode initComputation(String key)

    • getClusterNodes

      protected com.fasterxml.jackson.databind.JsonNode getClusterNodes(long atTimestamp)