wip

Author: just1not2

cluster-autoscaler/cloudprovider/builder/cloud_provider_builder.go

@@ -35,6 +35,7 @@ func NewCloudProvider(opts config.AutoscalingOptions, informerFactory informers.
 	}
 
 	rl := context.NewResourceLimiterFromAutoscalingOptions(opts)
+	klog.Errorf("WIP just1not2 RLCP: %v", *rl)
 
 	if opts.CloudProviderName == "" {
 		// Ideally this would be an error, but several unit tests of the

cluster-autoscaler/core/scaledown/resource/limits.go

@@ -161,6 +161,7 @@ func (lf *LimitsFinder) customResourcesTotal(context *context.AutoscalingContext
 		}
 	}
 
+	klog.Errorf("WIP just1not2 CRTLIMITS: %v", result)
 	return result, nil
 }
 

cluster-autoscaler/core/scaleup/resource/manager.go

@@ -102,6 +102,7 @@ func (m *Manager) ResourcesLeft(ctx *context.AutoscalingContext, nodeInfos map[s
 	var totalResourcesErr error
 	if cloudprovider.ContainsCustomResources(resourceLimiter.GetResources()) {
 		totalResources, totalResourcesErr = m.customResourcesTotal(ctx, nodeInfos, nodesFromNotAutoscaledGroups)
+		klog.Errorf("WIP just1not2 RESOURCELEFT: %v", totalResources)
 	}
 
 	resultScaleUpLimits := make(Limits)
@@ -133,6 +134,7 @@ func (m *Manager) ResourcesLeft(ctx *context.AutoscalingContext, nodeInfos map[s
 				} else {
 					resultScaleUpLimits[resource] = computeBelowMax(totalResources[resource], max)
 				}
+				klog.Errorf("WIP just1not2 RESOURCELEFT2: %v", resultScaleUpLimits[resource])
 			default:
 				klog.Errorf("Scale up limits defined for unsupported resource '%s'", resource)
 			}

cluster-autoscaler/processors/customresources/custom_resources_processor.go

@@ -21,6 +21,7 @@ import (
 	"k8s.io/autoscaler/cluster-autoscaler/cloudprovider"
 	"k8s.io/autoscaler/cluster-autoscaler/context"
 	"k8s.io/autoscaler/cluster-autoscaler/utils/errors"
+	"k8s.io/klog/v2"
 )
 
 // CustomResourceTarget contains information about targeted custom resources
@@ -44,5 +45,6 @@ type CustomResourcesProcessor interface {
 
 // NewDefaultCustomResourcesProcessor returns a default instance of CustomResourcesProcessor.
 func NewDefaultCustomResourcesProcessor() CustomResourcesProcessor {
+	klog.Errorf("WIP: datadog resource processor added")
 	return &DatadogCustomResourcesProcessor{}
 }

cluster-autoscaler/processors/customresources/datadog_custom_resources.go

@@ -87,6 +87,8 @@ func (p *DatadogCustomResourcesProcessor) GetNodeResourceTargets(context *contex
 			}
 			targetValue = intValue
 		}
+
+		klog.Errorf("WIP just1not2 CR: %v - %v", customResource, targetValue)
 		targets = append(targets, CustomResourceTarget{
 			ResourceType:  customResource,
 			ResourceCount: targetValue,