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