Package org.nuxeo.ecm.restapi.server.jaxrs.management

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 Summary

Fields

Modifier and Type	Field	Description
protected static final String	D2_FORMAT
protected static final String	ENABLED_OPTION
protected static final String	NO_CONSUMER
protected static final String	PUML_FORMAT
protected static final Function<StreamIntrospection,ScaleActivity>	TO_SCALE_ACTIVITY

Fields inherited from class org.nuxeo.ecm.webengine.model.impl.AbstractResource

ctx, next, path, prev, type

Constructor Summary

Constructors

Constructor	Description
StreamObject()

Method Summary

Modifier and Type	Method	Description
protected void	checkStreamMetricEnabled()
javax.ws.rs.core.Response	doGet(String format, javax.ws.rs.core.HttpHeaders headers)
javax.ws.rs.core.Response	doGetPuml(javax.ws.rs.core.HttpHeaders headers)	Deprecated. since 2021.21 use doGet(String, HttpHeaders) with format=puml instead.
StreamLag	getConsumerPosition(String consumer, String stream)
protected KeyValueStore	getKvStore()
protected StreamIntrospection	getStreamIntrospection()
List<StreamIntrospection.ProcessorTopology>	listConsumers(String stream, RenderingContext renderingContext)
List<StreamIntrospection.Stream>	listStreams()
ScaleActivity	scale()
StreamLagChange	setConsumerPositionAfterDate(String consumer, String stream, String dateTime)
StreamLagChange	setConsumerPositionToBeginning(String consumer, String stream)
StreamLagChange	setConsumerPositionToEnd(String consumer, String stream)
StreamLagChange	setConsumerPositionToOffset(String consumer, String stream, int partition, long offset)
void	startConsumer(String consumer)
void	stopConsumer(String consumer)

Methods inherited from class org.nuxeo.ecm.webengine.model.impl.AbstractResource

checkGuard, dispose, getActiveAdapter, getAdapter, getContext, getFacets, getLinks, getModule, getName, getNext, getNextSegment, getPath, getPrevious, getTemplate, getTrailingPath, getType, getURL, getView, hasFacet, initialize, initialize, isAdapter, isInstanceOf, isRoot, newAdapter, newObject, redirect, setNext, setPrevious, setRoot, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

PUML_FORMAT

protected static final String PUML_FORMAT

See Also:

• Constant Field Values

D2_FORMAT

protected static final String D2_FORMAT

See Also:

• Constant Field Values

NO_CONSUMER

protected static final String NO_CONSUMER

See Also:

• Constant Field Values

ENABLED_OPTION

protected static final String ENABLED_OPTION

See Also:

• Constant Field Values

TO_SCALE_ACTIVITY

protected static final Function<StreamIntrospection,ScaleActivity> TO_SCALE_ACTIVITY

Constructor Details

StreamObject

public StreamObject()

Method Details

doGet

public javax.ws.rs.core.Response doGet(String format,
 @Context
 javax.ws.rs.core.HttpHeaders headers)

doGetPuml

@Deprecated
public javax.ws.rs.core.Response doGetPuml(@Context
 javax.ws.rs.core.HttpHeaders headers)

Deprecated.

since 2021.21 use doGet(String, HttpHeaders) with format=puml instead.

listStreams

public List<StreamIntrospection.Stream> listStreams()

listConsumers

public List<StreamIntrospection.ProcessorTopology> listConsumers(String stream,
 @Context
 RenderingContext renderingContext)

stopConsumer

public void stopConsumer(String consumer)

startConsumer

public void startConsumer(String consumer)

getConsumerPosition

public StreamLag getConsumerPosition(String consumer,
 String stream)

setConsumerPositionToEnd

public StreamLagChange setConsumerPositionToEnd(String consumer,
 String stream)

setConsumerPositionToBeginning

public StreamLagChange setConsumerPositionToBeginning(String consumer,
 String stream)

setConsumerPositionToOffset

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

setConsumerPositionAfterDate

public StreamLagChange setConsumerPositionAfterDate(String consumer,
 String stream,
 String dateTime)

scale

public ScaleActivity scale()

getStreamIntrospection

protected StreamIntrospection getStreamIntrospection()

getKvStore

protected KeyValueStore getKvStore()

checkStreamMetricEnabled

protected void checkStreamMetricEnabled()