Package com.linkedin.davinci.store.memory

Class InMemoryStorageEngineFactory

java.lang.Object

com.linkedin.davinci.store.StorageEngineFactory

com.linkedin.davinci.store.memory.InMemoryStorageEngineFactory

public class InMemoryStorageEngineFactory
extends StorageEngineFactory

Constructor Summary

Constructors

Constructor	Description
InMemoryStorageEngineFactory(VeniceServerConfig serverConfig)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the storage configuration
void	closeStorageEngine(AbstractStorageEngine engine)	Close the storage engine from the underlying storage configuration
java.util.Set<java.lang.String>	getPersistedStoreNames()	Retrieve all the stores persisted previously
PersistenceType	getPersistenceType()	Return the persistence type current factory supports.
AbstractStorageEngine	getStorageEngine(VeniceStoreVersionConfig storeConfig)	Get an initialized storage implementation
void	removeStorageEngine(AbstractStorageEngine engine)	Remove the storage engine from the underlying storage configuration
void	removeStorageEngine(java.lang.String storeName)	Remove the storage engine without opening it.
void	removeStorageEnginePartition(java.lang.String storeName, int partition)

Methods inherited from class com.linkedin.davinci.store.StorageEngineFactory

getStorageEngine, verifyPersistenceType, verifyPersistenceType

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryStorageEngineFactory

public InMemoryStorageEngineFactory(VeniceServerConfig serverConfig)

Method Detail

getStorageEngine

public AbstractStorageEngine getStorageEngine(VeniceStoreVersionConfig storeConfig)
                                       throws StorageInitializationException

Description copied from class: StorageEngineFactory

Get an initialized storage implementation

Specified by:

getStorageEngine in class StorageEngineFactory

Parameters:

storeConfig - store definition

Returns:

The storage engine

Throws:

StorageInitializationException

getPersistedStoreNames

public java.util.Set<java.lang.String> getPersistedStoreNames()

Description copied from class: StorageEngineFactory

Retrieve all the stores persisted previously

Specified by:

getPersistedStoreNames in class StorageEngineFactory

Returns:

All the store names

close

public void close()

Description copied from class: StorageEngineFactory

Close the storage configuration

Specified by:

close in class StorageEngineFactory

removeStorageEngine

public void removeStorageEngine(AbstractStorageEngine engine)

Description copied from class: StorageEngineFactory

Remove the storage engine from the underlying storage configuration

Specified by:

removeStorageEngine in class StorageEngineFactory

Parameters:

engine - Specifies the storage engine to be removed

removeStorageEngine

public void removeStorageEngine(java.lang.String storeName)

Description copied from class: StorageEngineFactory

Remove the storage engine without opening it.

Specified by:

removeStorageEngine in class StorageEngineFactory

removeStorageEnginePartition

public void removeStorageEnginePartition(java.lang.String storeName,
                                         int partition)

Specified by:

removeStorageEnginePartition in class StorageEngineFactory

closeStorageEngine

public void closeStorageEngine(AbstractStorageEngine engine)

Description copied from class: StorageEngineFactory

Close the storage engine from the underlying storage configuration

Specified by:

closeStorageEngine in class StorageEngineFactory

Parameters:

engine - Specifies the storage engine to be removed

getPersistenceType

public PersistenceType getPersistenceType()

Description copied from class: StorageEngineFactory

Return the persistence type current factory supports.

Specified by:

getPersistenceType in class StorageEngineFactory

Returns: