[amazon-cloudwatch-agent-operator] feat(target-allocator): add per-node allocation strategy

apis/v1alpha1/allocation_strategy.go

@@ -5,11 +5,15 @@ package v1alpha1
 
 type (
 	// AmazonCloudWatchAgentTargetAllocatorAllocationStrategy represent which strategy to distribute target to each collector
-	// +kubebuilder:validation:Enum=consistent-hashing
+	// +kubebuilder:validation:Enum=consistent-hashing;per-node
 	AmazonCloudWatchAgentTargetAllocatorAllocationStrategy string
 )
 
 const (
 	// AmazonCloudWatchAgentTargetAllocatorAllocationStrategyConsistentHashing targets will be consistently added to collectors, which allows a high-availability setup.
 	AmazonCloudWatchAgentTargetAllocatorAllocationStrategyConsistentHashing AmazonCloudWatchAgentTargetAllocatorAllocationStrategy = "consistent-hashing"
+
+	// AmazonCloudWatchAgentTargetAllocatorAllocationStrategyPerNode targets will be allocated to the collector running on the same node as the target.
+	// Targets without a resolvable node fall back to the configured fallback strategy (consistent-hashing).
+	AmazonCloudWatchAgentTargetAllocatorAllocationStrategyPerNode AmazonCloudWatchAgentTargetAllocatorAllocationStrategy = "per-node"
 )

cmd/amazon-cloudwatch-agent-target-allocator/allocation/consistent_hashing.go

@@ -150,7 +150,7 @@ func (c *consistentHashingAllocator) handleCollectors(diff diff.Changes[*Collect
 	}
 	// Insert the new collectors
 	for _, i := range diff.Additions() {
-		c.collectors[i.Name] = NewCollector(i.Name)
+		c.collectors[i.Name] = NewCollector(i.Name, i.NodeName)
 		c.consistentHasher.Add(c.collectors[i.Name])
 	}