Uses of Package
org.nuxeo.lib.stream.log
-
Packages that use org.nuxeo.lib.stream.log Package Description org.nuxeo.ecm.core.bulk 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 The Computation pattern with a Log implementation.org.nuxeo.lib.stream.computation.internals org.nuxeo.lib.stream.computation.log Computation pattern implemented with Logorg.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 Computationsorg.nuxeo.lib.stream.tools.command org.nuxeo.lib.stream.tools.renderer org.nuxeo.runtime.pubsub org.nuxeo.runtime.stream -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.ecm.core.bulk Class Description Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.ecm.core.work Class Description LogManager Manage Log and give access to Appenders and Tailers.LogOffset A message position in a partition.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.importer.stream.automation Class Description LogManager Manage Log and give access to Appenders and Tailers. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.importer.stream.consumer Class Description LogAppender An appender is used to append message into a Log.LogManager Manage Log and give access to Appenders and Tailers. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.importer.stream.producer Class Description LogManager Manage Log and give access to Appenders and Tailers.LogTailer Sequential reader for a partition or multiple partitions.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.computation Class Description Latency Extends LogLag with lower and upper timestamps to express lag as a latency.LogOffset A message position in a partition.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.computation.internals Class Description LogOffset A message position in a partition. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.computation.log Class 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.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.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical.RebalanceListener Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.log Class 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.LogConfig LogLag Represent the number of messages between 2 offsetsLogManager 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.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical.RebalanceListener Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.log.chronicle Class Description AbstractLogConfig LogAppender An appender is used to append message into a Log.LogConfig LogLag Represent the number of messages between 2 offsetsLogManager 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.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical.RebalanceListener Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.log.internals Class 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 offsetsLogManager 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.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical.RebalanceListener Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.log.kafka Class Description AbstractLogConfig LogAppender An appender is used to append message into a Log.LogConfig LogLag Represent the number of messages between 2 offsetsLogManager 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.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical.NameResolver RebalanceListener Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.pattern.consumer Class Description LogManager Manage Log and give access to Appenders and Tailers.LogPartition A tuple to store a Log name and the partition index.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.pattern.consumer.internals Class 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. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.pattern.producer Class Description LogManager Manage Log and give access to Appenders and Tailers. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.pattern.producer.internals Class Description LogAppender An appender is used to append message into a Log. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.tools Class Description LogManager Manage Log and give access to Appenders and Tailers. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.tools.command Class Description Latency Extends LogLag with lower and upper timestamps to express lag as a latency.LogLag Represent the number of messages between 2 offsetsLogManager 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.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.tools.renderer Class Description LogRecord A LogRecord contains the message and its offset. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.runtime.pubsub Class Description LogAppender An appender is used to append message into a Log.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.runtime.stream Class Description Latency Extends LogLag with lower and upper timestamps to express lag as a latency.LogConfig LogManager Manage Log and give access to Appenders and Tailers.Name An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical.