Package com.linkedin.venice.pubsub.mock

Class InMemoryPubSubPositionFactory

java.lang.Object

com.linkedin.venice.pubsub.PubSubPositionFactory

com.linkedin.venice.pubsub.mock.InMemoryPubSubPositionFactory

public class InMemoryPubSubPositionFactory
extends PubSubPositionFactory

Constructor Summary

Constructors

Constructor	Description
InMemoryPubSubPositionFactory(int positionTypeId)	Constructs a factory with the given position type ID.

Method Summary

Modifier and Type	Method	Description
PubSubPosition	fromPositionRawBytes(ByteBuffer buffer)	Deserializes a PubSubPosition from the given byte buffer.
static PubSubPositionTypeRegistry	getPositionTypeRegistryWithInMemoryPosition()
String	getPubSubPositionClassName()	Returns the fully qualified class name of the PubSubPosition implementation handled by this factory.

Methods inherited from class com.linkedin.venice.pubsub.PubSubPositionFactory

fromPositionRawBytes, fromWireFormat, getPositionTypeId

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryPubSubPositionFactory

public InMemoryPubSubPositionFactory(int positionTypeId)

Constructs a factory with the given position type ID.

Parameters:

positionTypeId - the unique integer identifier for the position type

Method Details

fromPositionRawBytes

public PubSubPosition fromPositionRawBytes(ByteBuffer buffer)

Description copied from class: PubSubPositionFactory

Deserializes a PubSubPosition from the given byte buffer.

Specified by:

fromPositionRawBytes in class PubSubPositionFactory

Parameters:

buffer - the byte buffer containing the serialized position (does not include type ID)

Returns:

a new PubSubPosition instance

getPubSubPositionClassName

public String getPubSubPositionClassName()

Description copied from class: PubSubPositionFactory

Returns the fully qualified class name of the PubSubPosition implementation handled by this factory.

Specified by:

getPubSubPositionClassName in class PubSubPositionFactory

Returns:

the fully qualified class name of the associated position class

getPositionTypeRegistryWithInMemoryPosition

public static PubSubPositionTypeRegistry getPositionTypeRegistryWithInMemoryPosition()