Make Debug Info ...

Author: zipkid

pkg/clients/tagging/v1/client.go

@@ -75,6 +75,7 @@ func NewClient(
 }
 
 func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region string) ([]*model.TaggedResource, error) {
+	c.logger.Info("Using tagging.Client V1")
 	svc := config.SupportedServices.GetService(job.Namespace)
 	var resources []*model.TaggedResource
 	shouldHaveDiscoveredResources := false
@@ -124,7 +125,7 @@ func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region
 				if resource.FilterThroughTags(job.SearchTags) {
 					resources = append(resources, &resource)
 				} else {
-					c.logger.Debug("Skipping resource because search tags do not match", "arn", resource.ARN)
+					c.logger.Info("Skipping resource because search tags do not match", "arn", resource.ARN)
 				}
 			}
 			return !lastPage
@@ -133,7 +134,7 @@ func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region
 			return nil, err
 		}
 
-		c.logger.Debug("GetResourcesPages finished", "total", len(resources))
+		c.logger.Info("GetResourcesPages finished", "total", len(resources))
 	}
 
 	if ext, ok := ServiceFilters[svc.Namespace]; ok {
@@ -144,7 +145,7 @@ func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region
 				return nil, fmt.Errorf("failed to apply ResourceFunc for %s, %w", svc.Namespace, err)
 			}
 			resources = append(resources, newResources...)
-			c.logger.Debug("ResourceFunc finished", "total", len(resources))
+			c.logger.Info("ResourceFunc finished", "total", len(resources))
 		}
 
 		if ext.FilterFunc != nil {
@@ -153,7 +154,7 @@ func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region
 				return nil, fmt.Errorf("failed to apply FilterFunc for %s, %w", svc.Namespace, err)
 			}
 			resources = filteredResources
-			c.logger.Debug("FilterFunc finished", "total", len(resources))
+			c.logger.Info("FilterFunc finished", "total", len(resources))
 		}
 	}
 

pkg/clients/tagging/v2/client.go

@@ -75,6 +75,7 @@ func NewClient(
 }
 
 func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region string) ([]*model.TaggedResource, error) {
+	c.logger.Info("Using tagging.Client V2")
 	svc := config.SupportedServices.GetService(job.Namespace)
 	var resources []*model.TaggedResource
 	shouldHaveDiscoveredResources := false
@@ -131,12 +132,12 @@ func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region
 				if resource.FilterThroughTags(job.SearchTags) {
 					resources = append(resources, &resource)
 				} else {
-					c.logger.Debug("Skipping resource because search tags do not match", "arn", resource.ARN)
+					c.logger.Info("Skipping resource because search tags do not match", "arn", resource.ARN)
 				}
 			}
 		}
 
-		c.logger.Debug("GetResourcesPages finished", "total", len(resources))
+		c.logger.Info("GetResourcesPages finished", "total", len(resources))
 	}
 
 	if ext, ok := ServiceFilters[svc.Namespace]; ok {
@@ -147,7 +148,7 @@ func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region
 				return nil, fmt.Errorf("failed to apply ResourceFunc for %s, %w", svc.Namespace, err)
 			}
 			resources = append(resources, newResources...)
-			c.logger.Debug("ResourceFunc finished", "total", len(resources))
+			c.logger.Info("ResourceFunc finished", "total", len(resources))
 		}
 
 		if ext.FilterFunc != nil {
@@ -156,7 +157,7 @@ func (c client) GetResources(ctx context.Context, job model.DiscoveryJob, region
 				return nil, fmt.Errorf("failed to apply FilterFunc for %s, %w", svc.Namespace, err)
 			}
 			resources = filteredResources
-			c.logger.Debug("FilterFunc finished", "total", len(resources))
+			c.logger.Info("FilterFunc finished", "total", len(resources))
 		}
 	}