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

Class MemLogPartition

java.lang.Object

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

public class MemLogPartition
extends Object

Memory implementation of Log partition.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	MemLogPartition.BytesAndOffset
class	MemLogPartition.MemPartitionTailer	A tailer for a partition maintains an offset (current reading position).
static class	MemLogPartition.OffsetTracker	Tracks the committed offset for a group.

Constructor Summary

Constructors

Constructor	Description
MemLogPartition()

Method Summary

Modifier and Type	Method	Description
long	append(String tag, byte[] bytes)
void	closeTailer(Name group)
long	committed(Name group)
MemLogPartition.MemPartitionTailer	createTailer(Name group)
MemLogPartition.OffsetTracker	getCommittedOffsetTracker(Name group)
Set<Name>	getGroups()
long	size()

Methods inherited from class java.lang.Object

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

Constructor Details

MemLogPartition

public MemLogPartition()

Method Details

append

public long append(String tag,
 byte[] bytes)

size

public long size()

getCommittedOffsetTracker

public MemLogPartition.OffsetTracker getCommittedOffsetTracker(Name group)

createTailer

public MemLogPartition.MemPartitionTailer createTailer(Name group)

closeTailer

public void closeTailer(Name group)

getGroups

public Set<Name> getGroups()

committed

public long committed(Name group)