package org.apache.kafka.streams;

interface StreamsMetrics {
  Map<MetricName, ? extends Metric> metrics();
  Sensor addLatencyAndThroughputSensor(
    final String scopeName,
    final String entityName,
    final String operationName,
    final Sensor.RecordingLevel recordingLevel,
    final String... tags);
  void recordLatency(
    final Sensor sensor,
    final long startNs,
    final long endNs);
  Sensor addThroughputSensor(
    final String scopeName,
    final String entityName,
    final String operationName,
    final Sensor.RecordingLevel recordingLevel,
    final String... tags);
  void recordThroughput(
    final Sensor sensor,
    final long value);
  Sensor addSensor(
    final String name,
    final Sensor.RecordingLevel recordingLevel);
  Sensor addSensor(
    final String name,
    final Sensor.RecordingLevel recordingLevel,
    final Sensor... parents);
  void removeSensor(final Sensor sensor);
}