class ConfigCat::ManualPollingCachePolicy

Public Class Methods

new(config_fetcher, config_cache, cache_key) click to toggle source
# File lib/configcat/manualpollingcachepolicy.rb, line 7
def initialize(config_fetcher, config_cache, cache_key)
  @_config_fetcher = config_fetcher
  @_config_cache = config_cache
  @_cache_key = cache_key
  @_lock = Concurrent::ReadWriteLock.new()
end

Public Instance Methods

force_refresh() click to toggle source
# File lib/configcat/manualpollingcachepolicy.rb, line 24
def force_refresh()
  begin
    configuration_response = @_config_fetcher.get_configuration_json()
    if configuration_response.is_fetched()
      configuration = configuration_response.json()
      begin
        @_lock.acquire_write_lock()
        @_config_cache.set(@_cache_key, configuration)
      ensure
        @_lock.release_write_lock()
      end
    end
  rescue StandardError => e
    ConfigCat.logger.error("Double-check your SDK Key at https://app.configcat.com/sdkkey.")
    ConfigCat.logger.error "threw exception #{e.class}:'#{e}'"
    ConfigCat.logger.error "stacktrace: #{e.backtrace}"
  end
end
get() click to toggle source
# File lib/configcat/manualpollingcachepolicy.rb, line 14
def get()
  begin
    @_lock.acquire_read_lock()
    config = @_config_cache.get(@_cache_key)
    return config
  ensure
    @_lock.release_read_lock()
  end
end
stop() click to toggle source
# File lib/configcat/manualpollingcachepolicy.rb, line 43
def stop()
  # pass
end