Sha256: 15f99136de8e1ac75d909d1e349f78419cea9648f024f3dd07b8903afe386ba4
Contents?: true
Size: 1.16 KB
Versions: 114
Compression:
Stored size: 1.16 KB
Contents
# frozen_string_literal: true
module SplitIoClient
module Telemetry
class Synchronizer
extend Forwardable
def_delegators :@synchronizer,
:synchronize_config,
:synchronize_stats
def initialize(config,
telemtry_consumers,
telemetry_init_producer,
repositories,
telemetry_api)
@synchronizer = case config.telemetry_adapter.class.to_s
when 'SplitIoClient::Cache::Adapters::RedisAdapter'
SplitIoClient::Telemetry::RedisSynchronizer.new(config,
telemetry_init_producer)
else
SplitIoClient::Telemetry::MemorySynchronizer.new(config,
telemtry_consumers,
repositories,
telemetry_api)
end
end
end
end
end
Version data entries
114 entries across 114 versions & 1 rubygems