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 In-Memory and Kafka implementation.
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.tools.command
org.nuxeo.runtime.stream

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

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

Modifier and Type	Method	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	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	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)	Deprecated. since 11.1 use LogManager.getLatencyPerPartition(Name, Name, Codec, Function, Function) instead
default <M extends Externalizable> Latency	LogManager.getLatency(Name name, Name group, Codec<M> codec, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor)	Returns the latency between consumer group and producers for a Log.
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	Description
default <M extends Externalizable> List<Latency>	LogManager.getLatencyPerPartition(String name, String group, Codec<M> codec, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor)	Deprecated. since 11.1 use LogManager.getLatencyPerPartition(Name, Name, Codec, Function, Function) instead
<M extends Externalizable> List<Latency>	LogManager.getLatencyPerPartition(Name name, Name group, Codec<M> codec, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor)	Returns the lag with latency.
<M extends Externalizable> List<Latency>	UnifiedLogManager.getLatencyPerPartition(Name name, Name group, Codec<M> codec, Function<M,Long> timestampExtractor, Function<M,String> keyExtractor)

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

Modifier and Type	Method	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	Description
<M extends Externalizable> List<Latency>	AbstractLogManager.getLatencyPerPartition(Name name, Name 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	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	Description
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	Description
protected byte[]	LatencyTrackerComputation.encodeLatency(Latency latency)
protected LogOffset	RestoreCommand.findOffset(LogManager manager, LogPartitionGroup key, Latency latency)
protected void	LatencyDatadogComputation.publishMetrics(Latency latency, String prefix, String partition, Name stream, Name group)
protected void	LatencyMonitorComputation.publishMetrics(Latency latency, String prefix)

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

Modifier and Type	Method	Description
protected void	LatencyDatadogComputation.processLatencies(ComputationContext context, LogPartitionGroup logGroup, List<Latency> latencies)
protected void	LatencyMonitorComputation.processLatencies(ComputationContext context, LogPartitionGroup logGroup, List<Latency> latencies)
protected void	LatencyTrackerComputation.processLatencies(ComputationContext context, LogPartitionGroup logGroup, List<Latency> latencies)
protected void	LatencyCommand.renderLatency(Name group, List<Latency> latencies)
protected Map<LogPartitionGroup,LogOffset>	RestoreCommand.searchOffsets(LogManager manager, Map<LogPartitionGroup,Latency> latencies)

Uses of Latency in org.nuxeo.runtime.stream

Fields in org.nuxeo.runtime.stream declared as Latency

Modifier and Type	Field	Description
protected Latency	StreamMetricsComputation.LatencyMetric.latency