firehose

Documentation

Index

• func ProcessRequestBody(b []byte) ([]byte, error)

Functions

func ProcessRequestBody

func ProcessRequestBody(b []byte) ([]byte, error)

ProcessRequestBody converts Cloudwatch Stream protobuf metrics HTTP request body delivered via Firehose into OpenTelemetry protobuf message.

See https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-Metric-Streams.html

It joins decoded "data" fields from "record" list:

{
  "requestId": "<uuid-string>",
  "timestamp": <int64-value>,
  "records": [
    {
      "data": "<base64-encoded-payload>"
    }
  ]
}