Skip to content

Commit a2732f6

Browse files
committed
update dropped records integer type
1 parent a99296b commit a2732f6

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

collector/receiver/telemetryapireceiver/receiver.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -354,8 +354,8 @@ func createPlatformMessage(requestId string, functionVersion string, eventType s
354354
return fmt.Sprintf(platformExtensionLogFmt, name, state, events)
355355
}
356356
case string(telemetryapi.PlatformLogsDropped):
357-
droppedRecords, _ := record["droppedRecords"].(int64)
358-
droppedBytes, _ := record["droppedBytes"].(int64)
357+
droppedRecords, _ := record["droppedRecords"].(int32)
358+
droppedBytes, _ := record["droppedBytes"].(int32)
359359
reason, _ := record["reason"].(string)
360360
if reason != "" {
361361
return fmt.Sprintf(platformLogsDroppedLogFmt, int(droppedRecords), int(droppedBytes), reason)

collector/receiver/telemetryapireceiver/receiver_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1236,8 +1236,8 @@ func TestCreatePlatformMessage(t *testing.T) {
12361236
functionVersion: "",
12371237
eventType: "platform.logsDropped",
12381238
record: map[string]interface{}{
1239-
"droppedRecords": int64(10),
1240-
"droppedBytes": int64(1024),
1239+
"droppedRecords": int32(10),
1240+
"droppedBytes": int32(1024),
12411241
"reason": "",
12421242
},
12431243
expected: "",

0 commit comments

Comments
 (0)