Sha256: f7108e1af4f3b4570d1a02a6e8899e82fe09b77a0bb066833a2c2cd8e6aaa884
Contents?: true
Size: 935 Bytes
Versions: 76
Compression:
Stored size: 935 Bytes
Contents
# frozen_string_literal: true
module SplitIoClient
module Telemetry
class RedisInitProducer < InitProducer
def initialize(config)
@config = config
@adapter = config.telemetry_adapter
end
def record_config(config_data)
return if config_data.nil?
data = { m: { i: @config.machine_ip, n: @config.machine_name, s: "#{@config.language}-#{@config.version}" },
t: { oM: config_data.om, st: config_data.st, aF: config_data.af, rF: config_data.rf, t: config_data.t } }
@adapter.add_to_queue(config_key, data.to_json)
rescue StandardError => error
@config.log_found_exception(__method__.to_s, error)
end
def record_bur_timeout
# no-op
end
def record_non_ready_usages
# no-op
end
private
def config_key
"#{@config.redis_namespace}.telemetry.config"
end
end
end
end
Version data entries
76 entries across 76 versions & 1 rubygems