Package com.espertech.esper.common.internal.context.controller.keyed

Class ContextControllerKeyedSvcLevelOne

java.lang.Object

com.espertech.esper.common.internal.context.controller.keyed.ContextControllerKeyedSvcLevelOne

All Implemented Interfaces:

ContextControllerKeyedSvc

public class ContextControllerKeyedSvcLevelOne
extends Object
implements ContextControllerKeyedSvc

Constructor Summary

Constructors

Constructor	Description
ContextControllerKeyedSvcLevelOne()

Method Summary

Modifier and Type	Method	Description
Collection<Integer>	deactivate(IntSeqKey controllerPath)
void	destroy()
void	keyAdd(IntSeqKey controllerPath, Object key, int subpathIdOrCPId, ContextControllerConditionNonHA terminationCondition)
int	keyGetSubpathOrCPId(IntSeqKey controllerPath, Object key)
List<ContextControllerConditionNonHA>	keyGetTermConditions(IntSeqKey controllerPath)
boolean	keyHasSeen(IntSeqKey controllerPath, Object key)
ContextControllerKeyedSvcEntry	keyRemove(IntSeqKey controllerPath, Object key)
void	keyVisit(IntSeqKey controllerPath, BiConsumer<Object,Integer> keyAndSubpathOrCPId)
void	keyVisitEntry(IntSeqKey controllerPath, Consumer<ContextControllerKeyedSvcEntry> consumer)
void	mgmtCreate(IntSeqKey controllerPath, Object[] parentPartitionKeys)
ContextControllerFilterEntry[]	mgmtGetFilters(IntSeqKey controllerPath)
int	mgmtGetIncSubpath(IntSeqKey controllerPath)
Object[]	mgmtGetPartitionKeys(IntSeqKey controllerPath)
void	mgmtSetFilters(IntSeqKey controllerPath, ContextControllerFilterEntry[] filterEntries)

Methods inherited from class java.lang.Object

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

Constructor Details

ContextControllerKeyedSvcLevelOne

public ContextControllerKeyedSvcLevelOne()

Method Details

mgmtGetPartitionKeys

public Object[] mgmtGetPartitionKeys(IntSeqKey controllerPath)

Specified by:

mgmtGetPartitionKeys in interface ContextControllerKeyedSvc

mgmtGetIncSubpath

public int mgmtGetIncSubpath(IntSeqKey controllerPath)

Specified by:

mgmtGetIncSubpath in interface ContextControllerKeyedSvc

mgmtCreate

public void mgmtCreate(IntSeqKey controllerPath,
 Object[] parentPartitionKeys)

Specified by:

mgmtCreate in interface ContextControllerKeyedSvc

mgmtSetFilters

public void mgmtSetFilters(IntSeqKey controllerPath,
 ContextControllerFilterEntry[] filterEntries)

Specified by:

mgmtSetFilters in interface ContextControllerKeyedSvc

mgmtGetFilters

public ContextControllerFilterEntry[] mgmtGetFilters(IntSeqKey controllerPath)

Specified by:

mgmtGetFilters in interface ContextControllerKeyedSvc

keyHasSeen

public boolean keyHasSeen(IntSeqKey controllerPath,
 Object key)

Specified by:

keyHasSeen in interface ContextControllerKeyedSvc

keyAdd

public void keyAdd(IntSeqKey controllerPath,
 Object key,
 int subpathIdOrCPId,
 ContextControllerConditionNonHA terminationCondition)

Specified by:

keyAdd in interface ContextControllerKeyedSvc

keyRemove

public ContextControllerKeyedSvcEntry keyRemove(IntSeqKey controllerPath,
 Object key)

Specified by:

keyRemove in interface ContextControllerKeyedSvc

keyGetTermConditions

public List<ContextControllerConditionNonHA> keyGetTermConditions(IntSeqKey controllerPath)

Specified by:

keyGetTermConditions in interface ContextControllerKeyedSvc

keyVisit

public void keyVisit(IntSeqKey controllerPath,
 BiConsumer<Object,Integer> keyAndSubpathOrCPId)

Specified by:

keyVisit in interface ContextControllerKeyedSvc

keyVisitEntry

public void keyVisitEntry(IntSeqKey controllerPath,
 Consumer<ContextControllerKeyedSvcEntry> consumer)

Specified by:

keyVisitEntry in interface ContextControllerKeyedSvc

keyGetSubpathOrCPId

public int keyGetSubpathOrCPId(IntSeqKey controllerPath,
 Object key)

Specified by:

keyGetSubpathOrCPId in interface ContextControllerKeyedSvc

deactivate

public Collection<Integer> deactivate(IntSeqKey controllerPath)

Specified by:

deactivate in interface ContextControllerKeyedSvc

destroy

public void destroy()

Specified by:

destroy in interface ContextControllerKeyedSvc