Package com.espertech.esper.common.internal.metrics.stmtmetrics

Interface MetricReportingService

public interface MetricReportingService
Metrics reporting service for instrumentation data publishing, if enabled.

  • Method Details

    • setContext

      void setContext(FilterService filterService, SchedulingService schedulingService, EventServiceSendEventCommon eventServiceSendEventInternal)

    • processTimeEvent

      void processTimeEvent(long currentTime)
      Indicates current runtime time.
      Parameters:
      currentTime - runtime time

    • destroy

      void destroy()
      Destroy the service.

    • accountTime

      void accountTime(StatementMetricHandle metricsHandle, long deltaCPU, long deltaWall, int numInput)
      Account for statement CPU and wall time.
      Parameters:
      metricsHandle - statement handle
      deltaCPU - cpu time nsec
      deltaWall - wall time nsec
      numInput - number of input rows

    • accountOutput

      void accountOutput(StatementMetricHandle handle, int numIStream, int numRStream, Object epStatement, Object runtime)
      Account for statement output row counting.
      Parameters:
      handle - statement handle
      numIStream - number of insert stream rows
      numRStream - number of remove stream rows
      epStatement - statement
      runtime - runtime

    • getStatementHandle

      StatementMetricHandle getStatementHandle(int statementId, String deploymentId, String statementName)
      Returns for a new statement a handle for later accounting.
      Parameters:
      statementId - statement id
      deploymentId - deployment id
      statementName - statement name
      Returns:
      handle

    • setMetricsReportingInterval

      void setMetricsReportingInterval(String stmtGroupName, long newInterval)
      Change the reporting interval for the given statement group name.
      Parameters:
      stmtGroupName - group name
      newInterval - new interval, or zero or negative value to disable reporting

    • setMetricsReportingStmtDisabled

      void setMetricsReportingStmtDisabled(String deploymentId, String statementName)
      Disable metrics reporting for statement.
      Parameters:
      deploymentId - deployment id
      statementName - statement name

    • setMetricsReportingStmtEnabled

      void setMetricsReportingStmtEnabled(String deploymentId, String statementName)
      Enable metrics reporting for statement.
      Parameters:
      deploymentId - deployment id
      statementName - statement name

    • setMetricsReportingEnabled

      void setMetricsReportingEnabled()
      Enables metrics reporting globally.

    • setMetricsReportingDisabled

      void setMetricsReportingDisabled()
      Disables metrics reporting globally.

    • isMetricsReportingEnabled

      boolean isMetricsReportingEnabled()

    • iterateMetrics

      void iterateMetrics(Consumer<EPMetricsStatementGroup> consumer)