Class: SplitIoClient::Engine::Synchronizer

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

Instance Method Summary collapse

Constructor Details

#initialize(repositories, api_key, config, sdk_blocker, params) ⇒ Synchronizer

Returns a new instance of Synchronizer.



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

def initialize(
  repositories,
  api_key,
  config,
  sdk_blocker,
  params
)
  @splits_repository = repositories[:splits]
  @segments_repository = repositories[:segments]
  @impressions_repository = repositories[:impressions]
  @metrics_repository = repositories[:metrics]
  @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)
  @impression_counter = params[:imp_counter]
end

Instance Method Details

#fetch_segment(name) ⇒ Object 



60
61
62
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 60

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

#fetch_splits ⇒ Object 



55
56
57
58
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 55

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

#start_periodic_data_recording ⇒ Object 



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

def start_periodic_data_recording
  impressions_sender
  metrics_sender
  events_sender
  impressions_count_sender
end

#start_periodic_fetch ⇒ Object 



45
46
47
48
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 45

def start_periodic_fetch
  @split_fetcher.call
  @segment_fetcher.call
end

#stop_periodic_fetch ⇒ Object 



50
51
52
53
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 50

def stop_periodic_fetch
  @split_fetcher.stop_splits_thread
  @segment_fetcher.stop_segments_thread
end

#sync_all ⇒ Object 



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

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
    fetch_segments
  end
end