Class StreamObject

java.lang.Object
org.nuxeo.ecm.webengine.model.impl.AbstractResource<ResourceTypeImpl>
org.nuxeo.ecm.restapi.server.jaxrs.management.StreamObject
All Implemented Interfaces:
Resource, Adaptable

public class StreamObject extends AbstractResource<ResourceTypeImpl>
Nuxeo Stream Introspection endpoint
Since:
11.5
  • Field Details

  • Constructor Details

    • StreamObject

      public StreamObject()
  • Method Details

    • doGet

      public String doGet(String format)
    • doGetPuml

      @Deprecated public String doGetPuml()
      Deprecated.
      since 2022.21 use doGet(String) with format=puml instead.
    • listStreams

      public String listStreams()
    • listConsumers

      public String listConsumers(String stream)
    • stopConsumer

      public void stopConsumer(String consumer)
    • startConsumer

      public void startConsumer(String consumer)
    • getConsumerPosition

      public String getConsumerPosition(String consumer, String stream)
    • setConsumerPositionToEnd

      public String setConsumerPositionToEnd(String consumer, String stream)
    • positionChangeAsJson

      protected String positionChangeAsJson(String consumer, String stream, List<LogLag> before, List<LogLag> after)
    • setConsumerPositionToBeginning

      public String setConsumerPositionToBeginning(String consumer, String stream)
    • setConsumerPositionToOffset

      public String setConsumerPositionToOffset(String consumer, String stream, int partition, long offset)
    • setConsumerPositionAfterDate

      public String setConsumerPositionAfterDate(String consumer, String stream, String dateTime)
    • lagAsJson

      protected String lagAsJson(String consumer, String stream, List<LogLag> lags)
    • scale

      public String scale()
    • getJson

      protected String getJson()
    • getKvStore

      protected KeyValueStore getKvStore()
    • checkStreamMetricEnabled

      protected void checkStreamMetricEnabled()