Uses of Package
org.nuxeo.lib.stream.log
Packages that use org.nuxeo.lib.stream.log
Package
Description
The Computation pattern with a Log implementation.
Computation pattern implemented with Log
The Log interface with In-Memory and Kafka implementation.
Some tools for debugging on existing Log and Computations
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.ecm.core.bulkClassDescriptionAn 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.workClassDescriptionManage Log and give access to Appenders and Tailers.A message position in a partition.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.restapi.server.jaxrs.managementClassDescriptionRepresent the number of messages between 2 offsetsManage Log and give access to Appenders and Tailers.A LogRecord contains the message and its offset.Sequential reader for a partition or multiple partitions.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
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.importer.stream.consumerClassDescriptionAn appender is used to append message into a Log.Manage Log and give access to Appenders and Tailers.
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.importer.stream.producerClassDescriptionManage Log and give access to Appenders and Tailers.Sequential reader for a partition or multiple partitions.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.computationClassDescriptionExtends LogLag with lower and upper timestamps to express lag as a latency.A message position in a partition.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
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.computation.logClassDescriptionExtends LogLag with lower and upper timestamps to express lag as a latency.Manage Log and give access to Appenders and Tailers.A message position in a partition.A tuple to store a Log name and the partition index.Sequential reader for a partition or multiple partitions.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.Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.logClassDescriptionExtends LogLag with lower and upper timestamps to express lag as a latency.An appender is used to append message into a Log.Represent the number of messages between 2 offsetsManage Log and give access to Appenders and Tailers.A message position in a partition.A tuple to store a Log name and the partition index.A LogRecord contains the message and its offset.Sequential reader for a partition or multiple partitions.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.Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.log.internalsClassDescriptionExtends LogLag with lower and upper timestamps to express lag as a latency.An appender is used to append message into a Log.Represent the number of messages between 2 offsetsManage Log and give access to Appenders and Tailers.A message position in a partition.A tuple to store a Log name and the partition index.Sequential reader for a partition or multiple partitions.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.Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.log.kafkaClassDescriptionAn appender is used to append message into a Log.Represent the number of messages between 2 offsetsManage Log and give access to Appenders and Tailers.A message position in a partition.A tuple to store a Log name and the partition index.A LogRecord contains the message and its offset.Sequential reader for a partition or multiple partitions.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.Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.log.memClassDescriptionAn appender is used to append message into a Log.Represent the number of messages between 2 offsetsManage Log and give access to Appenders and Tailers.A message position in a partition.A tuple to store a Log name and the partition index.A LogRecord contains the message and its offset.Sequential reader for a partition or multiple partitions.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.Listener to be notified on partition rebalancing. -
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.pattern.consumerClassDescriptionManage Log and give access to Appenders and Tailers.A tuple to store a Log name and the partition index.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.internalsClassDescriptionManage Log and give access to Appenders and Tailers.A tuple to store a Log name and the partition index.Sequential reader for a partition or multiple partitions.Listener to be notified on partition rebalancing.
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.pattern.producer
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.pattern.producer.internals
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.tools
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.lib.stream.tools.commandClassDescriptionExtends LogLag with lower and upper timestamps to express lag as a latency.Represent the number of messages between 2 offsetsManage Log and give access to Appenders and Tailers.A message position in a partition.Sequential reader for a partition or multiple partitions.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
-
Classes in org.nuxeo.lib.stream.log used by org.nuxeo.runtime.pubsubClassDescriptionAn appender is used to append message into a Log.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.streamClassDescriptionExtends LogLag with lower and upper timestamps to express lag as a latency.Manage Log and give access to Appenders and Tailers.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.