Uses of Interface
org.nuxeo.lib.stream.log.LogTailer
Packages that use LogTailer
Package
Description
Computation pattern implemented with Log
The Log interface with In-Memory and Kafka implementation.
-
Uses of LogTailer in org.nuxeo.ecm.restapi.server.jaxrs.management
Methods in org.nuxeo.ecm.restapi.server.jaxrs.management that return LogTailerModifier and TypeMethodDescriptionStreamServlet.createTailer
(LogManager manager, StreamServlet.CatParams params) -
Uses of LogTailer in org.nuxeo.importer.stream.producer
Fields in org.nuxeo.importer.stream.producer declared as LogTailerModifier and TypeFieldDescriptionprotected final LogTailer<BlobInfoMessage>
RandomLogBlobInfoFetcher.tailer
Constructors in org.nuxeo.importer.stream.producer with parameters of type LogTailerModifierConstructorDescriptionRandomLogBlobInfoFetcher
(LogTailer<BlobInfoMessage> blobInfoTailer) -
Uses of LogTailer in org.nuxeo.lib.stream.computation.log
Fields in org.nuxeo.lib.stream.computation.log declared as LogTailerMethods in org.nuxeo.lib.stream.computation.log that return LogTailerModifier and TypeMethodDescriptionLogStreamManager.createTailer
(Name computationName, Collection<LogPartition> streamPartitions) 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 LogTailerModifier and TypeMethodDescriptiondefault <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(String group, String name) Deprecated.default <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(String group, String name, Codec<M> codec) Deprecated.since 11.1 useLogManager.createTailer(Name, Name, Codec)
insteaddefault <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(String group, Collection<LogPartition> partitions) Deprecated.since 11.1 use(Name)
insteaddefault <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(String group, Collection<LogPartition> partitions, Codec<M> codec) Deprecated.since 11.1 useLogManager.createTailer(Name, Name, Codec)
(Name)} insteaddefault <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(String group, LogPartition partition) Deprecated.since 11.1 use(Name)
insteaddefault <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(String group, LogPartition partition, Codec<M> codec) Deprecated.since 11.1 useLogManager.createTailer(Name, LogPartition, Codec)
insteaddefault <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(Name group, Collection<LogPartition> partitions) Creates a tailer for a consumergroup
and assign multiplepartitions
.<M extends Externalizable>
LogTailer<M>LogManager.createTailer
(Name group, Collection<LogPartition> partitions, Codec<M> codec) Creates a tailer for a consumergroup
and assign multiplepartitions
.default <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(Name group, LogPartition partition) Creates a tailer for a consumergroup
and assign a singlepartition
.default <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(Name group, LogPartition partition, Codec<M> codec) Creates a tailer for a consumergroup
and assign a singlepartition
.default <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(Name group, Name name) Creates a tailer for a consumergroup
and assign allpartitions
of the Log.default <M extends Externalizable>
LogTailer<M>LogManager.createTailer
(Name group, Name name, Codec<M> codec) Creates a tailer for a consumergroup
and assigns allpartitions
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 useLogManager.subscribe(Name, Collection, RebalanceListener)
insteaddefault <M extends Externalizable>
LogTailer<M>LogManager.subscribe
(String group, Collection<String> names, RebalanceListener listener, Codec<M> codec) Deprecated.since 11.1 useLogManager.subscribe(Name, Collection, RebalanceListener, Codec)
insteaddefault <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 consumergroup
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 LogTailerModifier and TypeFieldDescriptionAbstractLogManager.tailers
protected final Map<LogPartitionGroup,
LogTailer> AbstractLogManager.tailersAssignments
Methods in org.nuxeo.lib.stream.log.internals that return LogTailerModifier and TypeMethodDescription<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 LogTailerMethods in org.nuxeo.lib.stream.log.kafka that return LogTailerModifier and TypeMethodDescriptionprotected <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 LogTailerModifier and TypeClassDescriptionclass
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 LogTailerModifier and TypeMethodDescriptionMemLogAppender.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 LogTailerMethods in org.nuxeo.lib.stream.pattern.consumer.internals that return LogTailerModifier and TypeMethodDescriptionConsumerRunner.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 -
Uses of LogTailer in org.nuxeo.lib.stream.tools.command
Methods in org.nuxeo.lib.stream.tools.command that return LogTailerModifier and TypeMethodDescriptionprotected <T extends Externalizable>
LogTailer<T>PositionCommand.createTailer
(LogManager manager, Name name, int partition, Name group) DumpCommand.getTailer
(LogManager manager, Name name, int partition, Name group, String codec) Methods in org.nuxeo.lib.stream.tools.command with parameters of type LogTailerModifier and TypeMethodDescriptionprotected LogOffset
PositionCommand.searchWatermarkOffset
(LogTailer<Record> tailer, long timestamp)
LogManager.createTailer(Name, Name)
(Name)} instead