Uses of Interface
org.nuxeo.lib.stream.log.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
Modifier and TypeMethodDescriptionStreamServlet.createTailer
(LogManager manager, StreamServlet.CatParams params) -
Uses of LogTailer in org.nuxeo.importer.stream.producer
Modifier and TypeFieldDescriptionprotected final LogTailer<BlobInfoMessage>
RandomLogBlobInfoFetcher.tailer
ModifierConstructorDescriptionRandomLogBlobInfoFetcher
(LogTailer<BlobInfoMessage> blobInfoTailer) -
Uses of LogTailer in org.nuxeo.lib.stream.computation.log
Modifier 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
Modifier 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
Modifier and TypeFieldDescriptionAbstractLogManager.tailers
protected final Map<LogPartitionGroup,
LogTailer> AbstractLogManager.tailersAssignments
Modifier 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
Modifier 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
Modifier and TypeClassDescriptionclass
MemCompoundLogTailer<M extends Externalizable>
A compound tailer to handle multiple partitions.class
MemLogTailer<M extends Externalizable>
Memory implementation of LogTailer.Modifier 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
Modifier and TypeMethodDescriptionConsumerRunner.createTailer
(LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments) -
Uses of LogTailer in org.nuxeo.lib.stream.tools.command
Modifier 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) Modifier and TypeMethodDescriptionprotected LogOffset
PositionCommand.searchWatermarkOffset
(LogTailer<Record> tailer, long timestamp)
LogManager.createTailer(Name, Name)
(Name)} instead