Packages

package metrics

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package metrics

Type Members

  1. sealed trait BenchmarkResult extends Product with Serializable
  2. final case class ConsumptionSpeedMetric[T](recordTimeFunction: (T) => Seq[Timestamp], objective: Option[(MinConsumptionSpeed, Option[Value])], previousLatest: Option[Instant] = None, currentPeriodLatest: Option[Instant] = None) extends Metric[T] with Product with Serializable
  3. final case class CountRateMetric[T](countingFunction: (T) => Int, periodicObjectives: List[(RateObjective, Option[Value])], finalObjectives: List[RateObjective], counter: Int = 0, lastCount: Int = 0) extends Metric[T] with Product with Serializable
  4. final case class DelayMetric[T](recordTimeFunction: (T) => Seq[Timestamp], clock: Clock, objective: Option[(MaxDelay, Option[Value])], delaysInCurrentInterval: List[Duration] = List.empty) extends Metric[T] with Product with Serializable
  5. final class ExposedMetrics[T] extends AnyRef
  6. final case class LatencyMetric(totalNanos: LatencyNanos, numberObservations: Int, maxLatency: MaxLatency) extends Metric[LatencyNanos] with Product with Serializable
  7. class MeteredStreamObserver[T] extends ObserverWithResult[T, BenchmarkResult]
  8. trait Metric[Elem] extends AnyRef
  9. class MetricRegistryOwner extends ResourceOwner[MeterProvider]
  10. trait MetricValue extends AnyRef
  11. class MetricsCollector[T] extends AnyRef
  12. trait MetricsManager[T] extends AnyRef
  13. final case class MetricsManagerImpl[T](collector: ActorRef[Message], logInterval: FiniteDuration, observedMetric: String)(implicit system: ActorSystem[Command]) extends MetricsManager[T] with Product with Serializable
  14. trait ServiceLevelObjective[MetricValueType <: MetricValue] extends AnyRef
  15. final case class SizeMetric[T](sizingBytesFunction: (T) => Long, currentSizeBytesBucket: Long = 0, sizeRateList: List[Double] = List.empty) extends Metric[T] with Product with Serializable
  16. final case class TotalCountMetric[T](countingFunction: (T) => Int, counter: Int = 0, lastCount: Int = 0) extends Metric[T] with Product with Serializable

Ungrouped