Package com.linkedin.venice.pubsub.mock

Class InMemoryPubSubPosition

java.lang.Object

com.linkedin.venice.pubsub.mock.InMemoryPubSubPosition

All Implemented Interfaces:

Measurable, PubSubPosition

public class InMemoryPubSubPosition
extends Object
implements PubSubPosition

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	getHeapSize()
long	getInternalOffset()	Returns the internal offset used by this implementation.
InMemoryPubSubPosition	getNextPosition()	Only InMemoryPubSubPosition supports this kind of API
long	getNumericOffset()
InMemoryPubSubPosition	getPositionAfterNRecords(long n)	Get position that is after the current position by n records.
PubSubPositionWireFormat	getPositionWireFormat()	Position wrapper is used to wrap the position type and the position value.
InMemoryPubSubPosition	getPreviousPosition()
int	hashCode()
static InMemoryPubSubPosition	of(long offset)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.linkedin.venice.pubsub.api.PubSubPosition

getWireFormatBytes

Method Details

getNumericOffset

public long getNumericOffset()

Specified by:

getNumericOffset in interface PubSubPosition

getInternalOffset

public long getInternalOffset()

Returns the internal offset used by this implementation.

This method was added to support test cases that rely on accessing the internal offset directly, without depending on getNumericOffset(), which will be removed from the interface in the future.

Returns:

the internal offset value

of

public static InMemoryPubSubPosition of(long offset)

getPositionWireFormat

public PubSubPositionWireFormat getPositionWireFormat()

Description copied from interface: PubSubPosition

Position wrapper is used to wrap the position type and the position value. This is used to serialize and deserialize the position object when sending and receiving it over the wire.

Specified by:

getPositionWireFormat in interface PubSubPosition

Returns:

the position wrapper

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable

getNextPosition

public InMemoryPubSubPosition getNextPosition()

Only InMemoryPubSubPosition supports this kind of API

Returns:

a new InMemoryPubSubPosition with the internal offset incremented by 1

getPreviousPosition

public InMemoryPubSubPosition getPreviousPosition()

getPositionAfterNRecords

public InMemoryPubSubPosition getPositionAfterNRecords(long n)

Get position that is after the current position by n records.

Parameters:

n - the number of records to skip

Returns:

a new InMemoryPubSubPosition with the internal offset incremented by n

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Specified by:

equals in interface PubSubPosition

Overrides:

equals in class Object

hashCode

public int hashCode()

Specified by:

hashCode in interface PubSubPosition

Overrides:

hashCode in class Object