Package com.linkedin.venice.pubsub.mock
Class InMemoryPubSubPositionFactory
java.lang.Object
com.linkedin.venice.pubsub.PubSubPositionFactory
com.linkedin.venice.pubsub.mock.InMemoryPubSubPositionFactory
-
Constructor Summary
ConstructorsConstructorDescriptionInMemoryPubSubPositionFactory
(int positionTypeId) Constructs a factory with the given position type ID. -
Method Summary
Modifier and TypeMethodDescriptioncreateFromByteBuffer
(ByteBuffer buffer) Deserializes aPubSubPosition
from the given byte buffer.static PubSubPositionTypeRegistry
Returns the fully qualified class name of thePubSubPosition
implementation handled by this factory.Methods inherited from class com.linkedin.venice.pubsub.PubSubPositionFactory
createFromWireFormat, getPositionTypeId
-
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
-
createFromByteBuffer
Description copied from class:PubSubPositionFactory
Deserializes aPubSubPosition
from the given byte buffer.- Specified by:
createFromByteBuffer
in classPubSubPositionFactory
- Parameters:
buffer
- the byte buffer containing the serialized position- Returns:
- a new
PubSubPosition
instance
-
getPubSubPositionClassName
Description copied from class:PubSubPositionFactory
Returns the fully qualified class name of thePubSubPosition
implementation handled by this factory.- Specified by:
getPubSubPositionClassName
in classPubSubPositionFactory
- Returns:
- the fully qualified class name of the associated position class
-
getPositionTypeRegistryWithInMemoryPosition
-