Package org.nuxeo.lib.stream.log.mem

Class MemLogPartition.OffsetTracker

java.lang.Object

org.nuxeo.lib.stream.log.mem.MemLogPartition.OffsetTracker

Enclosing class:

MemLogPartition

public static class MemLogPartition.OffsetTracker
extends Object

Tracks the committed offset for a group.

Constructor Summary

Constructors

Constructor	Description
OffsetTracker()

Method Summary

Modifier and Type	Method	Description
long	awaitNanos(long nanos)
long	get()
void	set(long offset)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OffsetTracker

public OffsetTracker()

Method Details

get

public long get()

set

public void set(long offset)

awaitNanos

public long awaitNanos(long nanos)
                throws InterruptedException

Throws:

InterruptedException