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

Field Summary

Fields

Modifier and Type	Field	Description
static final int	INMEMORY_PUBSUB_POSITION_TYPE_ID

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

PUBSUB_POSITION_WIRE_FORMAT_SERIALIZER

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Class<? extends PubSubPositionFactory>	getFactoryClass()	Returns the factory class responsible for creating this position type.
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)
static InMemoryPubSubPosition	of(ByteBuffer buffer)
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

getFactoryClassName, isSymbolic, toWireFormatBuffer, toWireFormatBytes

Field Details

INMEMORY_PUBSUB_POSITION_TYPE_ID

public static final int INMEMORY_PUBSUB_POSITION_TYPE_ID

See Also:

• Constant Field Values

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)

of

public static InMemoryPubSubPosition of(ByteBuffer buffer)

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

getFactoryClass

public Class<? extends PubSubPositionFactory> getFactoryClass()

Description copied from interface: PubSubPosition

Returns the factory class responsible for creating this position type. This enables strong type checking and reflection-based instantiation without requiring the actual factory instance to be returned.

Specified by:

getFactoryClass in interface PubSubPosition

Returns:

the class object of the factory that can construct this position

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