skip realtime payloads in fake intake aggregator

DataDog · Jun 28, 2024 · 2a81deb · 2a81deb
1 parent 385ce66
commit 2a81deb
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/test/fakeintake/aggregator/containerAggregator.go b/test/fakeintake/aggregator/containerAggregator.go
@@ -44,6 +44,9 @@ func ParseContainerPayload(payload api.Payload) ([]*ContainerPayload, error) {
 	switch m := msg.Body.(type) {
 	case *agentmodel.CollectorContainer:
 		return []*ContainerPayload{{CollectorContainer: *m, collectedTime: payload.Timestamp}}, nil
+	case *agentmodel.CollectorContainerRealTime
+		// skip real-time payloads
+		return nil, nil
 	default:
 		return nil, fmt.Errorf("unexpected type %s", msg.Header.Type)
 	}