org.nuxeo.lib.stream.log.chronicle

Class ChronicleLogManager

java.lang.Object

org.nuxeo.lib.stream.log.internals.AbstractLogManager

org.nuxeo.lib.stream.log.chronicle.ChronicleLogManager

All Implemented Interfaces:

AutoCloseable, LogManager

public class ChronicleLogManager
extends AbstractLogManager

Since:

9.3

Field Summary

Fields

Modifier and Type	Field and Description
protected Path	basePath
protected ChronicleRetentionDuration	retention

Fields inherited from class org.nuxeo.lib.stream.log.internals.AbstractLogManager

appenders, tailers, tailersAssignments

Constructor Summary

Constructors

Constructor and Description
ChronicleLogManager(Path basePath)
ChronicleLogManager(Path basePath, String retentionDuration) Constructor

Method Summary

Modifier and Type	Method and Description
void	create(String name, int size)
<M extends Externalizable> CloseableLogAppender<M>	createAppender(String name, Codec<M> codec)
boolean	delete(String name) Tries to delete a Log.
protected static void	deleteQueueBasePath(Path basePath)
protected <M extends Externalizable> LogTailer<M>	doCreateTailer(Collection<LogPartition> partitions, String group, Codec<M> codec)
protected <M extends Externalizable> LogTailer<M>	doSubscribe(String group, Collection<String> names, RebalanceListener listener, Codec<M> codec)
boolean	exists(String name) Returns true if a Log with this name exists.
String	getBasePath()
protected LogLag	getLagForPartition(String name, int partition, String group)
List<LogLag>	getLagPerPartition(String name, String group) Returns the lag between consumer group and the producers for each partition.
protected int	getSize(String name)
protected static boolean	isChronicleLogFile(Path path)
List<String>	listAll() Returns all the Log names.
List<String>	listConsumerGroups(String name) List the consumer groups for a Log. Note that for Kafka it returns only consumers that use the subscribe API.
String	toString()

Methods inherited from class org.nuxeo.lib.stream.log.internals.AbstractLogManager

checkInvalidAssignment, checkInvalidCodec, close, createIfNotExists, createTailer, getAppender, getLatencyPerPartition, guessCodec, sameCodec, size, subscribe, supportSubscribe

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.nuxeo.lib.stream.log.LogManager

createTailer, createTailer, createTailer, createTailer, createTailer, getAppender, getLag, getLatency, getLatency, getLatencyPerPartition, subscribe

Field Detail

basePath

protected final Path basePath

retention

protected final ChronicleRetentionDuration retention

Constructor Detail

ChronicleLogManager

public ChronicleLogManager(Path basePath)

ChronicleLogManager

public ChronicleLogManager(Path basePath,
                           String retentionDuration)

Constructor

Parameters:

basePath - the base path.

retentionDuration - the retention duration. It is the time period the queue files will be retained. Once the retention duration expires, the older files are candidates for being purged. The property can be expressed as: 15s, 30m, 1h, 4d ... (where 's' is expressing a duration in seconds, 'm' in minutes,'h' in hours and 'd' in days)

Method Detail

deleteQueueBasePath

protected static void deleteQueueBasePath(Path basePath)

isChronicleLogFile

protected static boolean isChronicleLogFile(Path path)

getBasePath

public String getBasePath()

exists

public boolean exists(String name)

Description copied from interface: LogManager

Returns true if a Log with this name exists.

create

public void create(String name,
                   int size)

Specified by:

create in class AbstractLogManager

getSize

protected int getSize(String name)

Specified by:

getSize in class AbstractLogManager

delete

public boolean delete(String name)

Description copied from interface: LogManager

Tries to delete a Log. Returns true if successfully deleted, might not be possible depending on the implementation.

Specified by:

delete in interface LogManager

Overrides:

delete in class AbstractLogManager

getLagForPartition

protected LogLag getLagForPartition(String name,
                                    int partition,
                                    String group)

getLagPerPartition

public List<LogLag> getLagPerPartition(String name,
                                       String group)

Description copied from interface: LogManager

Returns the lag between consumer group and the producers for each partition. The result list is ordered, for instance index 0 is lag for partition 0.

toString

public String toString()

Overrides:

toString in class Object

listAll

public List<String> listAll()

Description copied from interface: LogManager

Returns all the Log names.

listConsumerGroups

public List<String> listConsumerGroups(String name)

Description copied from interface: LogManager

List the consumer groups for a Log.
Note that for Kafka it returns only consumers that use the subscribe API.

createAppender

public <M extends Externalizable> CloseableLogAppender<M> createAppender(String name,
                                                                         Codec<M> codec)

Specified by:

createAppender in class AbstractLogManager

doCreateTailer

protected <M extends Externalizable> LogTailer<M> doCreateTailer(Collection<LogPartition> partitions,
                                                                 String group,
                                                                 Codec<M> codec)

Specified by:

doCreateTailer in class AbstractLogManager

doSubscribe

protected <M extends Externalizable> LogTailer<M> doSubscribe(String group,
                                                              Collection<String> names,
                                                              RebalanceListener listener,
                                                              Codec<M> codec)

Specified by:

doSubscribe in class AbstractLogManager