Uses of Class
org.nuxeo.lib.stream.log.internals.LogPartitionGroup

Packages that use LogPartitionGroup

Package	Description
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.tools.command
org.nuxeo.runtime.stream

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

Fields in org.nuxeo.lib.stream.log.internals with type parameters of type LogPartitionGroup

Modifier and Type	Field	Description
protected final Map<LogPartitionGroup,LogTailer>	AbstractLogManager.tailersAssignments

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

Fields in org.nuxeo.lib.stream.tools.command with type parameters of type LogPartitionGroup

Modifier and Type	Field	Description
protected final List<LogPartitionGroup>	LatencyTrackerComputation.logGroups

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

Modifier and Type	Method	Description
static LogPartitionGroup	LatencyTrackerComputation.decodeKey(String key)

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

Modifier and Type	Method	Description
protected List<LogPartitionGroup>	LatencyTrackerComputation.getLogGroup()
protected Map<LogPartitionGroup,Latency>	RestoreCommand.readLatencies(LogManager manager)
protected Map<LogPartitionGroup,LogOffset>	RestoreCommand.searchOffsets(LogManager manager, Map<LogPartitionGroup,Latency> latencies)

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

Modifier and Type	Method	Description
static String	LatencyTrackerComputation.encodeKey(LogPartitionGroup logGroup, int partition)
protected LogOffset	RestoreCommand.findOffset(LogManager manager, LogPartitionGroup key, Latency latency)
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	RestoreCommand.updatePosition(LogManager manager, LogPartitionGroup key, LogOffset offset)

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

Modifier and Type	Method	Description
protected Map<LogPartitionGroup,LogOffset>	RestoreCommand.searchOffsets(LogManager manager, Map<LogPartitionGroup,Latency> latencies)
protected void	RestoreCommand.updatePositions(LogManager manager, Map<LogPartitionGroup,LogOffset> offsets)

Uses of LogPartitionGroup in org.nuxeo.runtime.stream

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

Modifier and Type	Field	Description
protected final LogPartitionGroup	StreamMetricsComputation.LatencyMetric.consumer

Fields in org.nuxeo.runtime.stream with type parameters of type LogPartitionGroup

Modifier and Type	Field	Description
protected final List<LogPartitionGroup>	StreamMetricsComputation.groups

Methods in org.nuxeo.runtime.stream that return types with arguments of type LogPartitionGroup

Modifier and Type	Method	Description
protected List<LogPartitionGroup>	StreamMetricsComputation.getGroups()

Constructors in org.nuxeo.runtime.stream with parameters of type LogPartitionGroup

Modifier	Constructor	Description
	LatencyMetric(LogPartitionGroup consumer, io.dropwizard.metrics5.MetricRegistry registry)