package config
Type Members
-
class
AppConfiguration extends AnyRef
This class reads the configuration from the given resource name using
ConfigurationLoader -
case class
KafkaConfiguration(streamsConfig: StreamsConfig, metricsTopic: String, metricPointEncoder: Encoder, serviceCallTopic: String, protoSpanTopic: String, autoOffsetReset: AutoOffsetReset, timestampExtractor: TimestampExtractor, accumulatorInterval: Int, closeTimeoutInMs: Long, collectorTags: List[String]) extends Product with Serializable
Case class holding required configuration for the node finder kstreams app
Case class holding required configuration for the node finder kstreams app
- streamsConfig
valid instance of StreamsConfig
- metricsTopic
topic name for latency metrics
- metricPointEncoder
encoder used to generate the metricPoint key in kafka
- serviceCallTopic
topic name for service call relationship information
- protoSpanTopic
topic from where Spans serialized in protobuf to be consumed
- autoOffsetReset
Offset type for the kstreams app to start with
- timestampExtractor
instance of timestamp extractor
- accumulatorInterval
interval to aggregate spans to look for client and server spans
- closeTimeoutInMs
time for closing a kafka topic
- collectorTags
Tags to be collected when generating graph edges