class Fluent::RelpInput

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_relp.rb, line 17
def configure(conf)
    super
end
on_message(msg) click to toggle source
# File lib/fluent/plugin/in_relp.rb, line 48
def on_message(msg)
      time = Engine.now
      record = {"message"=> msg}
      router.emit(@tag, time, record)
  rescue => e
    log.error msg.dump, error: e, error_class: e.class
    log.error_backtrace
end
run() click to toggle source
# File lib/fluent/plugin/in_relp.rb, line 41
def run
    @server.run()
  rescue => e
    log.error "unexpected error", error: e, error_class: e.class
    log.error_backtrace
end
shutdown() click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_relp.rb, line 35
def shutdown
    super
    @server.server_shutdown
    @thread.join
end
start() click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_relp.rb, line 21
def start
    super
    ssl_context = nil
    if @ssl_config != nil
            ssl_context = OpenSSL::SSL::SSLContext.new(:TLSv1_2)
            ssl_context.ca_file = @ssl_config.split(':')[2]
            ssl_context.verify_mode = OpenSSL::SSL::VERIFY_PEER
            ssl_context.key = OpenSSL::PKey::RSA.new(File.open(@ssl_config.split(':')[1]))
            ssl_context.cert = OpenSSL::X509::Certificate.new(File.open(@ssl_config.split(':')[0]))
    end
    @server = Relp::RelpServer.new(@port, method(:on_message), @bind, ssl_context, log)
    @thread = Thread.new(&method(:run))
end