Package com.espertech.esper.common.internal.collection

Class PathRegistry<K,E>

java.lang.Object

com.espertech.esper.common.internal.collection.PathRegistry<K,E>

public class PathRegistry<K,E>
extends Object

Constructor Summary

Constructors

Constructor	Description
PathRegistry(PathRegistryObjectType objectType)

Method Summary

Modifier and Type	Method	Description
void	add(K entityKey, String moduleName, E entity, String deploymentId)
void	addDependency(K entityKey, String moduleName, String deploymentIdDep)
void	addEntry(K entityKey, String moduleName, PathDeploymentEntry<E> entity)
PathRegistry<K,E>	copy()
void	deleteDeployment(String deploymentId)
Pair<E,String>	getAnyModuleExpectSingle(K entityKey, Set<String> moduleUses)
int	getCount()
Set<String>	getDependencies(K entityKey, String moduleName)
String	getDeploymentId(K entityEntity, String moduleName)
PathDeploymentEntry<E>	getEntryWithModule(K entityKey, String moduleName)
PathRegistryObjectType	getObjectType()
E	getWithModule(K entityKey, String moduleName)
boolean	isEmpty()
void	mergeFrom(PathRegistry<K,E> other)
void	mergeFromCheckDuplicate(PathRegistry<K,E> other, String moduleName)
void	removeDependency(K entityKey, String moduleName, String deploymentId)
void	traverse(Consumer<E> consumer)
void	traverseWithModule(BiConsumer<String,E> consumer)

Methods inherited from class java.lang.Object

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

Constructor Details

PathRegistry

public PathRegistry(PathRegistryObjectType objectType)

Method Details

getObjectType

public PathRegistryObjectType getObjectType()

add

public void add(K entityKey,
 String moduleName,
 E entity,
 String deploymentId)
         throws PathException

Throws:

PathException

addEntry

public void addEntry(K entityKey,
 String moduleName,
 PathDeploymentEntry<E> entity)
              throws PathException

Throws:

PathException

getAnyModuleExpectSingle

public Pair<E,String> getAnyModuleExpectSingle(K entityKey,
 Set<String> moduleUses)
                                        throws PathException

Throws:

PathException

getWithModule

public E getWithModule(K entityKey,
 String moduleName)

getEntryWithModule

public PathDeploymentEntry<E> getEntryWithModule(K entityKey,
 String moduleName)

getDeploymentId

public String getDeploymentId(K entityEntity,
 String moduleName)

deleteDeployment

public void deleteDeployment(String deploymentId)

getCount

public int getCount()

addDependency

public void addDependency(K entityKey,
 String moduleName,
 String deploymentIdDep)

getDependencies

public Set<String> getDependencies(K entityKey,
 String moduleName)

removeDependency

public void removeDependency(K entityKey,
 String moduleName,
 String deploymentId)

traverse

public void traverse(Consumer<E> consumer)

traverseWithModule

public void traverseWithModule(BiConsumer<String,E> consumer)

mergeFrom

public void mergeFrom(PathRegistry<K,E> other)

mergeFromCheckDuplicate

public void mergeFromCheckDuplicate(PathRegistry<K,E> other,
 String moduleName)
                             throws PathExceptionAlreadyRegistered

Throws:

PathExceptionAlreadyRegistered

copy

public PathRegistry<K,E> copy()

isEmpty

public boolean isEmpty()