Package | Description |
---|---|
org.nuxeo.lib.stream.log.chronicle | |
org.nuxeo.lib.stream.log.internals | |
org.nuxeo.lib.stream.tools.command |
Modifier and Type | Field and Description |
---|---|
protected LogPartitionGroup |
ChronicleLogTailer.id |
Modifier and Type | Field and Description |
---|---|
protected static Set<LogPartitionGroup> |
ChronicleLogTailer.tailersId |
Modifier and Type | Field and Description |
---|---|
protected Map<LogPartitionGroup,LogTailer> |
AbstractLogManager.tailersAssignments |
Modifier and Type | Field and Description |
---|---|
protected List<LogPartitionGroup> |
LatencyTrackerComputation.logGroups |
Modifier and Type | Method and Description |
---|---|
static LogPartitionGroup |
LatencyTrackerComputation.decodeKey(String key) |
Modifier and Type | Method and Description |
---|---|
protected Map<LogPartitionGroup,Latency> |
RestoreCommand.readLatencies(LogManager manager) |
protected Map<LogPartitionGroup,LogOffset> |
RestoreCommand.searchOffsets(LogManager manager,
Map<LogPartitionGroup,Latency> latencies) |
Modifier and Type | Method and Description |
---|---|
static String |
LatencyTrackerComputation.encodeKey(LogPartitionGroup logGroup,
int partition) |
protected LogOffset |
RestoreCommand.findOffset(LogManager manager,
LogPartitionGroup key,
Latency latency) |
protected List<Latency> |
LatencyTrackerComputation.getLatenciesForPartition(LogPartitionGroup logGroup,
Codec<Record> codec) |
protected void |
RestoreCommand.updatePosition(LogManager manager,
LogPartitionGroup key,
LogOffset offset) |
Modifier and Type | Method and Description |
---|---|
protected Map<LogPartitionGroup,LogOffset> |
RestoreCommand.searchOffsets(LogManager manager,
Map<LogPartitionGroup,Latency> latencies) |
protected void |
RestoreCommand.updatePositions(LogManager manager,
Map<LogPartitionGroup,LogOffset> offsets) |
Copyright © 2019 Nuxeo. All rights reserved.