added tests to improve coverage

Signed-off-by: Andreas Gkizas <[email protected]>

Author: gizas

exporter/exporterhelper/logs_test.go

@@ -59,6 +59,20 @@ func TestLogsRequest(t *testing.T) {
 	)
 }
 
+func TestLogsEncoding_UnmarshalError(t *testing.T) {
+	fgOrigReadState := queue.PersistRequestContextOnRead
+	queue.PersistRequestContextOnRead = func() bool { return false }
+	t.Cleanup(func() {
+		queue.PersistRequestContextOnRead = fgOrigReadState
+	})
+
+	enc := logsEncoding{}
+	ctx, req, err := enc.Unmarshal([]byte("!invalid-proto"))
+	assert.Error(t, err)
+	assert.Nil(t, req)
+	assert.NotNil(t, ctx)
+}
+
 func TestLogs_InvalidName(t *testing.T) {
 	le, err := NewLogs(context.Background(), exportertest.NewNopSettings(exportertest.NopType), nil, newPushLogsData(nil))
 	require.Nil(t, le)

exporter/exporterhelper/metrics_test.go

@@ -59,6 +59,20 @@ func TestMetricsRequest(t *testing.T) {
 	)
 }
 
+func TestMetricsEncoding_UnmarshalError(t *testing.T) {
+	fgOrigReadState := queue.PersistRequestContextOnRead
+	queue.PersistRequestContextOnRead = func() bool { return false }
+	t.Cleanup(func() {
+		queue.PersistRequestContextOnRead = fgOrigReadState
+	})
+
+	enc := metricsEncoding{}
+	ctx, req, err := enc.Unmarshal([]byte("!invalid-proto"))
+	assert.Error(t, err)
+	assert.Nil(t, req)
+	assert.NotNil(t, ctx)
+}
+
 func TestMetrics_NilConfig(t *testing.T) {
 	me, err := NewMetrics(context.Background(), exportertest.NewNopSettings(exportertest.NopType), nil, newPushMetricsData(nil))
 	require.Nil(t, me)

exporter/exporterhelper/traces_test.go

@@ -55,6 +55,20 @@ func TestTracesRequest(t *testing.T) {
 	assert.Equal(t, newTracesRequest(ptrace.NewTraces()), mr.(RequestErrorHandler).OnError(traceErr))
 }
 
+func TestTracesEncoding_UnmarshalError(t *testing.T) {
+	fgOrigReadState := queue.PersistRequestContextOnRead
+	queue.PersistRequestContextOnRead = func() bool { return false }
+	t.Cleanup(func() {
+		queue.PersistRequestContextOnRead = fgOrigReadState
+	})
+
+	enc := tracesEncoding{}
+	ctx, req, err := enc.Unmarshal([]byte("!invalid-proto"))
+	assert.Error(t, err)
+	assert.Nil(t, req)
+	assert.NotNil(t, ctx)
+}
+
 func TestTraces_InvalidName(t *testing.T) {
 	te, err := NewTraces(context.Background(), exportertest.NewNopSettings(exportertest.NopType), nil, newTraceDataPusher(nil))
 	require.Nil(t, te)

receiver/receiverhelper/obsreport_test.go

@@ -503,6 +503,15 @@ func TestCheckReceiverTracesViews(t *testing.T) {
 				Value: int64(0),
 			},
 		}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
+	metadatatest.AssertEqualReceiverFailedSpans(t, tt,
+		[]metricdata.DataPoint[int64]{
+			{
+				Attributes: attribute.NewSet(
+					attribute.String(internal.ReceiverKey, receiverID.String()),
+					attribute.String(internal.TransportKey, transport)),
+				Value: int64(0),
+			},
+		}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
 }
 
 func TestCheckReceiverMetricsViews(t *testing.T) {
@@ -537,6 +546,15 @@ func TestCheckReceiverMetricsViews(t *testing.T) {
 				Value: int64(0),
 			},
 		}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
+	metadatatest.AssertEqualReceiverFailedMetricPoints(t, tt,
+		[]metricdata.DataPoint[int64]{
+			{
+				Attributes: attribute.NewSet(
+					attribute.String(internal.ReceiverKey, receiverID.String()),
+					attribute.String(internal.TransportKey, transport)),
+				Value: int64(0),
+			},
+		}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
 }
 
 func TestCheckReceiverLogsViews(t *testing.T) {
@@ -571,6 +589,15 @@ func TestCheckReceiverLogsViews(t *testing.T) {
 				Value: int64(0),
 			},
 		}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
+	metadatatest.AssertEqualReceiverFailedLogRecords(t, tt,
+		[]metricdata.DataPoint[int64]{
+			{
+				Attributes: attribute.NewSet(
+					attribute.String(internal.ReceiverKey, receiverID.String()),
+					attribute.String(internal.TransportKey, transport)),
+				Value: int64(0),
+			},
+		}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
 }
 
 func testTelemetry(t *testing.T, testFunc func(t *testing.T, tt *componenttest.Telemetry)) {