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

Packages that use LogManager

Package	Description
org.nuxeo.ecm.core.work
org.nuxeo.importer.stream.automation
org.nuxeo.importer.stream.consumer
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
org.nuxeo.lib.stream.pattern.consumer.internals
org.nuxeo.lib.stream.pattern.producer
org.nuxeo.lib.stream.tools	Some tools for debugging on existing Log and Computations
org.nuxeo.lib.stream.tools.command
org.nuxeo.runtime.stream

Uses of LogManager in org.nuxeo.ecm.core.work

Fields in org.nuxeo.ecm.core.work declared as LogManager

Modifier and Type	Field	Description
protected LogManager	StreamWorkManager.logManager

Methods in org.nuxeo.ecm.core.work that return LogManager

Modifier and Type	Method	Description
protected LogManager	StreamWorkManager.getLogManager()

Uses of LogManager in org.nuxeo.importer.stream.automation

Methods in org.nuxeo.importer.stream.automation with parameters of type LogManager

Modifier and Type	Method	Description
protected BlobInfoWriter	BlobConsumers.getBlobInfoWriter(LogManager managerBlobInfo)
protected void	BlobConsumers.initBlobInfoMQ(LogManager manager)

Uses of LogManager in org.nuxeo.importer.stream.consumer

Constructors in org.nuxeo.importer.stream.consumer with parameters of type LogManager

Constructor	Description
DocumentConsumerPool(String logName, LogManager manager, Codec<M> codec, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)
DocumentConsumerPool(String logName, LogManager manager, ConsumerFactory<M> factory, ConsumerPolicy consumerPolicy)	Deprecated. since 11.1, due to serialization issue with java 11, use DocumentConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy) which allows to give a codec to tailer.

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

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

Modifier and Type	Field	Description
protected LogManager	RandomDocumentMessageProducerFactory.manager

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

Constructor	Description
RandomDocumentMessageProducerFactory(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

Fields in org.nuxeo.lib.stream.computation.log declared as LogManager

Modifier and Type	Field	Description
protected LogManager	LogStreamManager.logManager
protected LogManager	LogStreamProcessor.manager

Methods in org.nuxeo.lib.stream.computation.log that return LogManager

Modifier and Type	Method	Description
LogManager	LogStreamManager.getLogManager()

Constructors in org.nuxeo.lib.stream.computation.log with parameters of type LogManager

Constructor	Description
LogStreamManager(LogManager logManager)
LogStreamProcessor(LogManager manager)	Deprecated.

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

Classes in org.nuxeo.lib.stream.log that implement LogManager

Modifier and Type	Class	Description
class	UnifiedLogManager

Fields in org.nuxeo.lib.stream.log declared as LogManager

Modifier and Type	Field	Description
protected LogManager	UnifiedLogManager.cqManager
protected LogManager	UnifiedLogManager.defaultManager
protected LogManager	UnifiedLogManager.kafkaManager

Fields in org.nuxeo.lib.stream.log with type parameters of type LogManager

Modifier and Type	Field	Description
protected Map<LogConfig,LogManager>	UnifiedLogManager.managers

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

Modifier and Type	Method	Description
protected LogManager	UnifiedLogManager.getManager(Name name)
protected LogManager	UnifiedLogManager.getManager(Name name, Name group)

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

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

Modifier and Type	Class	Description
class	ChronicleLogManager

Uses of LogManager in org.nuxeo.lib.stream.log.internals

Classes in org.nuxeo.lib.stream.log.internals that implement LogManager

Modifier and Type	Class	Description
class	AbstractLogManager

Uses of LogManager in org.nuxeo.lib.stream.log.kafka

Classes in org.nuxeo.lib.stream.log.kafka that implement LogManager

Modifier and Type	Class	Description
class	KafkaLogManager

Uses of LogManager in org.nuxeo.lib.stream.pattern.consumer

Fields in org.nuxeo.lib.stream.pattern.consumer declared as LogManager

Modifier and Type	Field	Description
protected LogManager	ConsumerPool.manager

Constructors in org.nuxeo.lib.stream.pattern.consumer with parameters of type LogManager

Constructor	Description
ConsumerPool(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, use ConsumerPool(String, LogManager, Codec, ConsumerFactory, ConsumerPolicy) which allows to give a codec to tailer.

Uses of LogManager in org.nuxeo.lib.stream.pattern.consumer.internals

Methods in org.nuxeo.lib.stream.pattern.consumer.internals with parameters of type LogManager

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

Constructors in org.nuxeo.lib.stream.pattern.consumer.internals with parameters of type LogManager

Constructor	Description
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, List<LogPartition> defaultAssignments)	Deprecated. since 11.1, due to serialization issue with java 11, use ConsumerRunner(ConsumerFactory, ConsumerPolicy, LogManager, Codec, List) which allows to give a codec to tailer.
ConsumerRunner(ConsumerFactory<M> factory, ConsumerPolicy policy, LogManager manager, Codec<M> codec, List<LogPartition> defaultAssignments)

Uses of LogManager in org.nuxeo.lib.stream.pattern.producer

Fields in org.nuxeo.lib.stream.pattern.producer declared as LogManager

Modifier and Type	Field	Description
protected LogManager	ProducerPool.manager

Constructors in org.nuxeo.lib.stream.pattern.producer with parameters of type LogManager

Constructor	Description
ProducerPool(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, use ProducerPool(String, LogManager, Codec, ProducerFactory, short) which allows to give a codec to appender.

Uses of LogManager in org.nuxeo.lib.stream.tools

Fields in org.nuxeo.lib.stream.tools declared as LogManager

Modifier and Type	Field	Description
protected LogManager	Main.manager

Methods in org.nuxeo.lib.stream.tools that return LogManager

Modifier and Type	Method	Description
LogManager	Main.getLogManager(String[] args)

Uses of LogManager in org.nuxeo.lib.stream.tools.command

Fields in org.nuxeo.lib.stream.tools.command declared as LogManager

Modifier and Type	Field	Description
protected LogManager	LatencyTrackerComputation.manager

Methods in org.nuxeo.lib.stream.tools.command with parameters of type LogManager

Modifier and Type	Method	Description
protected void	AppendCommand.append(LogManager manager, Name name, int partition, String codec, Path input)
protected void	CatCommand.cat(LogManager manager, Name name, Name group, int limit, Renderer render, String codec)
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)
protected List<Name>	MonitorCommand.getLogNames(LogManager manager, String names)
protected List<Name>	RestoreCommand.getLogNames(LogManager manager, String names)
protected List<Name>	TrackerCommand.getLogNames(LogManager manager, String names)
protected LogTailer<Record>	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)

Constructors in org.nuxeo.lib.stream.tools.command with parameters of type LogManager

Constructor	Description
LatencyDatadogComputation(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

Fields in org.nuxeo.runtime.stream declared as LogManager

Modifier and Type	Field	Description
protected LogManager	StreamServiceImpl.logManager
protected LogManager	StreamMetricsComputation.manager

Methods in org.nuxeo.runtime.stream that return LogManager

Modifier and Type	Method	Description
LogManager	StreamService.getLogManager()
default LogManager	StreamService.getLogManager(String configName)	Deprecated. since 11.1 just use StreamService.getLogManager().
LogManager	StreamServiceImpl.getLogManager()
protected LogManager	StreamMetricsComputation.getManager()

Methods in org.nuxeo.runtime.stream with parameters of type LogManager

Modifier and Type	Method	Description
boolean	StreamMetricsComputation.LatencyMetric.update(LogManager manager, Codec<Record> codec)