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 



62
63
64
65
66
67
68
69
 
# File 'lib/splitclient-rb/engine/synchronizer.rb', line 62

def fetch_segment(name)
  back_off = SplitIoClient::SSE::EventSource::BackOff.new(SplitIoClient::Constants::FETCH_BACK_OFF_BASE_RETRIES, 1)
  loop do
    break if @segment_fetcher.fetch_segment(name)

    sleep(back_off.interval)
  end
end

#fetch_splits ⇒ Object 



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

def fetch_splits
  back_off = SplitIoClient::SSE::EventSource::BackOff.new(SplitIoClient::Constants::FETCH_BACK_OFF_BASE_RETRIES, 1)
  loop do
    break if @split_fetcher.fetch_splits

    sleep(back_off.interval)
  end
end

#start_periodic_data_recording ⇒ Object 



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

def start_periodic_data_recording
  impressions_sender
  metrics_sender
  events_sender
  impressions_count_sender
end

#start_periodic_fetch ⇒ Object 



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

def start_periodic_fetch
  @split_fetcher.call
  @segment_fetcher.call
end

#stop_periodic_fetch ⇒ Object 



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

def stop_periodic_fetch
  @split_fetcher.stop_splits_thread
  @segment_fetcher.stop_segments_thread
end

#sync_all ⇒ Object 



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

def sync_all
  @config.logger.debug('Synchronizing Splits and Segments ...') if @config.debug_enabled
  fetch_splits
  fetch_segments
end