class Fluent::Plugin::GrpcInput

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_grpc.rb, line 24
def configure(conf)
  super

  if @port < 1024
    raise Fluent::ConfigError, "well known ports cannot be used for this purpose."
  end
end
shutdown() click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_grpc.rb, line 45
def shutdown
  @s.stop

  super
end
start() click to toggle source
Calls superclass method
# File lib/fluent/plugin/in_grpc.rb, line 33
def start
  super

  @s = GRPC::RpcServer.new
  @s.add_http2_port("#{@bind}:#{@port}", :this_port_is_insecure)
  @s.handle(ForwarderServer)
  thread_create :in_grpc_server do
    @s.run
  end
end