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