Package com.linkedin.venice.persona

Class StoragePersonaAccessor

java.lang.Object

com.linkedin.venice.persona.StoragePersonaAccessor

public class StoragePersonaAccessor
extends Object

Zookeeper accessor for StoragePersona objects, allowing for read/write to persona paths.

The data structure on ZK would be: /Persona/StoragePersona/$name, where $name is specified at creation. Nothing in the accessor is cached locally.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	STORAGE_PERSONA_SUB_PATH

Constructor Summary

Constructors

Constructor	Description
StoragePersonaAccessor(String clusterName, HelixAdapterSerializer adapter, org.apache.helix.zookeeper.impl.client.ZkClient zkClient)

Method Summary

Modifier and Type	Method	Description
boolean	containsPersona(String name)
void	createPersona(StoragePersona persona)
void	createPersona(String name, long quotaNumber, Set<String> storesToEnforce, Set<String> owners)	Note that this method does not return an error if the persona already exists.
void	deletePersona(StoragePersona persona)
void	deletePersona(String personaName)
List<StoragePersona>	getAllPersonasFromZk()
StoragePersona	getPersonaFromZk(String name)
void	updatePersona(StoragePersona persona)

Methods inherited from class java.lang.Object

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

Field Details

STORAGE_PERSONA_SUB_PATH

public static final String STORAGE_PERSONA_SUB_PATH

See Also:

• Constant Field Values

Constructor Details

StoragePersonaAccessor

public StoragePersonaAccessor(String clusterName,
 HelixAdapterSerializer adapter,
 org.apache.helix.zookeeper.impl.client.ZkClient zkClient)

Method Details

createPersona

public void createPersona(String name,
 long quotaNumber,
 Set<String> storesToEnforce,
 Set<String> owners)

Note that this method does not return an error if the persona already exists. It is up to the caller, i.e. StoragePersonaRepository to throw an error in this case.

createPersona

public void createPersona(StoragePersona persona)

updatePersona

public void updatePersona(StoragePersona persona)

deletePersona

public void deletePersona(StoragePersona persona)

deletePersona

public void deletePersona(String personaName)

containsPersona

public boolean containsPersona(String name)

getPersonaFromZk

public StoragePersona getPersonaFromZk(String name)

getAllPersonasFromZk

public List<StoragePersona> getAllPersonasFromZk()