class Fluent::HttpRecordModifier::Cache

Public Class Methods

new(cache, expire) click to toggle source
# File lib/fluent/plugin/filter_http_record_modifier.rb, line 237
def initialize(cache, expire)
  @data = {}
  @cache = cache
  @expire = expire
end

Public Instance Methods

get(key) click to toggle source
# File lib/fluent/plugin/filter_http_record_modifier.rb, line 243
def get(key)
  unless @data.has_key?(key) and @cache
    return nil
  end
  if Time.now.to_i > @data[key]['time'] + @expire
    @data.delete(key)
    return nil
  end
  return @data[key]['value']
end
set(key, value) click to toggle source
# File lib/fluent/plugin/filter_http_record_modifier.rb, line 254
def set(key, value)
  if @cache
    @data[key] = {
      'time' => Time.now.to_i,
      'value' => value
    }
  end
end