Class: SplitIoClient::Engine::Synchronizer

Inherits:
Object
  • Object
show all
Includes:
Cache::Fetchers, Cache::Senders
Defined in:
lib/splitclient-rb/engine/synchronizer.rb

Constant Summary collapse

FORCE_CACHE_CONTROL_HEADERS = 
true

Instance Method Summary collapse

Constructor Details

#initialize(repositories, api_key, config, sdk_blocker, params) ⇒ 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/engine/synchronizer.rb', line 11

def initialize(
  repositories,
  api_key,
  config,
  sdk_blocker,
  params
)
  @splits_repository = repositories[:splits]
  @segments_repository = repositories[:segments]
  @impressions_repository = repositories[:impressions]
  @events_repository = repositories[:events]
  @api_key = api_key
  @config = config
  @sdk_blocker = sdk_blocker
  @split_fetcher = params[:split_fetcher]
  @segment_fetcher = params[:segment_fetcher]
  @impressions_api = SplitIoClient::Api::Impressions.new(@api_key, @config, params[:telemetry_runtime_producer])
  @impression_counter = params[:imp_counter]
  @telemetry_synchronizer = params[:telemetry_synchronizer]
end

Instance Method Details

#fetch_segment(name) ⇒ Object 



62
63
64
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 62

def fetch_segment(name)
  @segment_fetcher.fetch_segment(name, FORCE_CACHE_CONTROL_HEADERS)
end

#fetch_splits ⇒ Object 



57
58
59
60
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 57

def fetch_splits
  segment_names = @split_fetcher.fetch_splits(FORCE_CACHE_CONTROL_HEADERS)
  @segment_fetcher.fetch_segments_if_not_exists(segment_names, FORCE_CACHE_CONTROL_HEADERS) unless segment_names.empty?
end

#start_periodic_data_recording ⇒ Object 



40
41
42
43
44
45
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 40

def start_periodic_data_recording
  impressions_sender
  events_sender
  impressions_count_sender
  start_telemetry_sync_task
end

#start_periodic_fetch ⇒ Object 



47
48
49
50
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 47

def start_periodic_fetch
  @split_fetcher.call
  @segment_fetcher.call
end

#stop_periodic_fetch ⇒ Object 



52
53
54
55
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 52

def stop_periodic_fetch
  @split_fetcher.stop_splits_thread
  @segment_fetcher.stop_segments_thread
end

#sync_all ⇒ Object 



32
33
34
35
36
37
38
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 32

def sync_all
  @config.threads[:sync_all_thread] = Thread.new do
    @config.logger.debug('Synchronizing Splits and Segments ...') if @config.debug_enabled
    @split_fetcher.fetch_splits
    @segment_fetcher.fetch_segments
  end
end