Class MonitorCommand
- java.lang.Object
-
- org.nuxeo.lib.stream.tools.command.Command
-
- org.nuxeo.lib.stream.tools.command.MonitorCommand
-
- Direct Known Subclasses:
DatadogCommand
public class MonitorCommand extends Command
Monitors consumer latencies to graphite- Since:
- 10.3
-
-
Field Summary
Fields Modifier and Type Field 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<Name>
logNames
protected static String
NAME
protected boolean
partition
protected int
port
protected String
prefix
protected StreamProcessor
processor
protected Topology
topology
protected boolean
udp
protected boolean
verbose
-
Constructor Summary
Constructors Constructor Description MonitorCommand()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getDefaultPrefix()
protected List<Name>
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
-
-
-
-
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
-
partition
protected boolean partition
-
interval
protected int interval
-
count
protected int count
-
topology
protected Topology topology
-
processor
protected StreamProcessor processor
-
codec
protected String codec
-
host
protected String host
-
port
protected int port
-
udp
protected boolean udp
-
prefix
protected String prefix
-
-
Method Detail
-
updateOptions
public void updateOptions(org.apache.commons.cli.Options options)
- Specified by:
updateOptions
in classCommand
-
run
public boolean run(LogManager manager, org.apache.commons.cli.CommandLine cmd)
-
getLogNames
protected List<Name> getLogNames(LogManager manager, String names)
-
initTopology
protected void initTopology(LogManager manager)
-
getDefaultPrefix
public String getDefaultPrefix()
-
runProcessor
protected boolean runProcessor(LogManager manager)
-
-