| 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.