class Fluent::Plugin::GrpcInput::ForwarderServer

Public Instance Methods

forward(event, _unused_call) click to toggle source
# File lib/fluent/plugin/in_grpc.rb, line 17
def forward(event, _unused_call)
  $stdout.puts event.name
  Event::Ack.new(type: "received")
end