mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
Dmitry AnoshinandGitHub
0192199ccc
Resolves https://github.com/open-telemetry/opentelemetry-collector/issues/13324
34 lines
1.1 KiB
Go
34 lines
1.1 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package otlptext // import "go.opentelemetry.io/collector/exporter/debugexporter/internal/otlptext"
|
|
|
|
import (
|
|
"go.opentelemetry.io/collector/pdata/pcommon"
|
|
"go.opentelemetry.io/collector/pdata/xpdata/entity"
|
|
)
|
|
|
|
func addEntityRefsToResource(resource pcommon.Resource) {
|
|
entityRefs := entity.ResourceEntityRefs(resource)
|
|
|
|
serviceRef := entityRefs.AppendEmpty()
|
|
serviceRef.SetType("service")
|
|
serviceRef.SetSchemaUrl("https://opentelemetry.io/schemas/1.21.0")
|
|
serviceRef.IdKeys().Append("service.name")
|
|
serviceRef.DescriptionKeys().Append("service.version")
|
|
|
|
if _, exists := resource.Attributes().Get("host.name"); exists {
|
|
hostRef := entityRefs.AppendEmpty()
|
|
hostRef.SetType("host")
|
|
hostRef.IdKeys().Append("host.name")
|
|
}
|
|
}
|
|
|
|
func setupResourceWithEntityRefs(resource pcommon.Resource) {
|
|
resource.Attributes().PutStr("service.name", "my-service")
|
|
resource.Attributes().PutStr("service.version", "1.0.0")
|
|
resource.Attributes().PutStr("host.name", "server-01")
|
|
|
|
addEntityRefsToResource(resource)
|
|
}
|