Package org.nuxeo.lib.stream.tools.command

Class LatencyMonitorComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.lib.stream.tools.command.LatencyTrackerComputation

org.nuxeo.lib.stream.tools.command.LatencyMonitorComputation

All Implemented Interfaces:

Computation

public class LatencyMonitorComputation
extends LatencyTrackerComputation

A computation that sends periodically latencies to graphite.

Since:

10.3

Field Summary

Fields

Modifier and Type	Field	Description
protected String	basePrefix
protected io.dropwizard.metrics5.graphite.GraphiteSender	graphite
protected String	host
protected boolean	partition
protected int	port
protected boolean	udp

Fields inherited from class org.nuxeo.lib.stream.tools.command.LatencyTrackerComputation

codec, count, intervalMs, logGroups, logNames, manager, OUTPUT_STREAM, refreshGroupCounter, remaining, verbose

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

INPUT_1, INPUT_2, INPUT_3, INPUT_NULL, metadata, OUTPUT_1, OUTPUT_2, OUTPUT_3, OUTPUT_4

Constructor Summary

Constructors

Constructor	Description
LatencyMonitorComputation(LogManager manager, List<Name> logNames, String host, int port, boolean udp, String basePrefix, String computationName, int intervalSecond, int count, boolean partition, boolean verbose, Codec<Record> codec)
LatencyMonitorComputation(LogManager manager, List<Name> logNames, String host, int port, boolean udp, String basePrefix, String computationName, int intervalSecond, int count, boolean verbose, Codec<Record> codec)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	destroy()	Called when the framework is ready to shutdown the computation.
void	init(ComputationContext context)	Called when the framework has registered the computation successfully.
protected void	processLatencies(ComputationContext context, LogPartitionGroup logGroup, List<Latency> latencies)
protected void	publishMetrics(Latency latency, String prefix)

Methods inherited from class org.nuxeo.lib.stream.tools.command.LatencyTrackerComputation

decodeKey, encodeKey, encodeLatency, getLogGroup, processRecord, processTimer, refreshGroup

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

metadata, processFailure, processRetry

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.computation.Computation

signalStop

Field Detail

host

protected final String host

port

protected final int port

udp

protected final boolean udp

basePrefix

protected final String basePrefix

graphite

protected io.dropwizard.metrics5.graphite.GraphiteSender graphite

partition

protected final boolean partition

Constructor Detail

LatencyMonitorComputation

@Deprecated
public LatencyMonitorComputation(LogManager manager,
                                 List<Name> logNames,
                                 String host,
                                 int port,
                                 boolean udp,
                                 String basePrefix,
                                 String computationName,
                                 int intervalSecond,
                                 int count,
                                 boolean verbose,
                                 Codec<Record> codec)

Deprecated.

LatencyMonitorComputation

public LatencyMonitorComputation(LogManager manager,
                                 List<Name> logNames,
                                 String host,
                                 int port,
                                 boolean udp,
                                 String basePrefix,
                                 String computationName,
                                 int intervalSecond,
                                 int count,
                                 boolean partition,
                                 boolean verbose,
                                 Codec<Record> codec)

Method Detail

init

public void init(ComputationContext context)

Description copied from interface: Computation

Called when the framework has registered the computation successfully. Gives users a first opportunity to schedule timer callbacks and produce records. This method can be called multiple times.

Specified by:

init in interface Computation

Overrides:

init in class LatencyTrackerComputation

Parameters:

context - The computation context object provided by the system.

processLatencies

protected void processLatencies(ComputationContext context,
                                LogPartitionGroup logGroup,
                                List<Latency> latencies)

Overrides:

processLatencies in class LatencyTrackerComputation

publishMetrics

protected void publishMetrics(Latency latency,
                              String prefix)

destroy

public void destroy()

Description copied from interface: Computation

Called when the framework is ready to shutdown the computation. Gives users a chance to perform some cleanup before the process is killed.

Specified by:

destroy in interface Computation

Overrides:

destroy in class LatencyTrackerComputation