com.espertech.esper.common.internal.metrics.audit

Class AuditProviderDefault

java.lang.Object

com.espertech.esper.common.internal.metrics.audit.AuditProviderDefault

All Implemented Interfaces:

AuditProvider, AuditProviderContextPartition, AuditProviderDataflowOp, AuditProviderDataflowSource, AuditProviderDataflowTransition, AuditProviderExprDef, AuditProviderExpression, AuditProviderInsert, AuditProviderPattern, AuditProviderPatternInstances, AuditProviderProperty, AuditProviderSchedule, AuditProviderStream, AuditProviderView

public class AuditProviderDefault
extends Object
implements AuditProvider

Field Summary

Fields

Modifier and Type	Field and Description
static AuditProviderDefault	INSTANCE

Method Summary

Modifier and Type	Method and Description
boolean	activated()
void	contextPartition(boolean allocate, AgentInstanceContext agentInstanceContext)
void	dataflowOp(String dataFlowName, String instanceId, String operatorName, int operatorNumber, Object[] parameters, AgentInstanceContext agentInstanceContext)
void	dataflowSource(String dataFlowName, String dataFlowInstanceId, String operatorName, int operatorNumber, AgentInstanceContext agentInstanceContext)
void	dataflowTransition(String dataflowName, String dataFlowInstanceId, EPDataFlowState state, EPDataFlowState newState, AgentInstanceContext agentInstanceContext)
void	exprdef(String name, Object value, ExprEvaluatorContext exprEvaluatorContext)
void	expression(String text, Object value, ExprEvaluatorContext exprEvaluatorContext)
void	insert(EventBean event, ExprEvaluatorContext exprEvaluatorContext)
void	patternFalse(EvalFactoryNode factoryNode, Object from, AgentInstanceContext agentInstanceContext)
void	patternInstance(boolean increase, EvalFactoryNode factoryNode, AgentInstanceContext agentInstanceContext)
void	patternTrue(EvalFactoryNode factoryNode, Object from, MatchedEventMapMinimal matchEvent, boolean isQuitted, AgentInstanceContext agentInstanceContext)
void	property(String name, Object value, ExprEvaluatorContext exprEvaluatorContext)
void	scheduleAdd(long nextScheduledTime, AgentInstanceContext agentInstanceContext, ScheduleHandle scheduleHandle, ScheduleObjectType type, String name)
void	scheduleFire(AgentInstanceContext agentInstanceContext, ScheduleObjectType type, String name)
void	scheduleRemove(AgentInstanceContext agentInstanceContext, ScheduleHandle scheduleHandle, ScheduleObjectType type, String name)
void	stream(EventBean[] newData, EventBean[] oldData, ExprEvaluatorContext context, String filterSpecText)
void	stream(EventBean event, ExprEvaluatorContext context, String filterSpecText)
void	view(EventBean[] newData, EventBean[] oldData, AgentInstanceContext agentInstanceContext, ViewFactory viewFactory)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final AuditProviderDefault INSTANCE

Method Detail

activated

public boolean activated()

Specified by:

activated in interface AuditProvider

view

public void view(EventBean[] newData,
                 EventBean[] oldData,
                 AgentInstanceContext agentInstanceContext,
                 ViewFactory viewFactory)

Specified by:

view in interface AuditProviderView

stream

public void stream(EventBean event,
                   ExprEvaluatorContext context,
                   String filterSpecText)

Specified by:

stream in interface AuditProviderStream

stream

public void stream(EventBean[] newData,
                   EventBean[] oldData,
                   ExprEvaluatorContext context,
                   String filterSpecText)

Specified by:

stream in interface AuditProviderStream

scheduleAdd

public void scheduleAdd(long nextScheduledTime,
                        AgentInstanceContext agentInstanceContext,
                        ScheduleHandle scheduleHandle,
                        ScheduleObjectType type,
                        String name)

Specified by:

scheduleAdd in interface AuditProviderSchedule

scheduleRemove

public void scheduleRemove(AgentInstanceContext agentInstanceContext,
                           ScheduleHandle scheduleHandle,
                           ScheduleObjectType type,
                           String name)

Specified by:

scheduleRemove in interface AuditProviderSchedule

scheduleFire

public void scheduleFire(AgentInstanceContext agentInstanceContext,
                         ScheduleObjectType type,
                         String name)

Specified by:

scheduleFire in interface AuditProviderSchedule

property

public void property(String name,
                     Object value,
                     ExprEvaluatorContext exprEvaluatorContext)

Specified by:

property in interface AuditProviderProperty

insert

public void insert(EventBean event,
                   ExprEvaluatorContext exprEvaluatorContext)

Specified by:

insert in interface AuditProviderInsert

expression

public void expression(String text,
                       Object value,
                       ExprEvaluatorContext exprEvaluatorContext)

Specified by:

expression in interface AuditProviderExpression

patternTrue

public void patternTrue(EvalFactoryNode factoryNode,
                        Object from,
                        MatchedEventMapMinimal matchEvent,
                        boolean isQuitted,
                        AgentInstanceContext agentInstanceContext)

Specified by:

patternTrue in interface AuditProviderPattern

patternFalse

public void patternFalse(EvalFactoryNode factoryNode,
                         Object from,
                         AgentInstanceContext agentInstanceContext)

Specified by:

patternFalse in interface AuditProviderPattern

patternInstance

public void patternInstance(boolean increase,
                            EvalFactoryNode factoryNode,
                            AgentInstanceContext agentInstanceContext)

Specified by:

patternInstance in interface AuditProviderPatternInstances

exprdef

public void exprdef(String name,
                    Object value,
                    ExprEvaluatorContext exprEvaluatorContext)

Specified by:

exprdef in interface AuditProviderExprDef

dataflowTransition

public void dataflowTransition(String dataflowName,
                               String dataFlowInstanceId,
                               EPDataFlowState state,
                               EPDataFlowState newState,
                               AgentInstanceContext agentInstanceContext)

Specified by:

dataflowTransition in interface AuditProviderDataflowTransition

dataflowSource

public void dataflowSource(String dataFlowName,
                           String dataFlowInstanceId,
                           String operatorName,
                           int operatorNumber,
                           AgentInstanceContext agentInstanceContext)

Specified by:

dataflowSource in interface AuditProviderDataflowSource

dataflowOp

public void dataflowOp(String dataFlowName,
                       String instanceId,
                       String operatorName,
                       int operatorNumber,
                       Object[] parameters,
                       AgentInstanceContext agentInstanceContext)

Specified by:

dataflowOp in interface AuditProviderDataflowOp

contextPartition

public void contextPartition(boolean allocate,
                             AgentInstanceContext agentInstanceContext)

Specified by:

contextPartition in interface AuditProviderContextPartition