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

Class TrackerCommand

java.lang.Object

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

org.nuxeo.lib.stream.tools.command.TrackerCommand

public class TrackerCommand
extends Command

Track consumer positions so they can be restored in case of fail-over

Since:

10.1

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_LATENCIES_LOG
static String	INPUT_STREAM
static String	INTERNAL_LOG_PREFIX
protected int	interval
protected List<Name>	logNames
protected static String	NAME
protected String	output
protected StreamProcessor	processor
protected Topology	topology
protected boolean	verbose

Constructor Summary

Constructors

Constructor	Description
TrackerCommand()

Method Summary

Modifier and Type	Method	Description
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

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_LATENCIES_LOG

protected static final String DEFAULT_LATENCIES_LOG

See Also:

Constant Field Values

verbose

protected boolean verbose

output

protected String output

logNames

protected List<Name> logNames

interval

protected int interval

count

protected int count

topology

protected Topology topology

processor

protected StreamProcessor processor

codec

protected String codec

Constructor Detail

TrackerCommand

public TrackerCommand()

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<Name> getLogNames(LogManager manager,
                                 String names)

initTopology

protected void initTopology(LogManager manager)

runProcessor

protected boolean runProcessor(LogManager manager)