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

Class RestoreCommand

java.lang.Object

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

org.nuxeo.lib.stream.tools.command.RestoreCommand

public class RestoreCommand
extends Command

Restore consumer positions using the latency tracker Log.

Since:

10.1

Field Summary

Fields

Modifier and Type	Field	Description
protected String	codec
protected long	date
protected boolean	dryRun
protected static Name	GROUP
protected Name	input
protected List<Name>	logNames
protected static String	NAME
protected boolean	verbose

Constructor Summary

Constructors

Constructor	Description
RestoreCommand()

Method Summary

Modifier and Type	Method	Description
protected Latency	decodeLatency(byte[] data)
protected LogOffset	findOffset(LogManager manager, LogPartitionGroup key, Latency latency)
protected List<Name>	getLogNames(LogManager manager, String names)
String	name()
protected Map<LogPartitionGroup,Latency>	readLatencies(LogManager manager)
protected boolean	restorePosition(LogManager manager)
boolean	run(LogManager manager, org.apache.commons.cli.CommandLine cmd)
protected Map<LogPartitionGroup,LogOffset>	searchOffsets(LogManager manager, Map<LogPartitionGroup,Latency> latencies)
void	updateOptions(org.apache.commons.cli.Options options)
protected void	updatePosition(LogManager manager, LogPartitionGroup key, LogOffset offset)
protected void	updatePositions(LogManager manager, Map<LogPartitionGroup,LogOffset> offsets)

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

GROUP

protected static final Name GROUP

verbose

protected boolean verbose

input

protected Name input

logNames

protected List<Name> logNames

date

protected long date

dryRun

protected boolean dryRun

codec

protected String codec

Constructor Detail

RestoreCommand

public RestoreCommand()

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)
            throws InterruptedException

Specified by:

run in class Command

Throws:

InterruptedException

restorePosition

protected boolean restorePosition(LogManager manager)
                           throws InterruptedException

Throws:

InterruptedException

updatePositions

protected void updatePositions(LogManager manager,
                               Map<LogPartitionGroup,LogOffset> offsets)

updatePosition

protected void updatePosition(LogManager manager,
                              LogPartitionGroup key,
                              LogOffset offset)

searchOffsets

protected Map<LogPartitionGroup,LogOffset> searchOffsets(LogManager manager,
                                                               Map<LogPartitionGroup,Latency> latencies)
                                                        throws InterruptedException

Throws:

InterruptedException

findOffset

protected LogOffset findOffset(LogManager manager,
                               LogPartitionGroup key,
                               Latency latency)
                        throws InterruptedException

Throws:

InterruptedException

readLatencies

protected Map<LogPartitionGroup,Latency> readLatencies(LogManager manager)
                                                      throws InterruptedException

Throws:

InterruptedException

decodeLatency

protected Latency decodeLatency(byte[] data)

getLogNames

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