Sha256: 1da94a2ff1d6f932022337a7425bb66b5c2dc0344c874be7eef4a1de4fa28c06
Contents?: true
Size: 898 Bytes
Versions: 28
Compression:
Stored size: 898 Bytes
Contents
# frozen_string_literal: true
module SplitIoClient
module Telemetry
class RedisSynchronizer
def initialize(config,
telemetry_init_producer)
@config = config
@telemetry_init_producer = telemetry_init_producer
end
def synchronize_stats
# No-op
end
def synchronize_config(active_factories = nil, redundant_active_factories = nil, tags = nil)
active_factories ||= SplitIoClient.split_factory_registry.active_factories
redundant_active_factories ||= SplitIoClient.split_factory_registry.redundant_active_factories
init_config = ConfigInit.new(@config.mode, 'redis', active_factories, redundant_active_factories, tags)
@telemetry_init_producer.record_config(init_config)
rescue StandardError => e
@config.log_found_exception(__method__.to_s, e)
end
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems