Class: Fluent::Plugin::NetflowInput

Inherits:
Input
  • Object
show all
Defined in:
lib/fluent/plugin/in_netflow.rb

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



45
46
47
48
49
50
 
# File 'lib/fluent/plugin/in_netflow.rb', line 45

def configure(conf)
  super

  @parser = Fluent::Plugin::NetflowParser.new
  @parser.configure(conf)
end

#multi_workers_ready? ⇒ Boolean

Returns:

  • (Boolean) 


41
42
43
 
# File 'lib/fluent/plugin/in_netflow.rb', line 41

def multi_workers_ready?
  true
end

#shutdown ⇒ Object 



59
60
61
 
# File 'lib/fluent/plugin/in_netflow.rb', line 59

def shutdown
  super
end

#start ⇒ Object 



52
53
54
55
56
57
 
# File 'lib/fluent/plugin/in_netflow.rb', line 52

def start
  super
  server_create(:in_netflow_server, @port, bind: @bind, proto: @protocol_type, max_bytes: @max_bytes) do |data, sock|
    receive_data(sock.remote_host, data)
  end
end