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.internals | |
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) |
RandomDocumentMessageProducerFactory(long nbDocuments,
String lang,
LogManager manager,
String logBlobInfoName,
Boolean countFolderAsDocument)
Generates random documents messages that point to existing blobs.
|
Modifier and Type | Field and Description |
---|---|
protected LogManager |
ComputationContextImpl.manager |
Constructor and Description |
---|
ComputationContextImpl(LogManager logManager,
ComputationMetadataMapping metadata) |
ComputationContextImpl(LogManager logManager,
ComputationMetadataMapping metadata,
ComputationPolicy policy) |
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,
Codec<Record> inputCodec,
Codec<Record> outputCodec,
ComputationPolicy policy) |
ComputationRunner(Supplier<Computation> supplier,
ComputationMetadataMapping metadata,
List<LogPartition> defaultAssignment,
LogManager logManager,
Codec<Record> inputCodec,
Codec<Record> outputCodec,
ComputationPolicy policy) |
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 |
---|---|
LogManager |
Main.getLogManager(String[] args) |
Modifier and Type | Field and Description |
---|---|
protected LogManager |
LatencyTrackerComputation.manager |
Modifier and Type | Method and Description |
---|---|
protected void |
AppendCommand.append(LogManager manager,
String name,
int partition,
String codec,
Path input) |
protected void |
CatCommand.cat(LogManager manager,
String name,
String group,
int limit,
Renderer render,
String codec) |
protected boolean |
CopyCommand.copy(LogManager manager,
String src,
String srcCodec,
String dest,
String destCodec,
String group) |
protected <T extends Externalizable> |
PositionCommand.createTailer(LogManager manager,
String name,
int partition,
String group) |
protected void |
DumpCommand.dump(LogManager manager,
String name,
int partition,
String group,
int limit,
String codec,
Path output) |
protected LogOffset |
RestoreCommand.findOffset(LogManager manager,
LogPartitionGroup key,
Latency latency) |
protected void |
TailCommand.follow(LogManager manager,
String name,
String group,
Renderer render,
int timeout,
String codec) |
protected LogLag |
PositionCommand.getLag(LogManager manager,
String group,
String name,
int partition) |
protected List<String> |
TrackerCommand.getLogNames(LogManager manager,
String names) |
protected List<String> |
RestoreCommand.getLogNames(LogManager manager,
String names) |
protected List<String> |
MonitorCommand.getLogNames(LogManager manager,
String names) |
protected LogTailer<Record> |
DumpCommand.getTailer(LogManager manager,
String name,
int partition,
String group,
String codec) |
protected void |
TrackerCommand.initTopology(LogManager manager) |
protected void |
MonitorCommand.initTopology(LogManager manager) |
protected void |
LagCommand.lag(LogManager manager) |
protected void |
LagCommand.lag(LogManager manager,
String name) |
protected void |
LatencyCommand.latency(LogManager manager,
Codec<Record> codec) |
protected void |
LatencyCommand.latency(LogManager manager,
String name,
Codec<Record> codec) |
protected boolean |
PositionCommand.positionAfterDate(LogManager manager,
String group,
String name,
int partition,
long timestamp) |
protected boolean |
PositionCommand.positionToWatermark(LogManager manager,
String group,
String name,
int partition,
long timestamp) |
protected Map<LogPartitionGroup,Latency> |
RestoreCommand.readLatencies(LogManager manager) |
protected boolean |
PositionCommand.reset(LogManager manager,
String group,
String name,
int partition) |
protected boolean |
RestoreCommand.restorePosition(LogManager manager) |
boolean |
TrackerCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
TestCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
TailCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
RestoreCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
PositionCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
MonitorCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
boolean |
LatencyCommand.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 |
DumpCommand.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) |
boolean |
AppendCommand.run(LogManager manager,
org.apache.commons.cli.CommandLine cmd) |
protected boolean |
TrackerCommand.runProcessor(LogManager manager) |
protected boolean |
MonitorCommand.runProcessor(LogManager manager) |
protected Map<LogPartitionGroup,LogOffset> |
RestoreCommand.searchOffsets(LogManager manager,
Map<LogPartitionGroup,Latency> latencies) |
protected void |
TailCommand.tail(LogManager manager,
String name,
String group,
int lines,
Renderer render,
String codec) |
protected boolean |
PositionCommand.toEnd(LogManager manager,
String group,
String name,
int partition) |
protected void |
RestoreCommand.updatePosition(LogManager manager,
LogPartitionGroup key,
LogOffset offset) |
protected void |
RestoreCommand.updatePositions(LogManager manager,
Map<LogPartitionGroup,LogOffset> offsets) |
Constructor and Description |
---|
LatencyMonitorComputation(LogManager manager,
List<String> logNames,
String host,
int port,
boolean udp,
String basePrefix,
String computationName,
int intervalSecond,
int count,
boolean verbose,
Codec<Record> codec) |
LatencyTrackerComputation(LogManager manager,
List<String> logNames,
String computationName,
int intervalSecond,
int count,
boolean verbose,
Codec<Record> codec) |
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 © 2019 Nuxeo. All rights reserved.