Sha256: 08cbc4a260540fa1f21c7222743d8dca6c3e35ef82abc45b1946b7eb42d97ed2
Contents?: true
Size: 922 Bytes
Versions: 80
Compression:
Stored size: 922 Bytes
Contents
# frozen_string_literal: true
module SplitIoClient
module Telemetry
class RedisSynchronizer < Synchronizer
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 => error
@config.log_found_exception(__method__.to_s, error)
end
end
end
end
Version data entries
80 entries across 80 versions & 1 rubygems