Class: Fluent::Plugin::GrpcInput::ForwarderServer

Inherits:

Event::Forwarder::Service

• Object
• Event::Forwarder::Service
• Fluent::Plugin::GrpcInput::ForwarderServer

Defined in:

lib/fluent/plugin/in_grpc.rb

Instance Method Summary

• #forward(event, _unused_call) ⇒ Object

Instance Method Details

#forward(event, _unused_call) ⇒ Object

# File 'lib/fluent/plugin/in_grpc.rb', line 17

def forward(event, _unused_call)
  $stdout.puts event.name
  Event::Ack.new(type: "received")
end