added debugging through describeinstances trace

Author: gargipanatula

pkg/providers/v1/aws.go

@@ -594,11 +594,12 @@ func newAWSCloud2(cfg config.CloudConfig, awsServices Services, provider config.
 	}
 
 	ec2, err := awsServices.Compute(ctx, regionName)
-	klog.InfoS("Created ec2, ", ec2, "nil check: ", (ec2 == nil))
+	klog.InfoS("[debug] Created ec2, ", ec2, "nil check: ", (ec2 == nil))
 	if err != nil {
 		return nil, fmt.Errorf("error creating AWS EC2 client: %v", err)
 	}
 
+	klog.InfoS("[debug] Created ec2, ", ec2, "nil check: ", (ec2 == nil))
 	ec2v2, err := services.NewEc2SdkV2(ctx, regionName, credentialsV2)
 	if err != nil {
 		return nil, fmt.Errorf("error creating AWS EC2v2 client: %v", err)
@@ -630,6 +631,7 @@ func newAWSCloud2(cfg config.CloudConfig, awsServices Services, provider config.
 		createTagsBatcher: newCreateTagsBatcher(ctx, ec2),
 		deleteTagsBatcher: newDeleteTagsBatcher(ctx, ec2),
 	}
+	klog.InfoS("[debug] Created cloud, ec2:", ec2)
 	awsCloud.instanceCache.cloud = awsCloud
 	awsCloud.zoneCache.cloud = awsCloud
 	awsCloud.instanceTopologyManager = resourcemanagers.NewInstanceTopologyManager(ec2v2, &cfg)
@@ -646,7 +648,9 @@ func newAWSCloud2(cfg config.CloudConfig, awsServices Services, provider config.
 		}
 		awsCloud.vpcID = cfg.Global.VPC
 	} else {
+		klog.InfoS("[debug] calling buildSelfAWSInstance", awsCloud.ec2)
 		selfAWSInstance, err := awsCloud.buildSelfAWSInstance(ctx)
+		klog.InfoS("[debug] done calling buildSelfAWSInstance", awsCloud.ec2)
 		if err != nil {
 			return nil, err
 		}
@@ -1117,7 +1121,9 @@ func (c *Cloud) buildSelfAWSInstance(ctx context.Context) (*awsInstance, error)
 	// information from the instance returned by the EC2 API - it is a
 	// single API call to get all the information, and it means we don't
 	// have two code paths.
+	klog.InfoS("[debug] calling getInstanceByID", c.ec2)
 	instance, err := c.getInstanceByID(ctx, instanceID)
+	klog.InfoS("[debug] done calling getInstanceByID", c.ec2)
 	if err != nil {
 		return nil, fmt.Errorf("error finding instance %s: %q", instanceID, err)
 	}
@@ -3126,7 +3132,9 @@ func (c *Cloud) UpdateLoadBalancer(ctx context.Context, clusterName string, serv
 
 // Returns the instance with the specified ID
 func (c *Cloud) getInstanceByID(ctx context.Context, instanceID string) (*ec2types.Instance, error) {
+	klog.InfoS("[debug] calling getInstancesByIDs", c.ec2)
 	instances, err := c.getInstancesByIDs(ctx, []string{instanceID})
+	klog.InfoS("[debug] done calling getInstancesByIDs", c.ec2)
 	if err != nil {
 		return nil, err
 	}
@@ -3151,7 +3159,9 @@ func (c *Cloud) getInstancesByIDs(ctx context.Context, instanceIDs []string) (ma
 		InstanceIds: instanceIDs,
 	}
 
+	klog.InfoS("[debug] calling DescribeInstances", c.ec2)
 	instances, err := c.ec2.DescribeInstances(ctx, request)
+	klog.InfoS("[debug] done calling DescribeInstances", c.ec2)
 	if err != nil {
 		return nil, err
 	}

pkg/providers/v1/aws_sdk.go

@@ -157,31 +157,31 @@ func (p *awsSDKProvider) getCrossRequestRetryDelay(regionName string) *CrossRequ
 }
 
 func (p *awsSDKProvider) Compute(ctx context.Context, regionName string) (iface.EC2, error) {
-	klog.InfoS("[Compute] entered")
+	klog.InfoS("[debug] [Compute] entered")
 	cfg, err := awsConfig.LoadDefaultConfig(ctx,
 		awsConfig.WithRegion(regionName),
 		awsConfig.WithCredentialsProvider(p.credsV2),
 	)
-	klog.InfoS("[Compute] loaded config, err:", err)
+	klog.InfoS("[debug] [Compute] loaded config, err:", err)
 	if err != nil {
 		return nil, fmt.Errorf("unable to initialize AWS config: %v", err)
 	}
 
 	p.AddHandlersV2(ctx, regionName, &cfg)
-	klog.InfoS("[Compute] added handlers")
+	klog.InfoS("[debug] [Compute] added handlers")
 	var opts []func(*ec2.Options) = p.cfg.GetEC2EndpointOpts(regionName)
 	opts = append(opts, func(o *ec2.Options) {
 		o.Retryer = &customRetryer{
 			retry.NewStandard(),
 		}
 	})
-	klog.InfoS("[Compute] did GetEC2EndpointOpts")
+	klog.InfoS("[debug] [Compute] did GetEC2EndpointOpts")
 	opts = append(opts, func(o *ec2.Options) {
 		o.EndpointResolverV2 = p.cfg.GetCustomEC2Resolver()
 	})
-	klog.InfoS("[Compute] did GetCustomEC2Resolver")
+	klog.InfoS("[debug] [Compute] did GetCustomEC2Resolver")
 	ec2Client := ec2.NewFromConfig(cfg, opts...)
-	klog.InfoS("[Compute] did NewFromConfig")
+	klog.InfoS("[debug] [Compute] did NewFromConfig")
 
 	ec2 := &awsSdkEC2{
 		ec2: ec2Client,

pkg/providers/v1/config/config.go

@@ -135,15 +135,15 @@ func (cfg *CloudConfig) GetRegion(metadata EC2Metadata) (string, error) {
 		return cfg.Global.Region, nil
 	}
 
-	klog.Info("Loading region from metadata service a")
+	klog.Info("Loading region from metadata service [debug] a")
 	region, err := metadata.Region()
-	klog.Info("Loaded region from metadata service, err:", err)
+	klog.Info("[debug] Loaded region from metadata service, err:", err)
 	if err != nil {
 		return "", err
 	}
 
 	cfg.Global.Region = region
-	klog.Info("Loaded region from metadata service, set region to", region)
+	klog.Info("[debug] Loaded region from metadata service, set region to", region)
 	return region, nil
 }