com.espertech.esper.core.context.mgr
Interface ContextManager

All Superinterfaces:

FilterFaultHandler

All Known Implementing Classes:

ContextManagerImpl, ContextManagerNested

public interface ContextManager
extends FilterFaultHandler

Method Summary

void	addStatement(ContextControllerStatementBase statement, boolean isRecoveringResilient)
void	destroyStatement(java.lang.String statementName, int statementId)
ContextStatePathDescriptor	extractDestroyPaths(ContextPartitionSelector contextPartitionSelector)
ContextStatePathDescriptor	extractPaths(ContextPartitionSelector contextPartitionSelector)
ContextStatePathDescriptor	extractStopPaths(ContextPartitionSelector contextPartitionSelector)
java.util.Collection<java.lang.Integer>	getAgentInstanceIds(ContextPartitionSelector contextPartitionSelector)
ContextDescriptor	getContextDescriptor()
ContextStateCache	getContextStateCache()
FilterSpecLookupable	getFilterLookupable(EventType eventType)
int	getNumNestingLevels()
java.util.Map<java.lang.Integer,ContextControllerStatementDesc>	getStatements()
void	importStartPaths(ContextControllerState state, AgentInstanceSelector agentInstanceSelector)
void	safeDestroy()
java.util.Map<java.lang.Integer,ContextPartitionDescriptor>	startPaths(ContextPartitionSelector contextPartitionSelector)
void	stopStatement(java.lang.String statementName, int statementId)

Methods inherited from interface com.espertech.esper.filter.FilterFaultHandler

handleFilterFault

Method Detail

getContextDescriptor

ContextDescriptor getContextDescriptor()

getNumNestingLevels

int getNumNestingLevels()

getContextStateCache

ContextStateCache getContextStateCache()

addStatement

void addStatement(ContextControllerStatementBase statement,
                  boolean isRecoveringResilient)
                  throws ExprValidationException

Throws:

ExprValidationException

stopStatement

void stopStatement(java.lang.String statementName,
                   int statementId)

destroyStatement

void destroyStatement(java.lang.String statementName,
                      int statementId)

safeDestroy

void safeDestroy()

getFilterLookupable

FilterSpecLookupable getFilterLookupable(EventType eventType)

extractPaths

ContextStatePathDescriptor extractPaths(ContextPartitionSelector contextPartitionSelector)

extractStopPaths

ContextStatePathDescriptor extractStopPaths(ContextPartitionSelector contextPartitionSelector)

extractDestroyPaths

ContextStatePathDescriptor extractDestroyPaths(ContextPartitionSelector contextPartitionSelector)

importStartPaths

void importStartPaths(ContextControllerState state,
                      AgentInstanceSelector agentInstanceSelector)

startPaths

java.util.Map<java.lang.Integer,ContextPartitionDescriptor> startPaths(ContextPartitionSelector contextPartitionSelector)

getAgentInstanceIds

java.util.Collection<java.lang.Integer> getAgentInstanceIds(ContextPartitionSelector contextPartitionSelector)

getStatements

java.util.Map<java.lang.Integer,ContextControllerStatementDesc> getStatements()