Class: Cache

Inherits:
Object
  • Object
show all
Defined in:
lib/logstash/filters/ip2proxy.rb

Constant Summary collapse

ONE_DAY_IN_SECONDS = 
86_400

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.cache ⇒ Object (readonly)

Returns the value of attribute cache.


109
110
111
 
# File 'lib/logstash/filters/ip2proxy.rb', line 109

def cache
  @cache
end

.times_queried ⇒ Object (readonly)

Returns the value of attribute times_queried.


111
112
113
 
# File 'lib/logstash/filters/ip2proxy.rb', line 111

def times_queried
  @times_queried
end

.timestamps ⇒ Object (readonly)

Returns the value of attribute timestamps.


110
111
112
 
# File 'lib/logstash/filters/ip2proxy.rb', line 110

def timestamps
  @timestamps
end

Class Method Details

.cache_event(event, ip, filter) ⇒ Object Also known as: refresh_event

[View source]

142
143
144
145
146
 
# File 'lib/logstash/filters/ip2proxy.rb', line 142

def cache_event(event, ip, filter)
  filter.handleEvent(event)
  cache[ip] = event
  timestamps[ip] = Time.now
end

.cache_full?(cache_size) ⇒ Boolean

Returns:

  • (Boolean)
[View source]

138
139
140
 
# File 'lib/logstash/filters/ip2proxy.rb', line 138

def cache_full?(cache_size)
  cache.size >= cache_size
end

.find(event, ip, filter, cache_size) ⇒ Object

[View source]

113
114
115
116
117
118
119
120
121
122
123
124
125
126
 
# File 'lib/logstash/filters/ip2proxy.rb', line 113

def find(event, ip, filter, cache_size)
  synchronize do
    if cache.has_key?(ip)
      refresh_event(event, ip, filter) if too_old?(ip)
    else
      if cache_full?(cache_size)
        make_room
      end
      cache_event(event, ip, filter)
    end
    times_queried.increment(ip)
    cache[ip]
  end
end

.make_room ⇒ Object

[View source]

132
133
134
135
136
 
# File 'lib/logstash/filters/ip2proxy.rb', line 132

def make_room
  key = times_queried.delete_least_used
  cache.delete(key)
  timestamps.delete(key)
end

.synchronize(&block) ⇒ Object

[View source]

148
149
150
 
# File 'lib/logstash/filters/ip2proxy.rb', line 148

def synchronize(&block)
  @mutex.synchronize(&block)
end

.too_old?(ip) ⇒ Boolean

Returns:

  • (Boolean)
[View source]

128
129
130
 
# File 'lib/logstash/filters/ip2proxy.rb', line 128

def too_old?(ip)
  timestamps[ip] < Time.now - ONE_DAY_IN_SECONDS
end