org.nuxeo.lib.stream.tools.command

Class LatencyCommand

java.lang.Object

org.nuxeo.lib.stream.tools.command.Command

org.nuxeo.lib.stream.tools.command.LatencyCommand

public class LatencyCommand
extends Command

Display the current latencies of consumers.

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	NAME
protected boolean	verbose

Constructor Summary

Constructors

Constructor and Description
LatencyCommand()

Method Summary

Modifier and Type	Method and Description
protected String	formatDate(long timestamp)
protected static String	formatInterval(long l)
protected void	latency(LogManager manager, Codec<Record> codec)
protected void	latency(LogManager manager, String name, Codec<Record> codec)
String	name()
protected void	renderLatency(String group, List<Latency> latencies)
boolean	run(LogManager manager, org.apache.commons.cli.CommandLine cmd)
void	updateOptions(org.apache.commons.cli.Options options)

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

getRecordCodec, getRecordRenderer

Methods inherited from class java.lang.Object

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

Field Detail

NAME

protected static final String NAME

See Also:

Constant Field Values

verbose

protected boolean verbose

Constructor Detail

LatencyCommand

public LatencyCommand()

Method Detail

name

public String name()

Specified by:

name in class Command

updateOptions

public void updateOptions(org.apache.commons.cli.Options options)

Specified by:

updateOptions in class Command

run

public boolean run(LogManager manager,
                   org.apache.commons.cli.CommandLine cmd)

Specified by:

run in class Command

latency

protected void latency(LogManager manager,
                       Codec<Record> codec)

latency

protected void latency(LogManager manager,
                       String name,
                       Codec<Record> codec)

renderLatency

protected void renderLatency(String group,
                             List<Latency> latencies)

formatDate

protected String formatDate(long timestamp)

formatInterval

protected static String formatInterval(long l)