Skip to content

Commit 0d744ba

Browse files
committed
added port + targetProfile handling to mapper
1 parent 4f06a21 commit 0d744ba

1 file changed

Lines changed: 14 additions & 4 deletions

File tree

internal/controller/discovery/mapper.go

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package discovery
22

33
import (
4+
"fmt"
45
"maps"
56

67
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -20,10 +21,19 @@ func generateTargetResource(d core.DiscoveredTarget, ts *gnmicv1alpha1.TargetSou
2021
},
2122
}
2223

23-
// Add Address from DiscoveredTarget
24-
t.Spec.Address = d.Address
25-
// Add default Target Profile from the TargetSource Spec TargetProfile
26-
t.Spec.Profile = ts.Spec.TargetProfile
24+
// Add Address + Port from DiscoveredTarget or use TargetSource.spec.targetPort
25+
targetPort := ts.Spec.TargetPort
26+
if d.Port != 0 {
27+
targetPort = d.Port
28+
}
29+
t.Spec.Address = fmt.Sprintf("%s:%d", d.Address, targetPort)
30+
31+
// Add discovered Target Profile or use TargetSource.spec.targetProfile
32+
targetProfile := ts.Spec.TargetProfile
33+
if d.TargetProfile != "" {
34+
targetProfile = d.TargetProfile
35+
}
36+
t.Spec.Profile = targetProfile
2737

2838
// Copy TargetLabels from TargetSource Spec & DiscoveredTarget. Discovered labels take precedence over TargetSource labels.
2939
maps.Copy(t.Labels, ts.Spec.TargetLabels)

0 commit comments

Comments
 (0)