Add verbose logs

Author: srikanthccv

exporter/clickhouselogsexporter/usage.go

@@ -48,6 +48,7 @@ var (
 )
 
 func UsageExporter(metrics []*metricdata.Metric, id uuid.UUID) (map[string]usage.Usage, error) {
+	fmt.Println("usage exporter called in clickhouse logsexporter")
 	data := map[string]usage.Usage{}
 	for _, metric := range metrics {
 		if !strings.Contains(metric.Descriptor.Name, SigNozLogsCount) && !strings.Contains(metric.Descriptor.Name, SigNozLogsBytes) {
@@ -56,6 +57,7 @@ func UsageExporter(metrics []*metricdata.Metric, id uuid.UUID) (map[string]usage
 		exporterIndex := usage.GetIndexOfLabel(metric.Descriptor.LabelKeys, usage.ExporterIDKey)
 		tenantIndex := usage.GetIndexOfLabel(metric.Descriptor.LabelKeys, usage.TenantKey)
 		if exporterIndex == -1 || tenantIndex == -1 {
+			fmt.Println("error in usage parser failed to get index of labels", metric.Descriptor.Name, metric.Descriptor.LabelKeys)
 			return nil, fmt.Errorf("usage: failed to get index of labels")
 		}
 
@@ -91,5 +93,8 @@ func UsageExporter(metrics []*metricdata.Metric, id uuid.UUID) (map[string]usage
 			}
 		}
 	}
+	for _, d := range data {
+		fmt.Println("data.count, data.size, data.timestamp", d.Count, d.Size, d.TimeStamp)
+	}
 	return data, nil
 }

usage/usage.go

@@ -73,6 +73,7 @@ func (e *UsageCollector) Start() error {
 }
 
 func (c *UsageCollector) Stop() error {
+	fmt.Println("stopping usage collector")
 	c.ir.Stop()
 	c.ir.Flush()
 	return nil
@@ -81,23 +82,27 @@ func (c *UsageCollector) Stop() error {
 func (e *UsageCollector) ExportMetrics(ctx context.Context, metrics []*metricdata.Metric) error {
 	usages, err := e.usageParser(metrics, e.exporterID)
 	if err != nil {
+		fmt.Println("error in usage parser", err)
 		return err
 	}
 	time := time.Now()
 	for tenant, usage := range usages {
 		usage.TimeStamp = time
 		usageBytes, err := json.Marshal(usage)
 		if err != nil {
+			fmt.Println("error in marshaling usage", err)
 			return err
 		}
 		encryptedData, err := Encrypt([]byte(e.exporterID.String())[:32], usageBytes)
 		if err != nil {
+			fmt.Println("error in encrypting usage", err)
 			return err
 		}
 
 		// insert everything as a new row
 		err = e.db.Exec(ctx, fmt.Sprintf("insert into %s.%s values ($1, $2, $3, $4, $5)", e.dbName, e.distributedTableName), tenant, CollectorID.String(), e.exporterID.String(), time, string(encryptedData))
 		if err != nil {
+			fmt.Println("error in inserting usage", err)
 			return err
 		}
 	}