Package | Description |
---|---|
org.nuxeo.ecm.core.work | |
org.nuxeo.ecm.platform.audit.listener | |
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.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 |
Modifier and Type | Field and Description |
---|---|
protected LogManager |
StreamWorkManager.logManager |
Modifier and Type | Method and Description |
---|---|
protected LogManager |
StreamWorkManager.getLogManager() |
Modifier and Type | Method and Description |
---|---|
protected LogManager |
StreamAuditEventListener.getLogManager() |
Modifier and Type | Method and Description |
---|---|
protected BlobInfoWriter |
BlobConsumers.getBlobInfoWriter(LogManager managerBlobInfo) |
protected void |
BlobConsumers.initBlobInfoMQ(LogManager manager) |
Constructor and Description |
---|
DocumentConsumerPool(String logName,
LogManager manager,
ConsumerFactory<M> factory,
ConsumerPolicy consumerPolicy) |
Modifier and Type | Field and Description |
---|---|
protected LogManager |
RandomDocumentMessageProducerFactory.manager |
Constructor and Description |
---|
RandomDocumentMessageProducerFactory(long nbDocuments,
String lang,
LogManager manager,
String logBlobInfoName)
Generates random documents messages that point to existing blobs.
|
Modifier and Type | Field and Description |
---|---|
protected LogManager |
ComputationRunner.logManager |
protected LogManager |
LogStreamProcessor.manager |
protected LogManager |
ComputationPool.manager |
Constructor and Description |
---|
ComputationPool(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<List<LogPartition>> defaultAssignments,
LogManager manager) |
ComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<LogPartition> defaultAssignment,
LogManager logManager) |
LogStreamProcessor(LogManager manager) |
Modifier and Type | Class and Description |
---|---|
class |
ChronicleLogManager |
Modifier and Type | Class and Description |
---|---|
class |
AbstractLogManager |
Modifier and Type | Class and Description |
---|---|
class |
KafkaLogManager |
Modifier and Type | Field and Description |
---|---|
protected LogManager |
ConsumerPool.manager |
Constructor and Description |
---|
ConsumerPool(String logName,
LogManager manager,
ConsumerFactory<M> factory,
ConsumerPolicy policy) |
Modifier and Type | Method and Description |
---|---|
protected LogTailer<M> |
ConsumerRunner.createTailer(LogManager manager,
List<LogPartition> defaultAssignments) |
protected void |
ConsumerRunner.setTailerPosition(LogManager manager) |
Constructor and Description |
---|
ConsumerRunner(ConsumerFactory<M> factory,
ConsumerPolicy policy,
LogManager manager,
List<LogPartition> defaultAssignments) |
Modifier and Type | Field and Description |
---|---|
protected LogManager |
ProducerPool.manager |
Constructor and Description |
---|
ProducerPool(String logName,
LogManager manager,
ProducerFactory<M> factory,
short nbThreads) |
Modifier and Type | Field and Description |
---|---|
protected LogManager |
Main.manager |
Modifier and Type | Method and Description |
---|---|
protected void |
CatCommand.cat(LogManager manager,
String name,
String group,
int limit,
Renderer render) |
protected boolean |
CopyCommand.copy(LogManager manager,
String src,
String dest,
String group) |
protected void |
TailCommand.follow(LogManager manager,
String name,
String group,
Renderer render,
int timeout) |
protected void |
LagCommand.lag(LogManager manager) |
protected void |
LagCommand.lag(LogManager manager,
String name) |
protected void |
ResetCommand.reset(LogManager manager,
String group,
String name) |
boolean |
TailCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
ResetCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
LagCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
HelpCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
CopyCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
abstract boolean |
Command.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
CatCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
protected void |
TailCommand.tail(LogManager manager,
String name,
String group,
int lines,
Renderer render) |
Modifier and Type | Field and Description |
---|---|
protected Map<String,LogManager> |
StreamServiceImpl.managers |
Modifier and Type | Method and Description |
---|---|
protected LogManager |
StreamServiceImpl.createChronicleLogManager(LogConfigDescriptor config) |
protected LogManager |
StreamServiceImpl.createKafkaLogManager(LogConfigDescriptor config) |
LogManager |
StreamServiceImpl.getLogManager(String name) |
LogManager |
StreamService.getLogManager(String name)
Get a LogManager corresponding to the config name.
|
Copyright © 2018 Nuxeo. All rights reserved.