Package org.nuxeo.lib.stream.log.mem

Class MemLogManager

java.lang.Object

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

org.nuxeo.lib.stream.log.mem.MemLogManager

All Implemented Interfaces:

AutoCloseable, LogManager

public class MemLogManager
extends AbstractLogManager

Memory implementation of LogManager.

Field Summary

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

ADMIN_GROUP, appenders, tailers, tailersAssignments

Constructor Summary

Constructors

Constructor	Description
MemLogManager()

Method Summary

Modifier and Type	Method	Description
static void	clear()
void	create(Name name, int size)
<M extends Externalizable> CloseableLogAppender<M>	createAppender(Name name, Codec<M> codec)
boolean	delete(Name name)	Tries to delete a Log.
protected <M extends Externalizable> LogTailer<M>	doCreateTailer(Collection<LogPartition> partitions, Name group, Codec<M> codec)
protected <M extends Externalizable> LogTailer<M>	doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
boolean	exists(Name name)	Returns true if a Log with this name exists.
List<LogLag>	getLagPerPartition(Name name, Name group)	Returns the lag between consumer group and the producers for each partition.
int	getSize(Name name)
List<Name>	listAllNames()	Returns all the Log names.
List<Name>	listConsumerGroups(Name name)	List the consumer groups for a Log.
String	toString()

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

checkInvalidAssignment, checkInvalidCodec, cleanTailers, close, createIfNotExists, createTailer, getAppender, getLatencyPerPartition, guessCodec, sameCodec, size, subscribe, supportSubscribe, 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

createIfNotExists, createTailer, createTailer, createTailer, createTailer, createTailer, createTailer, createTailer, createTailer, createTailer, createTailer, createTailer, delete, deleteConsumers, deleteRecords, exists, getAppender, getAppender, getAppender, getLag, getLag, getLagPerPartition, getLatency, getLatency, getLatencyPerPartition, listAll, listConsumerGroups, size, subscribe, subscribe, subscribe

Constructor Details

MemLogManager

public MemLogManager()

Method Details

clear

public static void clear()

exists

public boolean exists(Name name)

Description copied from interface: LogManager

Returns true if a Log with this name exists.

create

public void create(Name name,
 int size)

Specified by:

create in class AbstractLogManager

getSize

public int getSize(Name name)

Specified by:

getSize in class AbstractLogManager

delete

public boolean delete(Name 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

getLagPerPartition

public List<LogLag> getLagPerPartition(Name name,
 Name 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.

Specified by:

getLagPerPartition in interface LogManager

Specified by:

getLagPerPartition in class AbstractLogManager

toString

public String toString()

Overrides:

toString in class Object

listAllNames

public List<Name> listAllNames()

Description copied from interface: LogManager

Returns all the Log names.

listConsumerGroups

public List<Name> listConsumerGroups(Name name)

Description copied from interface: LogManager

List the consumer groups for a Log.

createAppender

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

Specified by:

createAppender in class AbstractLogManager

doCreateTailer

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

Specified by:

doCreateTailer in class AbstractLogManager

doSubscribe

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

Specified by:

doSubscribe in class AbstractLogManager