Module: FlippRubyKafka

Defined in:
lib/flipp_ruby_kafka.rb,
lib/flipp_ruby_kafka/version.rb,
lib/flipp_ruby_kafka/test_helpers.rb,
lib/flipp_ruby_kafka/flipp_datadog_metrics.rb,
lib/flipp_ruby_kafka/utils/platform_topic_validation.rb,
lib/flipp_ruby_kafka/utils/platform_schema_validation.rb,
lib/generators/flipp_ruby_kafka/topic_validation/topic_validation_generator.rb,
lib/generators/flipp_ruby_kafka/schema_validation/schema_validation_generator.rb

Overview

Parent module.

Defined Under Namespace

Modules: Generators, TestHelpers, Utils Classes: FlippDatadogMetrics

Constant Summary collapse

VERSION = 
'0.0.6'

Class Method Summary collapse

Class Method Details

.configure_datadog ⇒ Object

Configure datadog. Must be called after FlippDatadog is configured.



67
68
69
70
71
 
# File 'lib/flipp_ruby_kafka.rb', line 67

def configure_datadog
  service_name = "#{FlippDatadog.config&.service || 'frk'}-consumer"
  self.config.metrics = FlippRubyKafka::FlippDatadogMetrics.new(nil, self.config.logger)
  self.config.tracer = Deimos::Tracing::Datadog.new(service_name: service_name)
end