Make Debug Info ...

Author: zipkid

pkg/clients/tagging/v1/client.go

@@ -124,7 +124,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 +133,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 +144,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 +153,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

@@ -131,12 +131,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 +147,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 +156,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/job/discovery.go

@@ -46,7 +46,9 @@ func runDiscoveryJob(
 ) ([]*model.TaggedResource, []*model.CloudwatchData) {
 	logger.Debug("Get tagged resources")
 
+	logger.Info("START - Get tagged resources")
 	resources, err := clientTag.GetResources(ctx, job, region)
+	logger.Info("STOP  - Get tagged resources")
 	if err != nil {
 		if errors.Is(err, tagging.ErrExpectedToFindResources) {
 			logger.Error("No tagged resources made it through filtering", "err", err)