Sha256: 23fb2253712f7d0da897029f84627870572383b30075308ebb52279a2c4bada5
Contents?: true
Size: 899 Bytes
Versions: 34
Compression:
Stored size: 899 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
34 entries across 34 versions & 1 rubygems