Class: LaunchDarkly::Impl::DataSource::PollingProcessor Private

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

Overview

This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.

Since:

  • 5.5.0

Instance Method Summary collapse

Constructor Details

#initialize(config, requestor) ⇒ PollingProcessor

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of PollingProcessor.

Since:

  • 5.5.0



13
14
15
16
17
18
19
20
 
# File 'lib/ldclient-rb/impl/data_source/polling.rb', line 13

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, 'LD/PollingDataSource')
end

Instance Method Details

#initialized? ⇒ Boolean

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns:

  • (Boolean)

Since:

  • 5.5.0



22
23
24
 
# File 'lib/ldclient-rb/impl/data_source/polling.rb', line 22

def initialized?
  @initialized.value
end

#poll ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Since:

  • 5.5.0



37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/ldclient-rb/impl/data_source/polling.rb', line 37

def poll
  begin
    all_data, headers = request_all_data
    DataSource.record_environment_id(@config.data_source_update_sink, headers)
    if all_data
      update_sink_or_data_store.init(all_data)
      if @initialized.make_true
        @config.logger.info { "[LDClient] Polling connection initialized" }
        @ready.set
      end
    end
    @config.data_source_update_sink&.update_status(LaunchDarkly::Interfaces::DataSource::Status::VALID, nil)
  rescue JSON::ParserError => e
    @config.logger.error { "[LDClient] JSON parsing failed for polling response." }
    error_info = LaunchDarkly::Interfaces::DataSource::ErrorInfo.new(
      LaunchDarkly::Interfaces::DataSource::ErrorInfo::INVALID_DATA,
      0,
      e.to_s,
      Time.now
    )
    @config.data_source_update_sink&.update_status(LaunchDarkly::Interfaces::DataSource::Status::INTERRUPTED, error_info)
  rescue Impl::DataSource::UnexpectedResponseError => e
    error_info = LaunchDarkly::Interfaces::DataSource::ErrorInfo.new(
      LaunchDarkly::Interfaces::DataSource::ErrorInfo::ERROR_RESPONSE, e.status, nil, Time.now)
    message = Util.http_error_message(e.status, "polling request", "will retry")
    @config.logger.error { "[LDClient] #{message}" }

    if Util.http_error_recoverable?(e.status)
      @config.data_source_update_sink&.update_status(
        LaunchDarkly::Interfaces::DataSource::Status::INTERRUPTED,
        error_info
      )
    else
      @ready.set  # if client was waiting on us, make it stop waiting - has no effect if already set
      stop_with_error_info error_info
    end
  rescue StandardError => e
    Impl::Util.log_exception(@config.logger, "Exception while polling", e)
    @config.data_source_update_sink&.update_status(
      LaunchDarkly::Interfaces::DataSource::Status::INTERRUPTED,
      LaunchDarkly::Interfaces::DataSource::ErrorInfo.new(LaunchDarkly::Interfaces::DataSource::ErrorInfo::UNKNOWN, 0, e.to_s, Time.now)
    )
  end
end

#start ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Since:

  • 5.5.0



26
27
28
29
30
31
 
# File 'lib/ldclient-rb/impl/data_source/polling.rb', line 26

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

#stop ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Since:

  • 5.5.0



33
34
35
 
# File 'lib/ldclient-rb/impl/data_source/polling.rb', line 33

def stop
  stop_with_error_info
end