@@ -138,10 +138,15 @@ internal TResponse DoRequest<TRequest, TResponse, TRequestParameters>(
138
138
139
139
using ( var activity = _activitySource . StartActivity ( $ "Elasticsearch: { request . HttpMethod } { urlTemplate } ", ActivityKind . Client ) )
140
140
{
141
- activity ? . AddTag ( "db.system" , "elasticsearch" ) ;
142
- response = _transport . Request < TResponse > ( request . HttpMethod , resolvedUrl , postData , parameters ) ;
141
+ activity ? . SetTag ( "db.system" , "elasticsearch" ) ;
142
+ activity ? . SetCustomProperty ( "elastic.transport.client" , true ) ;
143
+
144
+ response = _transport . Request < TResponse > ( request . HttpMethod , resolvedUrl , postData , request . RequestParameters ) ;
145
+
146
+ if ( response . ApiCallDetails . RequestBodyInBytes is not null )
147
+ activity ? . SetTag ( "db.statement" , System . Text . Encoding . UTF8 . GetString ( response . ApiCallDetails . RequestBodyInBytes ) ) ;
143
148
}
144
-
149
+
145
150
PostRequestProductCheck < TRequest , TResponse > ( request , response ) ;
146
151
147
152
if ( _productCheckStatus == ProductCheckStatus . Failed )
@@ -206,13 +211,13 @@ internal TResponse DoRequest<TRequest, TResponse, TRequestParameters>(
206
211
207
212
using ( var activity = _activitySource . StartActivity ( $ "Elasticsearch: { request . HttpMethod } { urlTemplate } ", ActivityKind . Client ) )
208
213
{
209
- activity ? . AddTag ( "db.system" , "elasticsearch" ) ;
214
+ activity ? . SetTag ( "db.system" , "elasticsearch" ) ;
210
215
activity ? . SetCustomProperty ( "elastic.transport.client" , true ) ;
211
216
212
217
response = _transport . Request < TResponse > ( request . HttpMethod , resolvedUrl , postData , request . RequestParameters ) ;
213
218
214
219
if ( response . ApiCallDetails . RequestBodyInBytes is not null )
215
- activity ? . AddTag ( "db.statement" , System . Text . Encoding . UTF8 . GetString ( response . ApiCallDetails . RequestBodyInBytes ) ) ;
220
+ activity ? . SetTag ( "db.statement" , System . Text . Encoding . UTF8 . GetString ( response . ApiCallDetails . RequestBodyInBytes ) ) ;
216
221
}
217
222
218
223
PostRequestProductCheck < TRequest , TResponse > ( request , response ) ;
0 commit comments