Package org.nuxeo.runtime.stream
Class StreamMetricsProcessor
java.lang.Object
org.nuxeo.runtime.stream.StreamMetricsProcessor
- All Implemented Interfaces:
StreamProcessorTopology
A processor fetching stream metrics populating Dropwizard metrics.
- Since:
- 11.1
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptiongetTopology
(Map<String, String> options) Returns a Stream computation topology.parseInputStreams
(String streams)
-
Field Details
-
DEFAULT_INTERVAL
-
STREAM_METRICS_FETCH_INTERVAL
- See Also:
-
STREAM_METRICS_LIST
- See Also:
-
-
Constructor Details
-
StreamMetricsProcessor
public StreamMetricsProcessor()
-
-
Method Details
-
getTopology
Description copied from interface:StreamProcessorTopology
Returns a Stream computation topology.- Specified by:
getTopology
in interfaceStreamProcessorTopology
-
parseInputStreams
-