Sha256: 4e779f7682c3ccb3fa0b80e68e3645890a0a6936aeb76b72f997b9e10f77ef68
Contents?: true
Size: 901 Bytes
Versions: 56
Compression:
Stored size: 901 Bytes
Contents
# frozen_string_literal: true
module SplitIoClient
module Telemetry
class RedisInitProducer
def initialize(config)
@config = config
@adapter = config.telemetry_adapter
end
def record_config(config_data)
return if config_data.nil?
data = { t: { oM: config_data.om, st: config_data.st, aF: config_data.af, rF: config_data.rf, t: config_data.t } }
field = "#{@config.language}-#{@config.version}/#{@config.machine_name}/#{@config.machine_ip}"
@adapter.add_to_map(config_key, field, data.to_json)
rescue StandardError => e
@config.log_found_exception(__method__.to_s, e)
end
def record_bur_timeout
# no-op
end
def record_non_ready_usages
# no-op
end
private
def config_key
"#{@config.redis_namespace}.telemetry.init"
end
end
end
end
Version data entries
56 entries across 56 versions & 1 rubygems