org.nuxeo.lib.stream.tools.command

Class MonitorCommand

java.lang.Object

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

org.nuxeo.lib.stream.tools.command.MonitorCommand

public class MonitorCommand
extends Command

Monitor consumer latencies to graphite

Since:

10.3

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	ALL_LOGS
protected String	codec
static String	COMPUTATION_NAME
protected int	count
protected static String	DEFAULT_COUNT
protected static String	DEFAULT_INTERVAL
protected static String	DEFAULT_PORT
protected String	host
static String	INPUT_STREAM
static String	INTERNAL_LOG_PREFIX
protected int	interval
protected List<String>	logNames
protected static String	NAME
protected String	output
protected int	port
protected String	prefix
protected LogStreamProcessor	processor
protected Topology	topology
protected boolean	udp
protected boolean	verbose

Constructor Summary

Constructors

Constructor and Description
MonitorCommand()

Method Summary

Modifier and Type	Method and Description
String	getDefaultPrefix()
protected List<String>	getLogNames(LogManager manager, String names)
protected void	initTopology(LogManager manager)
String	name()
boolean	run(LogManager manager, org.apache.commons.cli.CommandLine cmd)
protected boolean	runProcessor(LogManager manager)
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

COMPUTATION_NAME

public static final String COMPUTATION_NAME

See Also:

Constant Field Values

INPUT_STREAM

public static final String INPUT_STREAM

See Also:

Constant Field Values

INTERNAL_LOG_PREFIX

public static final String INTERNAL_LOG_PREFIX

See Also:

Constant Field Values

NAME

protected static final String NAME

See Also:

Constant Field Values

DEFAULT_INTERVAL

protected static final String DEFAULT_INTERVAL

See Also:

Constant Field Values

DEFAULT_COUNT

protected static final String DEFAULT_COUNT

See Also:

Constant Field Values

ALL_LOGS

protected static final String ALL_LOGS

See Also:

Constant Field Values

DEFAULT_PORT

protected static final String DEFAULT_PORT

See Also:

Constant Field Values

verbose

protected boolean verbose

output

protected String output

logNames

protected List<String> logNames

interval

protected int interval

count

protected int count

topology

protected Topology topology

processor

protected LogStreamProcessor processor

codec

protected String codec

host

protected String host

port

protected int port

udp

protected boolean udp

prefix

protected String prefix

Constructor Detail

MonitorCommand

public MonitorCommand()

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

getLogNames

protected List<String> getLogNames(LogManager manager,
                                   String names)

initTopology

protected void initTopology(LogManager manager)

getDefaultPrefix

public String getDefaultPrefix()

runProcessor

protected boolean runProcessor(LogManager manager)