feat: Add support for exporting telemetry API 'platform.*' log events

collector/internal/telemetryapi/listener_test.go

@@ -45,11 +45,6 @@ func setupListener(t *testing.T) (*Listener, string) {
 
 	address, err := listener.Start()
 	require.NoError(t, err)
-
-	t.Cleanup(func() {
-		listener.Shutdown()
-	})
-
 	return listener, address
 }
 
@@ -183,6 +178,7 @@ func TestListenOnAddress(t *testing.T) {
 
 func TestListener_StartAndShutdown(t *testing.T) {
 	listener, address := setupListener(t)
+	defer listener.Shutdown()
 	require.NotEqual(t, address, "", "Start() should not return an empty address")
 	require.True(t, strings.HasPrefix(address, "http://"), "Address should start with http://")
 	require.NotNil(t, listener.httpServer, "httpServer should not be nil")
@@ -241,6 +237,7 @@ func TestListener_httpHandler(t *testing.T) {
 	for _, test := range testCases {
 		t.Run(test.name, func(t *testing.T) {
 			listener, address := setupListener(t)
+			defer listener.Shutdown()
 			submitEvents(t, address, test.events)
 			require.EventuallyWithT(t, func(c *assert.CollectT) {
 				require.Equal(c, test.expectedCount, listener.queue.Len())
@@ -302,6 +299,7 @@ func TestListener_Wait_Success(t *testing.T) {
 	for _, test := range testCases {
 		t.Run(test.name, func(t *testing.T) {
 			listener, address := setupListener(t)
+			defer listener.Shutdown()
 
 			waitDone := make(chan error, 1)
 			go func() {

collector/internal/telemetryapi/types.go

@@ -24,15 +24,29 @@ const (
 	PlatformInitStart EventType = Platform + ".initStart"
 	// PlatformInitRuntimeDone is used when function initialization ended.
 	PlatformInitRuntimeDone EventType = Platform + ".initRuntimeDone"
-	// PlatformReport is used when a report of function invocation is received.
-	PlatformReport EventType = Platform + ".report"
-	// Function invocation started.
+	// PlatformInitReport is used when a report of function initialization is received.
+	PlatformInitReport EventType = Platform + ".initReport"
+	// PlatformStart is used when function invocation started.
 	PlatformStart EventType = Platform + ".start"
-	// The runtime finished processing an event with either success or failure.
+	// PlatformRuntimeDone is used when the runtime finished processing an event with either success or failure.
 	PlatformRuntimeDone EventType = Platform + ".runtimeDone"
+	// PlatformReport is used when a report of function invocation is received.
+	PlatformReport EventType = Platform + ".report"
+	// PlatformRestoreStart is used when runtime restore started.
+	PlatformRestoreStart EventType = Platform + ".restoreStart"
+	// PlatformRestoreRuntimeDone is used when runtime restore completed.
+	PlatformRestoreRuntimeDone EventType = Platform + ".restoreRuntimeDone"
+	// PlatformRestoreReport is used when a report of runtime restore is received.
+	PlatformRestoreReport EventType = Platform + ".restoreReport"
+	// PlatformExtension is used for extension state events.
+	PlatformExtension EventType = Platform + ".extension"
+	// PlatformTelemetrySubscription is used when the extension subscribed to the Telemetry API.
+	PlatformTelemetrySubscription EventType = Platform + ".telemetrySubscription"
+	// PlatformLogsDropped is used when Lambda dropped log entries.
+	PlatformLogsDropped EventType = Platform + ".logsDropped"
 	// Function is used to receive log events emitted by the function
 	Function EventType = "function"
-	// Extension is used is to receive log events emitted by the extension
+	// Extension is used to receive log events emitted by the extension
 	Extension EventType = "extension"
 )
 

collector/lambdacomponents/receiver/telemetryapi.go

@@ -17,8 +17,9 @@
 package receiver
 
 import (
-	"github.com/open-telemetry/opentelemetry-lambda/collector/receiver/telemetryapireceiver"
 	"go.opentelemetry.io/collector/receiver"
+
+	"github.com/open-telemetry/opentelemetry-lambda/collector/receiver/telemetryapireceiver"
 )
 
 func init() {

collector/receiver/telemetryapireceiver/config.go

@@ -23,7 +23,7 @@ type Config struct {
 	extensionID string
 	Port        int      `mapstructure:"port"`
 	Types       []string `mapstructure:"types"`
-	LogReport   bool     `mapstructure:"log_report"`
+	LogReport   *bool    `mapstructure:"log_report"`
 }
 
 // Validate validates the configuration by checking for missing or invalid fields