| Package | Description |
|---|---|
| org.nuxeo.lib.stream.log.chronicle |
| Modifier and Type | Field and Description |
|---|---|
static ChronicleRetentionDuration |
ChronicleRetentionDuration.NONE |
protected ChronicleRetentionDuration |
ChronicleRetentionListener.retention |
protected ChronicleRetentionDuration |
ChronicleLogOffsetTracker.retention |
protected ChronicleRetentionDuration |
ChronicleLogManager.retention |
protected ChronicleRetentionDuration |
ChronicleLogAppender.retention |
| Modifier and Type | Method and Description |
|---|---|
static ChronicleRetentionDuration |
ChronicleRetentionDuration.disableOf(ChronicleRetentionDuration retention) |
ChronicleRetentionDuration |
ChronicleLogAppender.getRetention() |
| Modifier and Type | Method and Description |
|---|---|
static <M extends Externalizable> |
ChronicleLogAppender.create(Codec<M> codec,
File basePath,
int size,
ChronicleRetentionDuration retention)
Create a new log
|
static ChronicleRetentionDuration |
ChronicleRetentionDuration.disableOf(ChronicleRetentionDuration retention) |
protected Properties |
ChronicleLogAppender.guessMetadata(ChronicleRetentionDuration retention) |
static <M extends Externalizable> |
ChronicleLogAppender.open(Codec<M> codec,
File basePath,
ChronicleRetentionDuration retention)
Open an existing log.
|
| Constructor and Description |
|---|
ChronicleLogAppender(Codec<M> codec,
File basePath,
ChronicleRetentionDuration retention)
Open an existing Log
|
ChronicleLogAppender(Codec<M> codec,
File basePath,
int size,
ChronicleRetentionDuration retention)
Create a new Log
|
ChronicleLogOffsetTracker(String basePath,
int partition,
String group,
ChronicleRetentionDuration retention) |
ChronicleLogTailer(Codec<M> codec,
String basePath,
net.openhft.chronicle.queue.ExcerptTailer cqTailer,
LogPartition partition,
String group,
ChronicleRetentionDuration retention) |
ChronicleRetentionListener(ChronicleRetentionDuration retention) |
Copyright © 2019 Nuxeo. All rights reserved.