Class: SplitIoClient::SSE::Workers::SplitsWorker
- Inherits:
-
Object
- Object
- SplitIoClient::SSE::Workers::SplitsWorker
- Defined in:
- lib/splitclient-rb/sse/workers/splits_worker.rb
Instance Method Summary collapse
- #add_to_queue(notification) ⇒ Object
-
#initialize(synchronizer, config, feature_flags_repository, telemetry_runtime_producer, segment_fetcher) ⇒ SplitsWorker
constructor
A new instance of SplitsWorker.
- #start ⇒ Object
- #stop ⇒ Object
Constructor Details
#initialize(synchronizer, config, feature_flags_repository, telemetry_runtime_producer, segment_fetcher) ⇒ SplitsWorker
Returns a new instance of SplitsWorker.
7 8 9 10 11 12 13 14 15 |
# File 'lib/splitclient-rb/sse/workers/splits_worker.rb', line 7 def initialize(synchronizer, config, feature_flags_repository, telemetry_runtime_producer, segment_fetcher) @synchronizer = synchronizer @config = config @feature_flags_repository = feature_flags_repository @queue = Queue.new @running = Concurrent::AtomicBoolean.new(false) @telemetry_runtime_producer = telemetry_runtime_producer @segment_fetcher = segment_fetcher end |
Instance Method Details
#add_to_queue(notification) ⇒ Object
37 38 39 40 |
# File 'lib/splitclient-rb/sse/workers/splits_worker.rb', line 37 def add_to_queue(notification) @config.logger.debug("feature_flags_worker add to queue #{notification.data['changeNumber']}") @queue.push(notification) end |
#start ⇒ Object
17 18 19 20 21 22 23 24 25 |
# File 'lib/splitclient-rb/sse/workers/splits_worker.rb', line 17 def start if @running.value @config.logger.debug('feature_flags_worker already running.') return end @running.make_true perform_thread end |
#stop ⇒ Object
27 28 29 30 31 32 33 34 35 |
# File 'lib/splitclient-rb/sse/workers/splits_worker.rb', line 27 def stop unless @running.value @config.logger.debug('feature_flags_worker not running.') return end @running.make_false Helpers::ThreadHelper.stop(:split_update_worker, @config) end |