Class: Fluent::Plugin::Opentelemetry::GrpcOutputHandler::ServiceStub::Logs

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/plugin/opentelemetry/grpc_output_handler.rb

Instance Method Summary collapse

Constructor Details

#initialize(host, creds, **kw) ⇒ Logs

Returns a new instance of Logs.



16
17
18
 
# File 'lib/fluent/plugin/opentelemetry/grpc_output_handler.rb', line 16

def initialize(host, creds, **kw)
  @stub = Opentelemetry::Proto::Collector::Logs::V1::LogsService::Stub.new(host, creds, **kw)
end

Instance Method Details

#export(json) ⇒ Object 



20
21
22
23
 
# File 'lib/fluent/plugin/opentelemetry/grpc_output_handler.rb', line 20

def export(json)
  message = Opentelemetry::Proto::Collector::Logs::V1::ExportLogsServiceRequest.decode_json(json)
  @stub.export(message)
end