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

Class LatencyDatadogComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

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

org.nuxeo.lib.stream.tools.command.LatencyDatadogComputation

All Implemented Interfaces:

Computation

public class LatencyDatadogComputation
extends LatencyTrackerComputation

A computation that sends periodically latencies to Datadog.

Since:

11.1

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	apiKey
protected final String	basePrefix
protected final String	hostname
protected static final String	HOSTNAME_UNKNOWN
protected final boolean	partition
protected final List<String>	tags
protected org.coursera.metrics.datadog.transport.HttpTransport	transport

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
LatencyDatadogComputation(LogManager manager, List<Name> logNames, String apiKey, List<String> tags, String basePrefix, String computationName, int intervalSecond, int count, boolean partition, boolean verbose, Codec<Record> codec)

Method Summary

Modifier and Type	Method	Description
void	destroy()	Called when the framework is ready to shutdown the computation.
protected String	getHostName()
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, String partition, Name stream, Name group)

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 Details

HOSTNAME_UNKNOWN

protected static final String HOSTNAME_UNKNOWN

See Also:

• Constant Field Values

apiKey

protected final String apiKey

tags

protected final List<String> tags

basePrefix

protected final String basePrefix

partition

protected final boolean partition

hostname

protected final String hostname

transport

protected org.coursera.metrics.datadog.transport.HttpTransport transport

Constructor Details

LatencyDatadogComputation

public LatencyDatadogComputation(LogManager manager,
 List<Name> logNames,
 String apiKey,
 List<String> tags,
 String basePrefix,
 String computationName,
 int intervalSecond,
 int count,
 boolean partition,
 boolean verbose,
 Codec<Record> codec)

Method Details

getHostName

protected String getHostName()

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,
 String partition,
 Name stream,
 Name group)

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