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

Inherits:
Event::Forwarder::Service show all
Defined in:
lib/fluent/plugin/in_grpc.rb

Instance Method Summary collapse

Instance Method Details

#forward(event, _unused_call) ⇒ Object



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

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