Package | Description |
---|---|
org.nuxeo.lib.stream.log |
The Log interface with Chronicle and Kafka implementation.
|
org.nuxeo.lib.stream.log.chronicle | |
org.nuxeo.lib.stream.log.internals | |
org.nuxeo.lib.stream.log.kafka | |
org.nuxeo.lib.stream.tools.command |
Modifier and Type | Field and Description |
---|---|
protected LogOffset |
LogRecord.offset |
Modifier and Type | Method and Description |
---|---|
LogOffset |
LogAppender.append(int partition,
M message)
Append a message into a partition, returns
LogOffset position of the message. |
default LogOffset |
LogAppender.append(String key,
M message)
Same as
LogAppender.append(int, Externalizable) , the queue is chosen using a hash of . |
LogOffset |
LogTailer.commit(LogPartition partition)
Commit current position for the partition.
|
LogOffset |
LogOffset.nextOffset()
Returns the next offset corresponding to the next position in the same partition.
|
LogOffset |
LogRecord.offset() |
LogOffset |
LogTailer.offsetForTimestamp(LogPartition partition,
long timestamp)
Look up the offset for the given partition by timestamp.
|
Modifier and Type | Method and Description |
---|---|
void |
LogTailer.seek(LogOffset offset)
Set the current position for a single partition.
|
boolean |
LogAppender.waitFor(LogOffset offset,
String group,
Duration timeout)
Wait for consumer to process a message up to the offset.
|
Constructor and Description |
---|
LogRecord(M message,
LogOffset offset) |
Modifier and Type | Method and Description |
---|---|
LogOffset |
ChronicleLogAppender.append(int partition,
M message) |
LogOffset |
ChronicleLogTailer.commit(LogPartition partition) |
LogOffset |
ChronicleCompoundLogTailer.commit(LogPartition partition) |
LogOffset |
ChronicleLogTailer.offsetForTimestamp(LogPartition partition,
long timestamp) |
LogOffset |
ChronicleCompoundLogTailer.offsetForTimestamp(LogPartition partition,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
ChronicleLogTailer.seek(LogOffset offset) |
void |
ChronicleCompoundLogTailer.seek(LogOffset offset) |
boolean |
ChronicleLogAppender.waitFor(LogOffset offset,
String group,
Duration timeout) |
Modifier and Type | Class and Description |
---|---|
class |
LogOffsetImpl |
Modifier and Type | Method and Description |
---|---|
LogOffset |
LogOffsetImpl.nextOffset() |
Modifier and Type | Method and Description |
---|---|
int |
LogOffsetImpl.compareTo(LogOffset o) |
Modifier and Type | Method and Description |
---|---|
LogOffset |
KafkaLogAppender.append(int partition,
M message) |
LogOffset |
KafkaLogAppender.append(int partition,
String key,
M message) |
LogOffset |
KafkaLogAppender.append(String key,
M message) |
LogOffset |
KafkaLogTailer.commit(LogPartition partition) |
LogOffset |
KafkaLogTailer.offsetForTimestamp(LogPartition partition,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaLogTailer.seek(LogOffset offset) |
boolean |
KafkaLogAppender.waitFor(LogOffset offset,
String group,
Duration timeout) |
Modifier and Type | Method and Description |
---|---|
protected LogOffset |
RestoreCommand.findOffset(LogManager manager,
LogPartitionGroup key,
Latency latency) |
protected LogOffset |
PositionCommand.searchWatermarkOffset(LogTailer<Record> tailer,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
protected Map<LogPartitionGroup,LogOffset> |
RestoreCommand.searchOffsets(LogManager manager,
Map<LogPartitionGroup,Latency> latencies) |
Modifier and Type | Method and Description |
---|---|
protected void |
RestoreCommand.updatePosition(LogManager manager,
LogPartitionGroup key,
LogOffset offset) |
Modifier and Type | Method and Description |
---|---|
protected void |
RestoreCommand.updatePositions(LogManager manager,
Map<LogPartitionGroup,LogOffset> offsets) |
Copyright © 2018 Nuxeo. All rights reserved.