Sha256: 31f69f63d7d047be13c2ac88de2edbddd01d895ad519abdb06da61647aea96ef

Contents?: true

Size: 1.18 KB

Versions: 142

Compression:

Stored size: 1.18 KB

Contents

# frozen_string_literal: true

module SplitIoClient
  module Cache
    module Senders
      class LocalhostRepoCleaner
        def initialize(impressions_repository, events_repository, config)
          @impressions_repository = impressions_repository
          @events_repository = events_repository
          @config = config
        end

        def call
          if ENV['SPLITCLIENT_ENV'] == 'test'
            clear_repositories
          else
            cleaner_thread

            if defined?(PhusionPassenger)
              PhusionPassenger.on_event(:starting_worker_process) do |forked|
                cleaner_thread if forked
              end
            end
          end
        end

        private

        def cleaner_thread
          @config.threads[:repo_cleaner] = Thread.new do
            @config.logger.info('Starting repositories cleanup service')
            loop do
              clear_repositories

              sleep(SplitIoClient::Utilities.randomize_interval(@config.features_refresh_rate))
            end
          end
        end

        def clear_repositories
          @impressions_repository.clear
          @events_repository.clear
        end
      end
    end
  end
end

Version data entries

142 entries across 142 versions & 1 rubygems

Version Path
splitclient-rb-8.5.0-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.5.0 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.5.0.pre.rc1-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.5.0.pre.rc1 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.4.1.pre.rc1-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.4.1.pre.rc1 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.4.0-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.4.0 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.4.0.pre.rc1-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.4.0.pre.rc1 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.4.0.rc.1-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.4.0.rc.1 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.3.2.pre.rc2-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.3.2.pre.rc2 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.3.2.pre.rc1-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.3.2.pre.rc1 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.3.1-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.3.1 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.3.1.pre.rc1-java lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb
splitclient-rb-8.3.1.pre.rc1 lib/splitclient-rb/cache/senders/localhost_repo_cleaner.rb