Uses of Interface
org.nuxeo.lib.stream.log.LogManager
Package
Description
Computation pattern implemented with Log
The Log interface with In-Memory and Kafka implementation.
Some tools for debugging on existing Log and Computations
-
Uses of LogManager in org.nuxeo.ecm.core.work
-
Uses of LogManager in org.nuxeo.ecm.restapi.server.jaxrs.management
Modifier and TypeMethodDescriptionStreamServlet.createTailer
(LogManager manager, StreamServlet.CatParams params) -
Uses of LogManager in org.nuxeo.importer.stream.automation
Modifier and TypeMethodDescriptionprotected BlobInfoWriter
BlobConsumers.getBlobInfoWriter
(LogManager managerBlobInfo) protected void
BlobConsumers.initBlobInfoMQ
(LogManager manager) -
Uses of LogManager in org.nuxeo.importer.stream.consumer
ModifierConstructorDescriptionDocumentConsumerPool
(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy) DocumentConsumerPool
(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy) Deprecated. -
Uses of LogManager in org.nuxeo.importer.stream.producer
Modifier and TypeFieldDescriptionprotected final LogManager
RandomDocumentMessageProducerFactory.manager
ModifierConstructorDescriptionRandomDocumentMessageProducerFactory
(long nbDocuments, String lang, LogManager manager, String logBlobInfoName) RandomDocumentMessageProducerFactory
(long nbDocuments, String lang, LogManager manager, String logBlobInfoName, Boolean countFolderAsDocument) Generates random documents messages that point to existing blobs. -
Uses of LogManager in org.nuxeo.lib.stream.computation.log
Modifier and TypeFieldDescriptionprotected final LogManager
LogStreamManager.logManager
protected final LogManager
LogStreamProcessor.manager
ModifierConstructorDescriptionLogStreamManager
(String nodeId, LogManager logManager) LogStreamManager
(LogManager logManager) LogStreamProcessor
(LogManager manager) Deprecated. -
Uses of LogManager in org.nuxeo.lib.stream.log
Modifier and TypeFieldDescriptionprotected LogManager
UnifiedLogManager.defaultManager
protected LogManager
UnifiedLogManager.kafkaManager
protected LogManager
UnifiedLogManager.memManager
Modifier and TypeMethodDescriptionprotected LogManager
UnifiedLogManager.getManager
(Name name) protected LogManager
UnifiedLogManager.getManager
(Name name, Name group) -
Uses of LogManager in org.nuxeo.lib.stream.log.internals
-
Uses of LogManager in org.nuxeo.lib.stream.log.kafka
-
Uses of LogManager in org.nuxeo.lib.stream.log.mem
-
Uses of LogManager in org.nuxeo.lib.stream.pattern.consumer
ModifierConstructorDescriptionConsumerPool
(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy policy) ConsumerPool
(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy policy) Deprecated.since 11.1, due to serialization issue with java 11, useConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy)
which allows to give acodec
totailer
. -
Uses of LogManager in org.nuxeo.lib.stream.pattern.consumer.internals
Modifier and TypeMethodDescriptionConsumerRunner.createTailer
(LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments) ConsumerRunner.setTailerPosition
(LogManager manager) ModifierConstructorDescriptionConsumerRunner
(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, List<LogPartition> defaultAssignments) Deprecated.since 11.1, due to serialization issue with java 11, useConsumerRunner(ConsumerFactory, ConsumerPolicy, LogManager, Codec, List)
which allows to give acodec
totailer
.ConsumerRunner
(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments) -
Uses of LogManager in org.nuxeo.lib.stream.pattern.producer
ModifierConstructorDescriptionProducerPool
(String logName, LogManager manager, Codec<M> codec, ProducerFactory<M> factory, short nbThreads) ProducerPool
(String logName, LogManager manager, ProducerFactory<M> factory, short nbThreads) Deprecated.since 11.1, due to serialization issue with java 11, useProducerPool(String, LogManager, Codec, ProducerFactory, short)
which allows to give acodec
toappender
. -
Uses of LogManager in org.nuxeo.lib.stream.tools
-
Uses of LogManager in org.nuxeo.lib.stream.tools.command
Modifier and TypeMethodDescriptionprotected void
AppendCommand.append
(LogManager manager, Name name, int partition, String codec, Path input) protected void
protected boolean
CopyCommand.copy
(LogManager manager, Name src, String srcCodec, Name dest, String destCodec, Name group) protected <T extends Externalizable>
LogTailer<T>PositionCommand.createTailer
(LogManager manager, Name name, int partition, Name group) protected void
DumpCommand.dump
(LogManager manager, Name name, int partition, Name group, int limit, String codec, Path output) protected LogOffset
RestoreCommand.findOffset
(LogManager manager, LogPartitionGroup key, Latency latency) protected void
TailCommand.follow
(LogManager manager, Name name, Name group, Renderer render, int timeout, String codec) protected LogLag
PositionCommand.getLag
(LogManager manager, Name group, Name name, int partition) MonitorCommand.getLogNames
(LogManager manager, String names) RestoreCommand.getLogNames
(LogManager manager, String names) TrackerCommand.getLogNames
(LogManager manager, String names) DumpCommand.getTailer
(LogManager manager, Name name, int partition, Name group, String codec) protected void
DatadogCommand.initTopology
(LogManager manager) protected void
MonitorCommand.initTopology
(LogManager manager) protected void
TrackerCommand.initTopology
(LogManager manager) protected void
LagCommand.lag
(LogManager manager) protected void
LagCommand.lag
(LogManager manager, Name name) protected void
LatencyCommand.latency
(LogManager manager, Codec<Record> codec) protected void
LatencyCommand.latency
(LogManager manager, Name name, Codec<Record> codec) protected boolean
PositionCommand.positionAfterDate
(LogManager manager, Name group, Name name, int partition, long timestamp) protected boolean
PositionCommand.positionToOffset
(LogManager manager, Name group, Name name, int partition, long offset) protected boolean
PositionCommand.positionToWatermark
(LogManager manager, Name group, Name name, int partition, long timestamp, String codec) protected Map<LogPartitionGroup,
Latency> RestoreCommand.readLatencies
(LogManager manager) protected boolean
PositionCommand.reset
(LogManager manager, Name group, Name name, int partition) protected boolean
RestoreCommand.restorePosition
(LogManager manager) boolean
AppendCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
CatCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) abstract boolean
Command.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
CopyCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
DatadogCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
DumpCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
HelpCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
LagCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
LatencyCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
MonitorCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
PositionCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
RestoreCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
TailCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
TestCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
TrackerCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) boolean
WorkCatCommand.run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) protected boolean
MonitorCommand.runProcessor
(LogManager manager) protected boolean
TrackerCommand.runProcessor
(LogManager manager) protected Map<LogPartitionGroup,
LogOffset> RestoreCommand.searchOffsets
(LogManager manager, Map<LogPartitionGroup, Latency> latencies) protected void
TailCommand.tail
(LogManager manager, Name name, Name group, int lines, Renderer render, String codec) protected boolean
PositionCommand.toEnd
(LogManager manager, Name group, Name name, int partition) protected void
RestoreCommand.updatePosition
(LogManager manager, LogPartitionGroup key, LogOffset offset) protected void
RestoreCommand.updatePositions
(LogManager manager, Map<LogPartitionGroup, LogOffset> offsets) protected void
WorkCatCommand.workStat
(LogManager manager, Name name, Name group, int limit, String codec) ModifierConstructorDescriptionLatencyDatadogComputation
(LogManager manager, List<Name> logNames, String apiKey, List<String> tags, String basePrefix, String computationName, int intervalSecond, int count, boolean partition, boolean verbose, Codec<Record> codec) LatencyMonitorComputation
(LogManager manager, List<Name> logNames, String host, int port, boolean udp, String basePrefix, String computationName, int intervalSecond, int count, boolean partition, boolean verbose, Codec<Record> codec) LatencyMonitorComputation
(LogManager manager, List<Name> logNames, String host, int port, boolean udp, String basePrefix, String computationName, int intervalSecond, int count, boolean verbose, Codec<Record> codec) Deprecated.LatencyTrackerComputation
(LogManager manager, List<Name> logNames, String computationName, int intervalSecond, int count, boolean verbose, Codec<Record> codec, int outputStream) -
Uses of LogManager in org.nuxeo.runtime.stream
Modifier and TypeFieldDescriptionprotected LogManager
StreamServiceImpl.logManager
protected LogManager
StreamMetricsComputation.manager
Modifier and TypeMethodDescriptionStreamService.getLogManager()
default LogManager
StreamService.getLogManager
(String configName) Deprecated.since 11.1 just useStreamService.getLogManager()
.StreamServiceImpl.getLogManager()
protected LogManager
StreamMetricsComputation.getManager()
Modifier and TypeMethodDescriptionboolean
StreamMetricsComputation.LatencyMetric.update
(LogManager manager, Codec<Record> codec)
DocumentConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy)
which allows to give acodec
totailer
.