@@ -187,27 +187,27 @@ func (rec *ObsReport) endOp(
187
187
188
188
// end span according to errors
189
189
if span .IsRecording () {
190
- var acceptedItemsKey , refusedItemsKey , internalErrorsKey string
190
+ var acceptedItemsKey , refusedItemsKey , failedItemsKey string
191
191
switch signal {
192
192
case pipeline .SignalTraces :
193
193
acceptedItemsKey = internal .AcceptedSpansKey
194
194
refusedItemsKey = internal .RefusedSpansKey
195
- internalErrorsKey = internal .FailedSpansKey
195
+ failedItemsKey = internal .FailedSpansKey
196
196
case pipeline .SignalMetrics :
197
197
acceptedItemsKey = internal .AcceptedMetricPointsKey
198
198
refusedItemsKey = internal .RefusedMetricPointsKey
199
- internalErrorsKey = internal .FailedMetricPointsKey
199
+ failedItemsKey = internal .FailedMetricPointsKey
200
200
case pipeline .SignalLogs :
201
201
acceptedItemsKey = internal .AcceptedLogRecordsKey
202
202
refusedItemsKey = internal .RefusedLogRecordsKey
203
- internalErrorsKey = internal .FailedLogRecordsKey
203
+ failedItemsKey = internal .FailedLogRecordsKey
204
204
}
205
205
206
206
span .SetAttributes (
207
207
attribute .String (internal .FormatKey , format ),
208
208
attribute .Int64 (acceptedItemsKey , int64 (numAccepted )),
209
209
attribute .Int64 (refusedItemsKey , int64 (numRefused )),
210
- attribute .Int64 (internalErrorsKey , int64 (numFailedErrors )),
210
+ attribute .Int64 (failedItemsKey , int64 (numFailedErrors )),
211
211
)
212
212
if err != nil {
213
213
span .SetStatus (codes .Error , err .Error ())
@@ -217,23 +217,23 @@ func (rec *ObsReport) endOp(
217
217
}
218
218
219
219
func (rec * ObsReport ) recordMetrics (receiverCtx context.Context , signal pipeline.Signal , numAccepted , numRefused , numFailedErrors int ) {
220
- var acceptedMeasure , refusedMeasure , internalErrorsMeasure metric.Int64Counter
220
+ var acceptedMeasure , refusedMeasure , failedMeasure metric.Int64Counter
221
221
switch signal {
222
222
case pipeline .SignalTraces :
223
223
acceptedMeasure = rec .telemetryBuilder .ReceiverAcceptedSpans
224
224
refusedMeasure = rec .telemetryBuilder .ReceiverRefusedSpans
225
- internalErrorsMeasure = rec .telemetryBuilder .ReceiverFailedSpans
225
+ failedMeasure = rec .telemetryBuilder .ReceiverFailedSpans
226
226
case pipeline .SignalMetrics :
227
227
acceptedMeasure = rec .telemetryBuilder .ReceiverAcceptedMetricPoints
228
228
refusedMeasure = rec .telemetryBuilder .ReceiverRefusedMetricPoints
229
- internalErrorsMeasure = rec .telemetryBuilder .ReceiverFailedMetricPoints
229
+ failedMeasure = rec .telemetryBuilder .ReceiverFailedMetricPoints
230
230
case pipeline .SignalLogs :
231
231
acceptedMeasure = rec .telemetryBuilder .ReceiverAcceptedLogRecords
232
232
refusedMeasure = rec .telemetryBuilder .ReceiverRefusedLogRecords
233
- internalErrorsMeasure = rec .telemetryBuilder .ReceiverFailedLogRecords
233
+ failedMeasure = rec .telemetryBuilder .ReceiverFailedLogRecords
234
234
}
235
235
236
236
acceptedMeasure .Add (receiverCtx , int64 (numAccepted ), rec .otelAttrs )
237
237
refusedMeasure .Add (receiverCtx , int64 (numRefused ), rec .otelAttrs )
238
- internalErrorsMeasure .Add (receiverCtx , int64 (numFailedErrors ), rec .otelAttrs )
238
+ failedMeasure .Add (receiverCtx , int64 (numFailedErrors ), rec .otelAttrs )
239
239
}
0 commit comments