11# frozen_string_literal: true
22
33require "fluent/plugin/input"
4- require "fluent/plugin/otlp /constant"
5- require "fluent/plugin/otlp /request"
6- require "fluent/plugin/otlp /response"
7- require "fluent/plugin/otlp /service_handler"
4+ require "fluent/plugin/opentelemetry /constant"
5+ require "fluent/plugin/opentelemetry /request"
6+ require "fluent/plugin/opentelemetry /response"
7+ require "fluent/plugin/opentelemetry /service_handler"
88require "fluent/plugin_helper/http_server"
99require "fluent/plugin_helper/thread"
1010
@@ -28,8 +28,8 @@ def headers
2828end
2929
3030module Fluent ::Plugin
31- class OtlpInput < Input
32- Fluent ::Plugin . register_input ( "otlp " , self )
31+ class OpentelemetryInput < Input
32+ Fluent ::Plugin . register_input ( "opentelemetry " , self )
3333
3434 helpers :thread , :http_server
3535
@@ -67,31 +67,31 @@ def start
6767
6868 if @http_config
6969 http_handler = HttpHandler . new
70- http_server_create_http_server ( :in_otlp_http_server , addr : @http_config . bind , port : @http_config . port , logger : log ) do |serv |
70+ http_server_create_http_server ( :in_opentelemetry_http_server , addr : @http_config . bind , port : @http_config . port , logger : log ) do |serv |
7171 serv . post ( "/v1/logs" ) do |req |
72- http_handler . logs ( req ) { |record | router . emit ( @tag , Fluent ::EventTime . now , { type : Otlp ::RECORD_TYPE_LOGS , message : record } ) }
72+ http_handler . logs ( req ) { |record | router . emit ( @tag , Fluent ::EventTime . now , { type : Opentelemetry ::RECORD_TYPE_LOGS , message : record } ) }
7373 end
7474 serv . post ( "/v1/metrics" ) do |req |
75- http_handler . metrics ( req ) { |record | router . emit ( @tag , Fluent ::EventTime . now , { type : Otlp ::RECORD_TYPE_METRICS , message : record } ) }
75+ http_handler . metrics ( req ) { |record | router . emit ( @tag , Fluent ::EventTime . now , { type : Opentelemetry ::RECORD_TYPE_METRICS , message : record } ) }
7676 end
7777 serv . post ( "/v1/traces" ) do |req |
78- http_handler . traces ( req ) { |record | router . emit ( @tag , Fluent ::EventTime . now , { type : Otlp ::RECORD_TYPE_TRACES , message : record } ) }
78+ http_handler . traces ( req ) { |record | router . emit ( @tag , Fluent ::EventTime . now , { type : Opentelemetry ::RECORD_TYPE_TRACES , message : record } ) }
7979 end
8080 end
8181 end
8282
8383 if @grpc_config
84- thread_create ( :in_otlp_grpc_server ) do
84+ thread_create ( :in_opentelemetry_grpc_server ) do
8585 grpc_handler = GrpcHandler . new ( @grpc_config , log )
8686 grpc_handler . run (
8787 logs : lambda { |record |
88- router . emit ( @tag , Fluent ::EventTime . now , { type : Otlp ::RECORD_TYPE_LOGS , message : record } )
88+ router . emit ( @tag , Fluent ::EventTime . now , { type : Opentelemetry ::RECORD_TYPE_LOGS , message : record } )
8989 } ,
9090 metrics : lambda { |record |
91- router . emit ( @tag , Fluent ::EventTime . now , { type : Otlp ::RECORD_TYPE_METRICS , message : record } )
91+ router . emit ( @tag , Fluent ::EventTime . now , { type : Opentelemetry ::RECORD_TYPE_METRICS , message : record } )
9292 } ,
9393 traces : lambda { |record |
94- router . emit ( @tag , Fluent ::EventTime . now , { type : Otlp ::RECORD_TYPE_TRACES , message : record } )
94+ router . emit ( @tag , Fluent ::EventTime . now , { type : Opentelemetry ::RECORD_TYPE_TRACES , message : record } )
9595 }
9696 )
9797 end
@@ -100,15 +100,15 @@ def start
100100
101101 class HttpHandler
102102 def logs ( req , &block )
103- common ( req , Otlp ::Request ::Logs , Otlp ::Response ::Logs , &block )
103+ common ( req , Opentelemetry ::Request ::Logs , Opentelemetry ::Response ::Logs , &block )
104104 end
105105
106106 def metrics ( req , &block )
107- common ( req , Otlp ::Request ::Metrics , Otlp ::Response ::Metrics , &block )
107+ common ( req , Opentelemetry ::Request ::Metrics , Opentelemetry ::Response ::Metrics , &block )
108108 end
109109
110110 def traces ( req , &block )
111- common ( req , Otlp ::Request ::Traces , Otlp ::Response ::Traces , &block )
111+ common ( req , Opentelemetry ::Request ::Traces , Opentelemetry ::Response ::Traces , &block )
112112 end
113113
114114 private
@@ -120,7 +120,7 @@ def common(req, request_class, response_class)
120120 return response_bad_request ( content_type ) unless valid_content_encoding? ( content_encoding )
121121
122122 body = req . body
123- body = Zlib ::GzipReader . new ( StringIO . new ( body ) ) . read if content_encoding == Otlp ::CONTENT_ENCODING_GZIP
123+ body = Zlib ::GzipReader . new ( StringIO . new ( body ) ) . read if content_encoding == Opentelemetry ::CONTENT_ENCODING_GZIP
124124
125125 begin
126126 record = request_class . new ( body ) . record
@@ -132,12 +132,12 @@ def common(req, request_class, response_class)
132132 yield record
133133
134134 res = response_class . new
135- response ( 200 , content_type , res . body ( type : Otlp ::Response . type ( content_type ) ) )
135+ response ( 200 , content_type , res . body ( type : Opentelemetry ::Response . type ( content_type ) ) )
136136 end
137137
138138 def valid_content_type? ( content_type )
139139 case content_type
140- when Otlp ::CONTENT_TYPE_PROTOBUF , Otlp ::CONTENT_TYPE_JSON
140+ when Opentelemetry ::CONTENT_TYPE_PROTOBUF , Opentelemetry ::CONTENT_TYPE_JSON
141141 true
142142 else
143143 false
@@ -147,15 +147,15 @@ def valid_content_type?(content_type)
147147 def valid_content_encoding? ( content_encoding )
148148 return true if content_encoding . nil?
149149
150- content_encoding == Otlp ::CONTENT_ENCODING_GZIP
150+ content_encoding == Opentelemetry ::CONTENT_ENCODING_GZIP
151151 end
152152
153153 def response ( code , content_type , body )
154- [ code , { Otlp ::CONTENT_TYPE => content_type } , body ]
154+ [ code , { Opentelemetry ::CONTENT_TYPE => content_type } , body ]
155155 end
156156
157157 def response_unsupported_media_type
158- response ( 415 , Otlp ::CONTENT_TYPE_PAIN , "415 unsupported media type, supported: [application/json, application/x-protobuf]" )
158+ response ( 415 , Opentelemetry ::CONTENT_TYPE_PAIN , "415 unsupported media type, supported: [application/json, application/x-protobuf]" )
159159 end
160160
161161 def response_bad_request ( content_type )
@@ -183,24 +183,24 @@ def run(logs:, metrics:, traces:)
183183 server = GRPC ::RpcServer . new ( interceptors : [ ExceptionInterceptor . new ] )
184184 server . add_http2_port ( "#{ @grpc_config . bind } :#{ @grpc_config . port } " , :this_port_is_insecure )
185185
186- logs_handler = Otlp ::ServiceHandler ::Logs . new
186+ logs_handler = Opentelemetry ::ServiceHandler ::Logs . new
187187 logs_handler . callback = lambda { |request |
188188 logs . call ( request . to_json )
189- Otlp ::Response ::Logs . build
189+ Opentelemetry ::Response ::Logs . build
190190 }
191191 server . handle ( logs_handler )
192192
193- metrics_handler = Otlp ::ServiceHandler ::Metrics . new
193+ metrics_handler = Opentelemetry ::ServiceHandler ::Metrics . new
194194 metrics_handler . callback = lambda { |request |
195195 metrics . call ( request . to_json )
196- Otlp ::Response ::Metrics . build
196+ Opentelemetry ::Response ::Metrics . build
197197 }
198198 server . handle ( metrics_handler )
199199
200- traces_handler = Otlp ::ServiceHandler ::Traces . new
200+ traces_handler = Opentelemetry ::ServiceHandler ::Traces . new
201201 traces_handler . callback = lambda { |request |
202202 traces . call ( request . to_json )
203- Otlp ::Response ::Traces . build
203+ Opentelemetry ::Response ::Traces . build
204204 }
205205 server . handle ( traces_handler )
206206
0 commit comments