Skip to content

Commit

Permalink
Revert "service discovery: Report additional names separately (#33817)"
Browse files Browse the repository at this point in the history
This reverts commit 27d2166.
  • Loading branch information
FlorentClarret authored Feb 10, 2025
1 parent ab77e3a commit f6e7ac3
Show file tree
Hide file tree
Showing 7 changed files with 23 additions and 39 deletions.
2 changes: 0 additions & 2 deletions pkg/collector/corechecks/servicediscovery/events.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@ type eventPayload struct {
ServiceName string `json:"service_name"`
GeneratedServiceName string `json:"generated_service_name"`
GeneratedServiceNameSource string `json:"generated_service_name_source,omitempty"`
AdditionalGeneratedNames []string `json:"additional_generated_names,omitempty"`
ContainerServiceName string `json:"container_service_name,omitempty"`
ContainerServiceNameSource string `json:"container_service_name_source,omitempty"`
DDService string `json:"dd_service,omitempty"`
Expand Down Expand Up @@ -83,7 +82,6 @@ func (ts *telemetrySender) newEvent(t eventType, service model.Service) *event {
ServiceName: service.Name,
GeneratedServiceName: service.GeneratedName,
GeneratedServiceNameSource: service.GeneratedNameSource,
AdditionalGeneratedNames: service.AdditionalGeneratedNames,
ContainerServiceName: service.ContainerServiceName,
ContainerServiceNameSource: service.ContainerServiceNameSource,
DDService: service.DDService,
Expand Down
4 changes: 0 additions & 4 deletions pkg/collector/corechecks/servicediscovery/events_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,6 @@ func Test_telemetrySender(t *testing.T) {
Name: "test-service",
GeneratedName: "generated-name",
GeneratedNameSource: "generated-name-source",
AdditionalGeneratedNames: []string{"additional0", "additional1"},
ContainerServiceName: "container-service-name",
ContainerServiceNameSource: "service",
DDService: "dd-service",
Expand Down Expand Up @@ -87,7 +86,6 @@ func Test_telemetrySender(t *testing.T) {
ServiceName: "test-service",
GeneratedServiceName: "generated-name",
GeneratedServiceNameSource: "generated-name-source",
AdditionalGeneratedNames: []string{"additional0", "additional1"},
ContainerServiceName: "container-service-name",
ContainerServiceNameSource: "service",
DDService: "dd-service",
Expand Down Expand Up @@ -116,7 +114,6 @@ func Test_telemetrySender(t *testing.T) {
ServiceName: "test-service",
GeneratedServiceName: "generated-name",
GeneratedServiceNameSource: "generated-name-source",
AdditionalGeneratedNames: []string{"additional0", "additional1"},
ContainerServiceName: "container-service-name",
ContainerServiceNameSource: "service",
DDService: "dd-service",
Expand Down Expand Up @@ -145,7 +142,6 @@ func Test_telemetrySender(t *testing.T) {
ServiceName: "test-service",
GeneratedServiceName: "generated-name",
GeneratedServiceNameSource: "generated-name-source",
AdditionalGeneratedNames: []string{"additional0", "additional1"},
ContainerServiceName: "container-service-name",
ContainerServiceNameSource: "service",
DDService: "dd-service",
Expand Down
3 changes: 0 additions & 3 deletions pkg/collector/corechecks/servicediscovery/impl_linux_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,6 @@ var (
Name: "python-service",
GeneratedName: "python-service",
GeneratedNameSource: "python-service-source",
AdditionalGeneratedNames: []string{"bar", "foo"},
ContainerServiceName: "test-service-1-container",
ContainerServiceNameSource: "app",
Language: "python",
Expand Down Expand Up @@ -269,7 +268,6 @@ func Test_linuxImpl(t *testing.T) {
ServiceName: "python-service",
GeneratedServiceName: "python-service",
GeneratedServiceNameSource: "python-service-source",
AdditionalGeneratedNames: []string{"bar", "foo"},
ContainerServiceName: "test-service-1-container",
ContainerServiceNameSource: "app",
ServiceType: "web_service",
Expand All @@ -293,7 +291,6 @@ func Test_linuxImpl(t *testing.T) {
ServiceName: "python-service",
GeneratedServiceName: "python-service",
GeneratedServiceNameSource: "python-service-source",
AdditionalGeneratedNames: []string{"bar", "foo"},
ContainerServiceName: "test-service-1-container",
ContainerServiceNameSource: "app",
ServiceType: "web_service",
Expand Down
1 change: 0 additions & 1 deletion pkg/collector/corechecks/servicediscovery/model/model.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ type Service struct {
Name string `json:"name"`
GeneratedName string `json:"generated_name"`
GeneratedNameSource string `json:"generated_name_source"`
AdditionalGeneratedNames []string `json:"additional_generated_names"`
ContainerServiceName string `json:"container_service_name"`
ContainerServiceNameSource string `json:"container_service_name_source"`
DDService string `json:"dd_service"`
Expand Down
21 changes: 9 additions & 12 deletions pkg/collector/corechecks/servicediscovery/module/impl_linux.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,6 @@ type serviceInfo struct {
name string
generatedName string
generatedNameSource string
additionalGeneratedNames []string
containerServiceName string
containerServiceNameSource string
ddServiceName string
Expand Down Expand Up @@ -88,7 +87,6 @@ func (i *serviceInfo) toModelService(pid int32, out *model.Service) *model.Servi
out.Name = i.name
out.GeneratedName = i.generatedName
out.GeneratedNameSource = i.generatedNameSource
out.AdditionalGeneratedNames = i.additionalGeneratedNames
out.ContainerServiceName = i.containerServiceName
out.ContainerServiceNameSource = i.containerServiceNameSource
out.DDService = i.ddServiceName
Expand Down Expand Up @@ -540,16 +538,15 @@ func (s *discovery) getServiceInfo(pid int32) (*serviceInfo, error) {
}

return &serviceInfo{
name: name,
generatedName: nameMeta.Name,
generatedNameSource: string(nameMeta.Source),
additionalGeneratedNames: nameMeta.AdditionalNames,
ddServiceName: nameMeta.DDService,
language: lang,
apmInstrumentation: apmInstrumentation,
ddServiceInjected: nameMeta.DDServiceInjected,
cmdLine: sanitizeCmdLine(s.scrubber, cmdline),
startTimeMilli: uint64(createTime),
name: name,
generatedName: nameMeta.Name,
generatedNameSource: string(nameMeta.Source),
ddServiceName: nameMeta.DDService,
language: lang,
apmInstrumentation: apmInstrumentation,
ddServiceInjected: nameMeta.DDServiceInjected,
cmdLine: sanitizeCmdLine(s.scrubber, cmdline),
startTimeMilli: uint64(createTime),
}, nil
}

Expand Down
26 changes: 12 additions & 14 deletions pkg/collector/corechecks/servicediscovery/service_detector.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,31 +23,29 @@ type ServiceMetadata struct {
}

func fixAdditionalNames(additionalNames []string) []string {
if len(additionalNames) == 0 {
return additionalNames
}

out := make([]string, 0, len(additionalNames))
for _, v := range additionalNames {
if len(strings.TrimSpace(v)) == 0 {
continue
}

// lang is only used for fallback names, which we don't use since we
// check for errors.
norm, err := traceutil.NormalizeService(v, "")
if err == nil {
out = append(out, norm)
if len(strings.TrimSpace(v)) > 0 {
out = append(out, v)
}
}
slices.Sort(out)
return out
}

func makeFinalName(meta usm.ServiceMetadata) string {
name := meta.Name
if len(meta.AdditionalNames) > 0 {
name = name + "-" + strings.Join(fixAdditionalNames(meta.AdditionalNames), "-")
}

return name
}

// fixupMetadata performs additional adjustments on the meta data returned from
// the meta data extraction library.
func fixupMetadata(meta usm.ServiceMetadata, lang language.Language) usm.ServiceMetadata {
meta.AdditionalNames = fixAdditionalNames(meta.AdditionalNames)
meta.Name = makeFinalName(meta)

langName := ""
if lang != language.Unknown {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,6 @@ func TestFixup(t *testing.T) {
assert.Equal(t, meta.Name, "unnamed-service")
assert.Equal(t, meta.DDService, "")

meta = fixupMetadata(usm.ServiceMetadata{Name: "foo", AdditionalNames: []string{"bAr", " ", "*", "baz", "a"}}, language.Go)
assert.Equal(t, "foo", meta.Name)
assert.Equal(t, []string{"a", "bar", "baz"}, meta.AdditionalNames)
meta = fixupMetadata(usm.ServiceMetadata{Name: "foo", AdditionalNames: []string{"bar", "baz"}}, language.Go)
assert.Equal(t, meta.Name, "foo-bar-baz")
}

0 comments on commit f6e7ac3

Please sign in to comment.