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 |
The Computation pattern with a Log implementation.
|
org.nuxeo.lib.stream.computation.internals | |
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.pattern.producer.internals | |
org.nuxeo.lib.stream.tools |
Some tools for debugging on existing Log and Computations
|
org.nuxeo.lib.stream.tools.command | |
org.nuxeo.lib.stream.tools.renderer | |
org.nuxeo.runtime.pubsub | |
org.nuxeo.runtime.stream |
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
Class and Description |
---|
LogAppender
An appender is used to append message into a Log.
|
LogManager
Manage Log and give access to Appenders and Tailers.
|
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
Class and Description |
---|
LogAppender
An appender is used to append message into a Log.
|
LogManager
Manage Log and give access to Appenders and Tailers.
|
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogTailer
Sequential reader for a partition or multiple partitions.
|
Class and Description |
---|
Latency
Extends LogLag with lower and upper timestamps to express lag as a latency.
|
LogOffset
A message position in a partition.
|
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogOffset
A message position in a partition.
|
Class and Description |
---|
Latency
Extends LogLag with lower and upper timestamps to express lag as a latency.
|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogPartition
A tuple to store a Log name and the partition index.
|
LogTailer
Sequential reader for a partition or multiple partitions.
|
RebalanceListener
Listener to be notified on partition rebalancing.
|
Class and Description |
---|
Latency
Extends LogLag with lower and upper timestamps to express lag as a latency.
|
LogAppender
An appender is used to append message into a Log.
|
LogLag
Represent the number of messages between 2 offsets
|
LogOffset
A message position in a partition.
|
LogPartition
A tuple to store a Log name and the partition index.
|
LogRecord
A LogRecord contains the message and its offset.
|
LogTailer
Sequential reader for a partition or multiple partitions.
|
RebalanceListener
Listener to be notified on partition rebalancing.
|
Class and Description |
---|
LogAppender
An appender is used to append message into a Log.
|
LogLag
Represent the number of messages between 2 offsets
|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogOffset
A message position in a partition.
|
LogPartition
A tuple to store a Log name and the partition index.
|
LogRecord
A LogRecord contains the message and its offset.
|
LogTailer
Sequential reader for a partition or multiple partitions.
|
RebalanceListener
Listener to be notified on partition rebalancing.
|
Class and Description |
---|
Latency
Extends LogLag with lower and upper timestamps to express lag as a latency.
|
LogAppender
An appender is used to append message into a Log.
|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogOffset
A message position in a partition.
|
LogPartition
A tuple to store a Log name and the partition index.
|
LogTailer
Sequential reader for a partition or multiple partitions.
|
RebalanceListener
Listener to be notified on partition rebalancing.
|
Class and Description |
---|
LogAppender
An appender is used to append message into a Log.
|
LogLag
Represent the number of messages between 2 offsets
|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogOffset
A message position in a partition.
|
LogPartition
A tuple to store a Log name and the partition index.
|
LogRecord
A LogRecord contains the message and its offset.
|
LogTailer
Sequential reader for a partition or multiple partitions.
|
RebalanceListener
Listener to be notified on partition rebalancing.
|
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogPartition
A tuple to store a Log name and the partition index.
|
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogPartition
A tuple to store a Log name and the partition index.
|
LogTailer
Sequential reader for a partition or multiple partitions.
|
RebalanceListener
Listener to be notified on partition rebalancing.
|
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
Class and Description |
---|
LogAppender
An appender is used to append message into a Log.
|
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
Class and Description |
---|
Latency
Extends LogLag with lower and upper timestamps to express lag as a latency.
|
LogLag
Represent the number of messages between 2 offsets
|
LogManager
Manage Log and give access to Appenders and Tailers.
|
LogOffset
A message position in a partition.
|
LogTailer
Sequential reader for a partition or multiple partitions.
|
Class and Description |
---|
LogRecord
A LogRecord contains the message and its offset.
|
Class and Description |
---|
LogAppender
An appender is used to append message into a Log.
|
Class and Description |
---|
LogManager
Manage Log and give access to Appenders and Tailers.
|
Copyright © 2019 Nuxeo. All rights reserved.