[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"
 )

apis/v1alpha1/amazoncloudwatchagent_types.go

@@ -316,7 +316,7 @@ type AmazonCloudWatchAgentTargetAllocator struct {
 	// +optional
 	Resources v1.ResourceRequirements `json:"resources,omitempty"`
 	// AllocationStrategy determines which strategy the target allocator should use for allocation.
-	// The current option is consistent-hashing.
+	// The options are consistent-hashing and per-node.
 	// +optional
 	AllocationStrategy AmazonCloudWatchAgentTargetAllocatorAllocationStrategy `json:"allocationStrategy,omitempty"`
 	// FilterStrategy determines how to filter targets before allocating them among the collectors.

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])
 	}