cwmetricstream

Documentation

Index

• Constants
• func ToSemConvAttributeKey(key string) string
• type Unmarshaler
  • func NewUnmarshaler(logger *zap.Logger) *Unmarshaler
  • func (u Unmarshaler) Type() string
  • func (u Unmarshaler) Unmarshal(records [][]byte) (pmetric.Metrics, error)

Constants

const (
	TypeStr = "cwmetrics"
)

Functions

func ToSemConvAttributeKey

func ToSemConvAttributeKey(key string) string

ToSemConvAttributeKey maps some common keys to semantic convention attributes.

Types

type Unmarshaler

type Unmarshaler struct {
	// contains filtered or unexported fields
}

Unmarshaler for the CloudWatch Metric Stream JSON record format.

More details can be found at: https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-metric-streams-formats-json.html

func NewUnmarshaler

func NewUnmarshaler(logger *zap.Logger) *Unmarshaler

NewUnmarshaler creates a new instance of the Unmarshaler.

func (Unmarshaler) Type

func (u Unmarshaler) Type() string

Type of the serialized messages.

func (Unmarshaler) Unmarshal

func (u Unmarshaler) Unmarshal(records [][]byte) (pmetric.Metrics, error)

Unmarshal deserializes the records into cWMetrics and uses the resourceMetricsBuilder to group them into a single pmetric.Metrics. Skips invalid cWMetrics received in the record and