Uses of Interface
org.nuxeo.lib.stream.log.LogOffset

Packages that use LogOffset

Package	Description
org.nuxeo.ecm.core.event.stream
org.nuxeo.ecm.core.search.index
org.nuxeo.ecm.core.work
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 In-Memory and Kafka implementation.
org.nuxeo.lib.stream.log.internals
org.nuxeo.lib.stream.log.kafka
org.nuxeo.lib.stream.log.mem
org.nuxeo.lib.stream.tools.command

Uses of LogOffset in org.nuxeo.ecm.core.event.stream

Methods in org.nuxeo.ecm.core.event.stream that return types with arguments of type LogOffset

Modifier and Type	Method	Description
List<LogOffset>	DomainEventProducer.maxPerPartition(List<LogOffset> offsets)	Helper that returns the higher offsets per partitions.

Method parameters in org.nuxeo.ecm.core.event.stream with type arguments of type LogOffset

Modifier and Type	Method	Description
List<LogOffset>	DomainEventProducer.maxPerPartition(List<LogOffset> offsets)	Helper that returns the higher offsets per partitions.
void	DomainEventProducer.postCommitHook(List<LogOffset> offsets)	This hook is called once the records have been produced downstream, providing the list of produced record offsets.

Uses of LogOffset in org.nuxeo.ecm.core.search.index

Method parameters in org.nuxeo.ecm.core.search.index with type arguments of type LogOffset

Modifier and Type	Method	Description
void	IndexingDomainEventProducer.postCommitHook(List<LogOffset> offsets)

Uses of LogOffset in org.nuxeo.ecm.core.work

Methods in org.nuxeo.ecm.core.work with parameters of type LogOffset

Modifier and Type	Method	Description
Record	BaseOverflowRecordFilter.afterRead(Record record, LogOffset offset)

Uses of LogOffset in org.nuxeo.lib.stream.computation

Methods in org.nuxeo.lib.stream.computation that return LogOffset

Modifier and Type	Method	Description
LogOffset	StreamManager.append(String stream, Record record)	Appends a record to a processor's source stream.
LogOffset	ComputationContext.getLastOffset()

Methods in org.nuxeo.lib.stream.computation with parameters of type LogOffset

Modifier and Type	Method	Description
default void	RecordFilter.afterAppend(Record record, LogOffset offset)	Called after a record is appended to a stream.
default Record	RecordFilter.afterRead(Record record, LogOffset offset)	Called after reading a record.
boolean	StreamManager.waitFor(String stream, Name group, LogOffset offset, Duration timeout)	Wait for a consumer group to process the stream up to the given offset.

Uses of LogOffset in org.nuxeo.lib.stream.computation.internals

Fields in org.nuxeo.lib.stream.computation.internals declared as LogOffset

Modifier and Type	Field	Description
protected LogOffset	ComputationContextImpl.lastOffset

Methods in org.nuxeo.lib.stream.computation.internals that return LogOffset

Modifier and Type	Method	Description
LogOffset	ComputationContextImpl.getLastOffset()
LogOffset	ComputationContextImpl.produceRecordImmediate(String streamName, Record record)	Writes to an output stream immediately.

Methods in org.nuxeo.lib.stream.computation.internals with parameters of type LogOffset

Modifier and Type	Method	Description
void	RecordFilterChainImpl.afterAppend(Record record, LogOffset offset)
Record	RecordFilterChainImpl.afterRead(Record record, LogOffset offset)
void	ComputationContextImpl.setLastOffset(LogOffset lastOffset)

Uses of LogOffset in org.nuxeo.lib.stream.computation.log

Methods in org.nuxeo.lib.stream.computation.log that return LogOffset

Modifier and Type	Method	Description
LogOffset	LogStreamManager.append(String streamUrn, Record record)

Methods in org.nuxeo.lib.stream.computation.log with parameters of type LogOffset

Modifier and Type	Method	Description
boolean	LogStreamManager.waitFor(String streamUrn, Name group, LogOffset offset, Duration timeout)

Uses of LogOffset in org.nuxeo.lib.stream.log

Fields in org.nuxeo.lib.stream.log declared as LogOffset

Modifier and Type	Field	Description
protected final LogOffset	LogRecord.offset

Methods in org.nuxeo.lib.stream.log that return LogOffset

Modifier and Type	Method	Description
LogOffset	LogAppender.append(int partition, M message)	Append a message into a partition, returns LogOffset position of the message.
default LogOffset	LogAppender.append(String key, M message)	Same as LogAppender.append(int, Externalizable), the queue is chosen using a hash of parameters "key".
LogOffset	LogTailer.commit(LogPartition partition)	Commit current position for the partition.
LogOffset	LogOffset.nextOffset()	Returns the next offset corresponding to the next position in the same partition.
LogOffset	LogRecord.offset()
LogOffset	LogTailer.offsetForTimestamp(LogPartition partition, long timestamp)	Look up the offset for the given partition by timestamp.

Methods in org.nuxeo.lib.stream.log with parameters of type LogOffset

Modifier and Type	Method	Description
void	LogTailer.seek(LogOffset offset)	Set the current position for a single partition.
boolean	LogAppender.waitFor(LogOffset offset, Name group, Duration timeout)	Wait for consumer to process a message up to the offset.

Constructors in org.nuxeo.lib.stream.log with parameters of type LogOffset

Modifier	Constructor	Description
	LogRecord(M message, LogOffset offset)

Uses of LogOffset in org.nuxeo.lib.stream.log.internals

Classes in org.nuxeo.lib.stream.log.internals that implement LogOffset

Modifier and Type	Class	Description
class	LogOffsetImpl

Methods in org.nuxeo.lib.stream.log.internals that return LogOffset

Modifier and Type	Method	Description
LogOffset	LogOffsetImpl.nextOffset()

Methods in org.nuxeo.lib.stream.log.internals with parameters of type LogOffset

Modifier and Type	Method	Description
int	LogOffsetImpl.compareTo(LogOffset o)

Uses of LogOffset in org.nuxeo.lib.stream.log.kafka

Methods in org.nuxeo.lib.stream.log.kafka that return LogOffset

Modifier and Type	Method	Description
LogOffset	KafkaLogAppender.append(int partition, String key, M message)
LogOffset	KafkaLogAppender.append(int partition, M message)
LogOffset	KafkaLogAppender.append(String key, M message)
LogOffset	KafkaLogTailer.commit(LogPartition partition)
LogOffset	KafkaLogTailer.offsetForTimestamp(LogPartition partition, long timestamp)

Methods in org.nuxeo.lib.stream.log.kafka with parameters of type LogOffset

Modifier and Type	Method	Description
void	KafkaLogTailer.seek(LogOffset offset)
boolean	KafkaLogAppender.waitFor(LogOffset offset, Name group, Duration timeout)

Uses of LogOffset in org.nuxeo.lib.stream.log.mem

Methods in org.nuxeo.lib.stream.log.mem that return LogOffset

Modifier and Type	Method	Description
LogOffset	MemLogAppender.append(int partition, M message)
LogOffset	MemCompoundLogTailer.commit(LogPartition partition)
LogOffset	MemLogTailer.commit(LogPartition partition)
LogOffset	MemCompoundLogTailer.offsetForTimestamp(LogPartition partition, long timestamp)
LogOffset	MemLogTailer.offsetForTimestamp(LogPartition partition, long timestamp)

Methods in org.nuxeo.lib.stream.log.mem with parameters of type LogOffset

Modifier and Type	Method	Description
void	MemCompoundLogTailer.seek(LogOffset offset)
void	MemLogTailer.seek(LogOffset offset)
boolean	MemLogAppender.waitFor(LogOffset logOffset, Name group, Duration timeout)

Uses of LogOffset in org.nuxeo.lib.stream.tools.command

Methods in org.nuxeo.lib.stream.tools.command that return LogOffset

Modifier and Type	Method	Description
protected LogOffset	RestoreCommand.findOffset(LogManager manager, LogPartitionGroup key, Latency latency)
protected LogOffset	PositionCommand.searchWatermarkOffset(LogTailer<Record> tailer, long timestamp)

Methods in org.nuxeo.lib.stream.tools.command that return types with arguments of type LogOffset

Modifier and Type	Method	Description
protected Map<LogPartitionGroup,LogOffset>	RestoreCommand.searchOffsets(LogManager manager, Map<LogPartitionGroup,Latency> latencies)

Methods in org.nuxeo.lib.stream.tools.command with parameters of type LogOffset

Modifier and Type	Method	Description
protected void	RestoreCommand.updatePosition(LogManager manager, LogPartitionGroup key, LogOffset offset)

Method parameters in org.nuxeo.lib.stream.tools.command with type arguments of type LogOffset

Modifier and Type	Method	Description
protected void	RestoreCommand.updatePositions(LogManager manager, Map<LogPartitionGroup,LogOffset> offsets)