Class: Fluent::Plugin::GeoipFilter

Inherits:
Filter
  • Object
show all
Defined in:
lib/fluent/plugin/filter_geoip.rb

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



20
21
22
23
24
 
# File 'lib/fluent/plugin/filter_geoip.rb', line 20

def configure(conf)
  compat_parameters_convert(conf, :inject)
  super
  @geoip = Fluent::GeoIP.new(self, conf)
end

#filter(tag, time, record) ⇒ Object 



26
27
28
29
30
31
32
33
 
# File 'lib/fluent/plugin/filter_geoip.rb', line 26

def filter(tag, time, record)
  filtered_record = @geoip.add_geoip_field(record)
  if filtered_record
    record = filtered_record
  end
  record = inject_values_to_record(tag, time, record)
  record
end

#multi_workers_ready? ⇒ Boolean

Returns:

  • (Boolean) 


35
36
37
 
# File 'lib/fluent/plugin/filter_geoip.rb', line 35

def multi_workers_ready?
  true
end