Class: LaunchDarkly::PollingProcessor

Inherits:
Object
  • Object
show all
Defined in:
lib/ldclient-rb/polling.rb

Instance Method Summary collapse

Constructor Details

#initialize(config, requestor) ⇒ PollingProcessor

Returns a new instance of PollingProcessor.



9
10
11
12
13
14
15
16
 
# File 'lib/ldclient-rb/polling.rb', line 9

def initialize(config, requestor)
  @config = config
  @requestor = requestor
  @initialized = Concurrent::AtomicBoolean.new(false)
  @started = Concurrent::AtomicBoolean.new(false)
  @ready = Concurrent::Event.new
  @task = Impl::RepeatingTask.new(@config.poll_interval, 0, -> { self.poll }, @config.logger)
end

Instance Method Details

#initialized? ⇒ Boolean

Returns:

  • (Boolean) 


18
19
20
 
# File 'lib/ldclient-rb/polling.rb', line 18

def initialized?
  @initialized.value
end

#poll ⇒ Object 



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/ldclient-rb/polling.rb', line 34

def poll
  begin
    all_data = @requestor.request_all_data
    if all_data
      @config.feature_store.init(all_data)
      if @initialized.make_true
        @config.logger.info { "[LDClient] Polling connection initialized" }
        @ready.set
      end
    end
  rescue UnexpectedResponseError => e
    message = Util.http_error_message(e.status, "polling request", "will retry")
    @config.logger.error { "[LDClient] #{message}" }
    unless Util.http_error_recoverable?(e.status)
      @ready.set  # if client was waiting on us, make it stop waiting - has no effect if already set
      stop
    end
  rescue StandardError => e
    Util.log_exception(@config.logger, "Exception while polling", e)
  end
end

#start ⇒ Object 



22
23
24
25
26
27
 
# File 'lib/ldclient-rb/polling.rb', line 22

def start
  return @ready unless @started.make_true
  @config.logger.info { "[LDClient] Initializing polling connection" }
  @task.start
  @ready
end

#stop ⇒ Object 



29
30
31
32
 
# File 'lib/ldclient-rb/polling.rb', line 29

def stop
  @task.stop
  @config.logger.info { "[LDClient] Polling connection stopped" }
end