class Fluent::Plugin::GrpcOutput

Public Instance Methods

start() click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_grpc.rb, line 12
def start
  super
  @stub = Event::Forwarder::Stub.new(@path, :this_channel_is_insecure)
end
write(chunk) click to toggle source
# File lib/fluent/plugin/out_grpc.rb, line 17
def write(chunk)
  chunk.each do |time, record|
    ack = @stub.forward(Event::Log.new(name: record['message']))
    $stdout.puts ack.type
  end
end