package util
- Alphabetic
- Public
- Protected
Type Members
- case class GaussianDistribution[T](mean: T, stdDev: T) extends Product with Serializable
- trait JsonSerializer[S] extends AnyRef
A JSON serializer for arbitrary types.
- class KafkaMetricsReporter extends MetricsReporter with Metrics
An implementation of the Kafka metric reporter that registers all Kafka metrics to a global metric registry.
- trait Logging extends AnyRef
Convenience trait for importing an instance of a logger.
- case class MetricTag(name: String, value: String) extends Product with Serializable
- trait Metrics extends AnyRef
Convenience trait for importing metric creation methods.
Convenience trait for importing metric creation methods. All exposed metrics are registered to a global registry.
- trait TimeExtractor[P] extends AnyRef
Type-class for extracting epoch milliseconds from various time representations.
- trait TimeProvider extends AnyRef
A current time provider, used for mocking time in tests.
Value Members
- object Metrics
- object RandomExtensions
- object Retry extends Logging
- object TimeExtractor
- object TimeProvider
- object UuidExtensions