Uses of Class
org.nuxeo.lib.stream.log.Latency

Packages that use Latency

Package	Description
org.nuxeo.lib.stream.computation	The Computation pattern with a Log implementation.
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.log	The Log interface with Chronicle and Kafka implementation.
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.tools.command

Uses of Latency in org.nuxeo.lib.stream.computation

Methods in org.nuxeo.lib.stream.computation that return Latency

Modifier and Type	Method and Description
Latency	StreamProcessor.getLatency(String computationName) Returns the latency for a computation.

Uses of Latency in org.nuxeo.lib.stream.computation.log

Methods in org.nuxeo.lib.stream.computation.log that return Latency

Modifier and Type	Method and Description
Latency	LogStreamProcessor.getLatency(String computationName)

Uses of Latency in org.nuxeo.lib.stream.log

Methods in org.nuxeo.lib.stream.log that return Latency

Modifier and Type	Method and Description
static Latency	Latency.fromJson(String json)
default <M extends Externalizable> Latency	LogManager.getLatency(String name, String group, Codec<M> codec, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor) Returns the latency between consumer group and producers for a Log.
default <M extends Externalizable> Latency	LogManager.getLatency(String name, String group, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor) Deprecated. 10.2 use LogManager.getLatency(String, String, Codec, Function, Function) instead.
static Latency	Latency.noLatency(long upper, LogLag lag)
static Latency	Latency.of(List<Latency> latencies)

Methods in org.nuxeo.lib.stream.log that return types with arguments of type Latency

Modifier and Type	Method and Description
<M extends Externalizable> List<Latency>	LogManager.getLatencyPerPartition(String name, String group, Codec<M> codec, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor) Returns the lag with latency.
default <M extends Externalizable> List<Latency>	LogManager.getLatencyPerPartition(String name, String group, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor) Deprecated. 10.2 use LogManager.getLatencyPerPartition(String, String, Codec, Function, Function) instead.

Method parameters in org.nuxeo.lib.stream.log with type arguments of type Latency

Modifier and Type	Method and Description
static Latency	Latency.of(List<Latency> latencies)

Uses of Latency in org.nuxeo.lib.stream.log.internals

Methods in org.nuxeo.lib.stream.log.internals that return types with arguments of type Latency

Modifier and Type	Method and Description
<M extends Externalizable> List<Latency>	AbstractLogManager.getLatencyPerPartition(String name, String group, Codec<M> codec, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor)

Uses of Latency in org.nuxeo.lib.stream.tools.command

Methods in org.nuxeo.lib.stream.tools.command that return Latency

Modifier and Type	Method and Description
protected Latency	RestoreCommand.decodeLatency(byte[] data)

Methods in org.nuxeo.lib.stream.tools.command that return types with arguments of type Latency

Modifier and Type	Method and Description
protected List<Latency>	LatencyTrackerComputation.getLatenciesForPartition(LogPartitionGroup logGroup, Codec<Record> codec)
protected Map<LogPartitionGroup,Latency>	RestoreCommand.readLatencies(LogManager manager)

Methods in org.nuxeo.lib.stream.tools.command with parameters of type Latency

Modifier and Type	Method and Description
protected byte[]	LatencyTrackerComputation.encodeLatency(Latency latency)
protected LogOffset	RestoreCommand.findOffset(LogManager manager, LogPartitionGroup key, Latency latency)

Method parameters in org.nuxeo.lib.stream.tools.command with type arguments of type Latency

Modifier and Type	Method and Description
protected void	LatencyCommand.renderLatency(String group, List<Latency> latencies)
protected Map<LogPartitionGroup,LogOffset>	RestoreCommand.searchOffsets(LogManager manager, Map<LogPartitionGroup,Latency> latencies)