Implemented TargetAllocator resource deployments.

internal/manifests/targetallocator/adapters/config_to_prom_config.go

@@ -9,6 +9,8 @@ import (
 	"net/url"
 	"regexp"
 
+	"github.com/aws/amazon-cloudwatch-agent-operator/internal/naming"
+
 	"github.com/aws/amazon-cloudwatch-agent-operator/internal/manifests/collector/adapters"
 )
 
@@ -194,7 +196,7 @@ func AddHTTPSDConfigToPromConfig(prometheus map[interface{}]interface{}, taServi
 		escapedJob := url.QueryEscape(jobName)
 		scrapeConfig["http_sd_configs"] = []interface{}{
 			map[string]interface{}{
-				"url": fmt.Sprintf("http://%s:80/jobs/%s/targets", taServiceName, escapedJob),
+				"url": fmt.Sprintf("http://%s:%d/jobs/%s/targets", taServiceName, naming.TargetAllocatorPort, escapedJob),
 			},
 		}
 	}
@@ -226,7 +228,7 @@ func AddTAConfigToPromConfig(prometheus map[interface{}]interface{}, taServiceNa
 		return nil, errorNotAMap("target_allocator")
 	}
 
-	targetAllocatorCfg["endpoint"] = fmt.Sprintf("http://%s:80", taServiceName)
+	targetAllocatorCfg["endpoint"] = fmt.Sprintf("http://%s:%d", taServiceName, naming.TargetAllocatorPort)
 	targetAllocatorCfg["interval"] = "30s"
 
 	// Remove the scrape_configs key from the map

internal/manifests/targetallocator/container.go

@@ -23,7 +23,7 @@ func Container(cfg config.Config, logger logr.Logger, otelcol v1alpha1.AmazonClo
 	ports := make([]corev1.ContainerPort, 0)
 	ports = append(ports, corev1.ContainerPort{
 		Name:          "http",
-		ContainerPort: 8080,
+		ContainerPort: naming.TargetAllocatorTargetPort,
 		Protocol:      corev1.ProtocolTCP,
 	})
 

internal/manifests/targetallocator/service.go

@@ -35,8 +35,8 @@ func Service(params manifests.Params) *corev1.Service {
 			Selector: selector,
 			Ports: []corev1.ServicePort{{
 				Name:       "targetallocation",
-				Port:       80,
-				TargetPort: intstr.FromString("http"),
+				Port:       naming.TargetAllocatorPort,
+				TargetPort: intstr.FromInt32(naming.TargetAllocatorTargetPort),
 			}},
 		},
 	}

internal/manifests/targetallocator/service_test.go

@@ -24,7 +24,7 @@ func TestServicePorts(t *testing.T) {
 		Log:     logger,
 	}
 
-	ports := []v1.ServicePort{{Name: "targetallocation", Port: 80, TargetPort: intstr.FromString("http")}}
+	ports := []v1.ServicePort{{Name: "targetallocation", Port: 80, TargetPort: intstr.FromInt32(8080)}}
 
 	s := Service(params)
 

internal/naming/port.go

@@ -9,6 +9,11 @@ import (
 	"strings"
 )
 
+const (
+	TargetAllocatorPort       = 80
+	TargetAllocatorTargetPort = 8080
+)
+
 var (
 	// DNS_LABEL constraints: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#dns-label-names
 	dnsLabelValidation = regexp.MustCompile("^(([A-Za-z0-9][-A-Za-z0-9_.]*)?[A-Za-z0-9])?$")