Copy multiple attributes/labels in k8sattributes

[zeitlinger]

Component(s)

processor/k8sattributes

Is your feature request related to a problem? Please describe.

As a user, I'd like to add my resource attributes as k8s attributes/labels in a generic way:

opentelemetry.io/resource.deployment.environment should become deployment.environment and so on

Describe the solution you'd like

similar to to the existing regex: field=(?P<value>.+) syntax

k8sattributes:
  auth_type: "serviceAccount"
  passthrough: false
  extract:
   labels:
     - key_regex: opentelemetry.io/resource.(?P<key>.+)
       from: pod

Describe alternatives you've considered

No response

Additional context

No response

[github-actions]

Pinging code owners:

• processor/k8sattributes: @dmitryax @rmfitzpatrick @fatsheep9146 @TylerHelmuth

See Adding Labels via Comments if you do not have permissions to add labels yourself.

[zeitlinger]

apparently this feature already exists - untested and undocumented

package kube

import (
	"github.com/stretchr/testify/assert"
	"regexp"
	"testing"
)

func TestFieldExtractionRule_extractFromMetadata(t *testing.T) {
	type fields struct {
		Name                 string
		Key                  string
		KeyRegex             *regexp.Regexp
		HasKeyRegexReference bool
		Regex                *regexp.Regexp
		From                 string
	}
	tests := []struct {
		name   string
		fields fields
		want   map[string]string
	}{
		{
			name: "Test extractFromMetadata",
			fields: fields{
				Name:                 "$key",
				KeyRegex:             regexp.MustCompile("opentelemetry.io/resource.(?P<key>.+)"),
				HasKeyRegexReference: true,
			},
			want: map[string]string{
				"deployment.environment": "staging",
			},
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			r := &FieldExtractionRule{
				Name:                 tt.fields.Name,
				Key:                  tt.fields.Key,
				KeyRegex:             tt.fields.KeyRegex,
				HasKeyRegexReference: tt.fields.HasKeyRegexReference,
				Regex:                tt.fields.Regex,
				From:                 tt.fields.From,
			}
			m := map[string]string{
				"opentelemetry.io/resource.deployment.environment": "staging",
			}
			tags := make(map[string]string)
			r.extractFromMetadata(m, tags, "")
			assert.Equal(t, tt.want, tags)
		})
	}
}

here is a test for it.