Class: Fluent::TelemetryInput

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

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



15
16
17
 
# File 'lib/fluent/plugin/in_telemetry_iosxr.rb', line 15

def configure(conf)
  super
end

#shutdown ⇒ Object 



28
29
30
 
# File 'lib/fluent/plugin/in_telemetry_iosxr.rb', line 28

def shutdown
  super
end

#start ⇒ Object 



19
20
21
22
23
24
25
26
27
 
# File 'lib/fluent/plugin/in_telemetry_iosxr.rb', line 19

def start
  super
  @hdr_parsed = false
  @buffer = ""
  @hdr_buffer = ""
  server_create(:in_telemetry_server, @port, bind: @bind, proto: :tcp) do |data, sock|
    receive_data(sock.remote_host, data)
  end
end