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

Packages that use LogTailer

Package	Description
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 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.pattern.consumer.internals

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

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

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

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

Constructor and 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 and Description
protected LogTailer<Record>	ComputationRunner.tailer

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

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

Modifier and Type	Method and Description
<M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, Collection<LogPartition> partitions) Create a tailer for a consumer group and assign multiple partitions.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, LogPartition partition) Create a tailer for a consumer group and assign a single partition.
default <M extends Externalizable> LogTailer<M>	LogManager.createTailer(String group, String name) Create a tailer for a consumer group and assign all partitions of the Log.
<M extends Externalizable> LogTailer<M>	LogManager.subscribe(String group, Collection<String> names, RebalanceListener listener) Create a tailer for a consumer group and subscribe to multiple Logs.

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

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

Modifier and Type	Class and Description
class	ChronicleCompoundLogTailer<M extends Externalizable> A compound tailer to handle multiple partitions.
class	ChronicleLogTailer<M extends Externalizable>

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

Modifier and Type	Method and Description
protected LogTailer<M>	ChronicleLogAppender.addTailer(ChronicleLogTailer<M> tailer)
LogTailer<M>	ChronicleLogAppender.createTailer(LogPartition partition, String group)
protected <M extends Externalizable> LogTailer<M>	ChronicleLogManager.doCreateTailer(Collection<LogPartition> partitions, String group)
protected <M extends Externalizable> LogTailer<M>	ChronicleLogManager.doSubscribe(String group, Collection<String> names, RebalanceListener listener)

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 and Description
protected Set<LogTailer>	AbstractLogManager.tailers
protected Map<LogPartitionGroup,LogTailer>	AbstractLogManager.tailersAssignments

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

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

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 and Description
class	KafkaLogTailer<M extends Externalizable>

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

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

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 and Description
protected LogTailer<M>	ConsumerRunner.tailer

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

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