Class: SplitIoClient::Telemetry::Synchronizer

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/splitclient-rb/telemetry/synchronizer.rb

Instance Method Summary collapse

Constructor Details

#initialize(config, telemtry_consumers, telemetry_init_producer, repositories, telemetry_api, flag_sets, flag_sets_invalid) ⇒ Synchronizer

Returns a new instance of Synchronizer.



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/splitclient-rb/telemetry/synchronizer.rb', line 11

def initialize(config,
               telemtry_consumers,
               telemetry_init_producer,
               repositories,
               telemetry_api,
               flag_sets,
               flag_sets_invalid)
  @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,
                                                                     flag_sets,
                                                                     flag_sets_invalid)
                  end
end