firehose

Documentation

Index

• func ProcessRequestBody(b []byte) ([]byte, error)
• func ResponseWriter(w http.ResponseWriter, ct time.Time, reqID string, err error)
• func WriteSuccessResponse(w http.ResponseWriter, r *http.Request)

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>"
    }
  ]
}

func ResponseWriter

func ResponseWriter(w http.ResponseWriter, ct time.Time, reqID string, err error)

ResponseWriter writes response for AWS Firehose HTTP Endpoint request https://docs.aws.amazon.com/firehose/latest/dev/httpdeliveryrequestresponse.html#responseformat

func WriteSuccessResponse

func WriteSuccessResponse(w http.ResponseWriter, r *http.Request)

WriteSuccessResponse writes success response for AWS Firehose request.

See https://docs.aws.amazon.com/firehose/latest/dev/httpdeliveryrequestresponse.html#responseformat