Uses of Interface
org.nuxeo.lib.stream.log.LogTailer

Packages that use LogTailer

Package	Description
org.nuxeo.ecm.restapi.server.management
org.nuxeo.importer.stream.producer
org.nuxeo.lib.stream.computation.log	Computation pattern implemented with Log
org.nuxeo.lib.stream.log	The Log interface with In-Memory and Kafka implementation.
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.log.kafka
org.nuxeo.lib.stream.log.mem
org.nuxeo.lib.stream.pattern.consumer.internals
org.nuxeo.lib.stream.tools.command

Uses of LogTailer in org.nuxeo.ecm.restapi.server.management

Methods in org.nuxeo.ecm.restapi.server.management that return LogTailer

Modifier and Type	Method	Description
protected LogTailer<Record>	StreamServlet.createTailer(LogManager manager, StreamServlet.CatParams params)

Uses of LogTailer in org.nuxeo.importer.stream.producer

Fields in org.nuxeo.importer.stream.producer declared as LogTailer

Modifier and Type	Field	Description
protected final LogTailer<BlobInfoMessage>	RandomLogBlobInfoFetcher.tailer

Constructors in org.nuxeo.importer.stream.producer with parameters of type LogTailer

Modifier	Constructor	Description
	RandomLogBlobInfoFetcher(LogTailer<BlobInfoMessage> blobInfoTailer)

Uses of LogTailer in org.nuxeo.lib.stream.computation.log

Fields in org.nuxeo.lib.stream.computation.log declared as LogTailer

Modifier and Type	Field	Description
protected final LogTailer<Record>	ComputationRunner.tailer

Methods in org.nuxeo.lib.stream.computation.log that return LogTailer

Modifier and Type	Method	Description
LogTailer<Record>	LogStreamManager.createTailer(Name computationName, Collection<LogPartition> streamPartitions)
LogTailer<Record>	LogStreamManager.subscribe(Name computationName, Collection<Name> streams, RebalanceListener listener)

Uses of LogTailer in org.nuxeo.lib.stream.log

Methods in org.nuxeo.lib.stream.log that return LogTailer

Modifier and Type	Method	Description
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, String name)	Deprecated. since 11.1 use LogManager.createTailer(Name, Name) (Name)} instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, String name, Codec<M> codec)	Deprecated. since 11.1 use LogManager.createTailer(Name, Name, Codec) instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, Collection<LogPartition> partitions)	Deprecated. since 11.1 use (Name) instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, Collection<LogPartition> partitions, Codec<M> codec)	Deprecated. since 11.1 use LogManager.createTailer(Name, Name, Codec) (Name)} instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, LogPartition partition)	Deprecated. since 11.1 use (Name) instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, LogPartition partition, Codec<M> codec)	Deprecated. since 11.1 use LogManager.createTailer(Name, LogPartition, Codec) instead
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, Collection<LogPartition> partitions)	Creates a tailer for a consumer group and assign multiple partitions.
<M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, Collection<LogPartition> partitions, Codec<M> codec)	Creates a tailer for a consumer group and assign multiple partitions.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, LogPartition partition)	Creates a tailer for a consumer group and assign a single partition.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, LogPartition partition, Codec<M> codec)	Creates a tailer for a consumer group and assign a single partition.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, Name name)	Creates a tailer for a consumer group and assign all partitions of the Log.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(Name group, Name name, Codec<M> codec)	Creates a tailer for a consumer group and assigns all partitions of the Log.
<M extends Externalizable> LogTailer<M>	UnifiedLogManager.createTailer(Name group, Collection<LogPartition> partitions, Codec<M> codec)
default <M extends Externalizable> LogTailer<M>	LogManager.subscribe(String group, Collection<String> names, RebalanceListener listener)	Deprecated. since 11.1 use LogManager.subscribe(Name, Collection, RebalanceListener) instead
default <M extends Externalizable> LogTailer<M>	LogManager.subscribe(String group, Collection<String> names, RebalanceListener listener, Codec<M> codec)	Deprecated. since 11.1 use LogManager.subscribe(Name, Collection, RebalanceListener, Codec) instead
default <M extends Externalizable> LogTailer<M>	LogManager.subscribe(Name group, Collection<Name> names, RebalanceListener listener)
<M extends Externalizable> LogTailer<M>	LogManager.subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)	Creates a tailer for a consumer group and subscribe to multiple Logs.
<M extends Externalizable> LogTailer<M>	UnifiedLogManager.subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)

Uses of LogTailer in org.nuxeo.lib.stream.log.internals

Fields in org.nuxeo.lib.stream.log.internals with type parameters of type LogTailer

Modifier and Type	Field	Description
protected final Set<LogTailer>	AbstractLogManager.tailers
protected final Map<LogPartitionGroup,LogTailer>	AbstractLogManager.tailersAssignments

Methods in org.nuxeo.lib.stream.log.internals that return LogTailer

Modifier and Type	Method	Description
<M extends Externalizable> LogTailer<M>	AbstractLogManager.createTailer(Name group, Collection<LogPartition> partitions, Codec<M> codec)
protected abstract <M extends Externalizable> LogTailer<M>	AbstractLogManager.doCreateTailer(Collection<LogPartition> partitions, Name group, Codec<M> codec)
protected abstract <M extends Externalizable> LogTailer<M>	AbstractLogManager.doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)
<M extends Externalizable> LogTailer<M>	AbstractLogManager.subscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)

Uses of LogTailer in org.nuxeo.lib.stream.log.kafka

Classes in org.nuxeo.lib.stream.log.kafka that implement LogTailer

Modifier and Type	Class	Description
class	KafkaLogTailer<M extends Externalizable>

Methods in org.nuxeo.lib.stream.log.kafka that return LogTailer

Modifier and Type	Method	Description
protected <M extends Externalizable> LogTailer<M>	KafkaLogManager.doCreateTailer(Collection<LogPartition> partitions, Name group, Codec<M> codec)
protected <M extends Externalizable> LogTailer<M>	KafkaLogManager.doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)

Uses of LogTailer in org.nuxeo.lib.stream.log.mem

Classes in org.nuxeo.lib.stream.log.mem that implement LogTailer

Modifier and Type	Class	Description
class	MemCompoundLogTailer<M extends Externalizable>	A compound tailer to handle multiple partitions.
class	MemLogTailer<M extends Externalizable>	Memory implementation of LogTailer.

Methods in org.nuxeo.lib.stream.log.mem that return LogTailer

Modifier and Type	Method	Description
LogTailer<M>	MemLogAppender.createTailer(LogPartition partition, Name group, Codec<M> codec)
protected <M extends Externalizable> LogTailer<M>	MemLogManager.doCreateTailer(Collection<LogPartition> partitions, Name group, Codec<M> codec)
protected <M extends Externalizable> LogTailer<M>	MemLogManager.doSubscribe(Name group, Collection<Name> names, RebalanceListener listener, Codec<M> codec)

Uses of LogTailer in org.nuxeo.lib.stream.pattern.consumer.internals

Fields in org.nuxeo.lib.stream.pattern.consumer.internals declared as LogTailer

Modifier and Type	Field	Description
protected final LogTailer<M>	ConsumerRunner.tailer

Methods in org.nuxeo.lib.stream.pattern.consumer.internals that return LogTailer

Modifier and Type	Method	Description
protected LogTailer<M>	ConsumerRunner.createTailer(LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments)

Methods in org.nuxeo.lib.stream.pattern.consumer.internals that return types with arguments of type LogTailer

Modifier and Type	Method	Description
protected Consumer<LogTailer<M>>	ConsumerRunner.setTailerPosition(LogManager manager)

Uses of LogTailer in org.nuxeo.lib.stream.tools.command

Methods in org.nuxeo.lib.stream.tools.command that return LogTailer

Modifier and Type	Method	Description
protected <T extends Externalizable> LogTailer<T>	PositionCommand.createTailer(LogManager manager, Name name, int partition, Name group)
protected LogTailer<Record>	DumpCommand.getTailer(LogManager manager, Name name, int partition, Name group, String codec)

Methods in org.nuxeo.lib.stream.tools.command with parameters of type LogTailer

Modifier and Type	Method	Description
protected LogOffset	PositionCommand.searchWatermarkOffset(LogTailer<Record> tailer, long timestamp)