Decoupled API version and Schema version. Fixed Record datatype (#1346)

open-telemetry · Jun 13, 2024 · 6867c50 · 6867c50
1 parent e6ef326
commit 6867c50
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/collector/internal/telemetryapi/client.go b/collector/internal/telemetryapi/client.go
@@ -27,8 +27,11 @@ import (
 )
 
 const (
+	ApiVersion20220701             = "2022-07-01"
+	ApiVersionLatest               = ApiVersion20220701
 	SchemaVersion20220701          = "2022-07-01"
-	SchemaVersionLatest            = SchemaVersion20220701
+	SchemaVersion20221213          = "2022-12-13"
+	SchemaVersionLatest            = SchemaVersion20221213
 	lambdaAgentIdentifierHeaderKey = "Lambda-Extension-Identifier"
 )
 
@@ -42,7 +45,7 @@ func NewClient(logger *zap.Logger) *Client {
 	return &Client{
 		logger:     logger.Named("telemetryAPI.Client"),
 		httpClient: &http.Client{},
-		baseURL:    fmt.Sprintf("http://%s/%s/telemetry", os.Getenv("AWS_LAMBDA_RUNTIME_API"), SchemaVersionLatest),
+		baseURL:    fmt.Sprintf("http://%s/%s/telemetry", os.Getenv("AWS_LAMBDA_RUNTIME_API"), ApiVersionLatest),
 	}
 }
 

diff --git a/collector/receiver/telemetryapireceiver/types.go b/collector/receiver/telemetryapireceiver/types.go
@@ -15,7 +15,7 @@
 package telemetryapireceiver // import "github.com/open-telemetry/opentelemetry-lambda/collector/receiver/telemetryapireceiver"
 
 type event struct {
-	Time   string         `json:"time"`
-	Type   string         `json:"type"`
-	Record map[string]any `json:"record"`
+	Time   string `json:"time"`
+	Type   string `json:"type"`
+	Record any    `json:"record"`
 }