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

Packages that use LogTailer

Package	Description
org.nuxeo.ecm.restapi.server.jaxrs.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 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
org.nuxeo.lib.stream.tools.command

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

Methods in org.nuxeo.ecm.restapi.server.jaxrs.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 LogTailer<BlobInfoMessage>	RandomLogBlobInfoFetcher.tailer

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

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 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.chronicle

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

Modifier and Type	Class	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	Description
protected LogTailer<M>	ChronicleLogAppender.addTailer(ChronicleLogTailer<M> tailer)
LogTailer<M>	ChronicleLogAppender.createTailer(LogPartition partition, Name group, Codec<M> codec)
protected <M extends Externalizable> LogTailer<M>	ChronicleLogManager.doCreateTailer(Collection<LogPartition> partitions, Name group, Codec<M> codec)
protected <M extends Externalizable> LogTailer<M>	ChronicleLogManager.doSubscribe(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 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	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.pattern.consumer.internals

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

Modifier and Type	Field	Description
protected 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)

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)