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

Packages that use LogPartitionGroup

Package	Description
org.nuxeo.lib.stream.log.chronicle
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.chronicle

Fields in org.nuxeo.lib.stream.log.chronicle declared as LogPartitionGroup

Modifier and Type	Field	Description
protected LogPartitionGroup	ChronicleLogTailer.id

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

Modifier and Type	Field	Description
protected static Set<LogPartitionGroup>	ChronicleLogTailer.tailersId

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 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 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 LogPartitionGroup	StreamMetricsComputation.LatencyMetric.consumer

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

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

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