otlpmetricstream

Documentation

Index

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

Constants

const (
	// Supported version depends on version of go.opentelemetry.io/collector/pdata/pmetric/pmetricotlp dependency
	TypeStr = "otlp_v1"
)

Types

type Unmarshaler

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

Unmarshaler for the CloudWatch Metric Stream OpenTelemetry record format.

More details can be found at: https://docs.aws.amazon.com/AmazonCloudWatch/latest/monitoring/CloudWatch-metric-streams-formats-opentelemetry-100.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 pmetric.Metrics