Skip to content

Commit

Permalink
updating kong pdk
Browse files Browse the repository at this point in the history
  • Loading branch information
pkalum committed Nov 28, 2023
1 parent 9f9c3d9 commit 1291f2b
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions plugins/gateway/kong/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -232,13 +232,16 @@ func createTelemetry(kong *pdk.PDK) (*models.Telemetry, error) {
}
host, port, _ := parseKongHost(routedService.Host)

encodedReqBody := strfmt.Base64(reqBody)
encodedRespBody := strfmt.Base64(resBody)

telemetry := models.Telemetry{
DestinationAddress: ":" + port, // No destination ip for now
DestinationNamespace: "", // No namespace here for now as it is concatenated on 'host'
Request: &models.Request{
Common: &models.Common{
TruncatedBody: truncatedBodyReq,
Body: strfmt.Base64(reqBody),
Body: encodedReqBody,
Headers: createHeaders(reqHeaders),
Version: fmt.Sprintf("%f", version),
Time: requestTime,
Expand All @@ -251,7 +254,7 @@ func createTelemetry(kong *pdk.PDK) (*models.Telemetry, error) {
Response: &models.Response{
Common: &models.Common{
TruncatedBody: truncatedBodyRes,
Body: strfmt.Base64(resBody),
Body: encodedRespBody,
Headers: createHeaders(resHeaders),
Version: fmt.Sprintf("%f", version),
Time: responseTime,
Expand Down

0 comments on commit 1291f2b

Please sign in to comment.