chore: Modify variable name format

Author: YikaiHu

dth/job.go

@@ -157,7 +157,7 @@ func (f *Finder) Run(ctx context.Context) {
 		prefixes = f.srcClient.ListCommonPrefixes(ctx, f.cfg.FinderDepth, f.cfg.MaxKeys)
 	}
 	var wg sync.WaitGroup
-	var total_obj_count int64 = 0
+	var totalObjCount int64 = 0
 
 	start := time.Now()
 
@@ -166,9 +166,9 @@ func (f *Finder) Run(ctx context.Context) {
 		log.Printf("prefix: %s", *p)
 		wg.Add(1)
 		if f.cfg.SkipCompare {
-			go f.directSend(ctx, p, batchCh, msgCh, compareCh, &wg, &total_obj_count)
+			go f.directSend(ctx, p, batchCh, msgCh, compareCh, &wg, &totalObjCount)
 		} else {
-			go f.compareAndSend(ctx, p, batchCh, msgCh, compareCh, &wg, &total_obj_count)
+			go f.compareAndSend(ctx, p, batchCh, msgCh, compareCh, &wg, &totalObjCount)
 		}
 	}
 	wg.Wait()
@@ -178,7 +178,7 @@ func (f *Finder) Run(ctx context.Context) {
 	close(compareCh)
 
 	end := time.Since(start)
-	log.Printf("Finder Job Completed in %v, found %d objects in total\n", end, total_obj_count)
+	log.Printf("Finder Job Completed in %v, found %d objects in total\n", end, totalObjCount)
 }
 
 // List objects in destination bucket, load the full list into a map
@@ -216,15 +216,15 @@ func (f *Finder) getTargetObjects(ctx context.Context, prefix *string) (objects
 
 // This function will compare source and target and get a list of delta,
 // and then send delta to SQS Queue.
-func (f *Finder) compareAndSend(ctx context.Context, prefix *string, batchCh chan struct{}, msgCh chan *string, compareCh chan struct{}, wg *sync.WaitGroup, total_obj_count *int64) {
+func (f *Finder) compareAndSend(ctx context.Context, prefix *string, batchCh chan struct{}, msgCh chan *string, compareCh chan struct{}, wg *sync.WaitGroup, totalObjCount *int64) {
 	defer wg.Done()
 
 	log.Printf("Comparing within prefix /%s\n", *prefix)
 	target := f.getTargetObjects(ctx, prefix)
 
 	token := ""
 	i, j := 0, 0
-	var obj_count int64 = 0
+	var objCount int64 = 0
 	retry := 0
 	// batch := make([]*string, f.cfg.MessageBatchSize)
 
@@ -264,7 +264,7 @@ func (f *Finder) compareAndSend(ctx context.Context, prefix *string, batchCh cha
 				i++
 				if i%f.cfg.MessageBatchSize == 0 {
 					wg.Add(1)
-					obj_count += int64(f.cfg.MessageBatchSize)
+					objCount += int64(f.cfg.MessageBatchSize)
 					j++
 					if j%100 == 0 {
 						log.Printf("Found %d batches in prefix /%s\n", j, *prefix)
@@ -290,7 +290,7 @@ func (f *Finder) compareAndSend(ctx context.Context, prefix *string, batchCh cha
 	// For remainning objects.
 	if i != 0 {
 		j++
-		obj_count += int64(i)
+		objCount += int64(i)
 		wg.Add(1)
 		batchCh <- struct{}{}
 		go func(i int) {
@@ -304,23 +304,23 @@ func (f *Finder) compareAndSend(ctx context.Context, prefix *string, batchCh cha
 			<-batchCh
 		}(i)
 	}
-	atomic.AddInt64(total_obj_count, obj_count)
+	atomic.AddInt64(totalObjCount, objCount)
 
 	// end := time.Since(start)
 	// log.Printf("Compared and Sent %d batches in %v", j, end)
-	log.Printf("Completed in prefix /%s, found %d batches (%d objects) in total", *prefix, j, obj_count)
+	log.Printf("Completed in prefix /%s, found %d batches (%d objects) in total", *prefix, j, objCount)
 	<-compareCh
 }
 
 // This function will send the task to SQS Queue directly, without comparison.
-func (f *Finder) directSend(ctx context.Context, prefix *string, batchCh chan struct{}, msgCh chan *string, compareCh chan struct{}, wg *sync.WaitGroup, total_obj_count *int64) {
+func (f *Finder) directSend(ctx context.Context, prefix *string, batchCh chan struct{}, msgCh chan *string, compareCh chan struct{}, wg *sync.WaitGroup, totalObjCount *int64) {
 	defer wg.Done()
 
 	log.Printf("Scanning prefix /%s\n", *prefix)
 
 	token := ""
 	i, j := 0, 0
-	var obj_count int64 = 0
+	var objCount int64 = 0
 	retry := 0
 	// batch := make([]*string, f.cfg.MessageBatchSize)
 
@@ -357,7 +357,7 @@ func (f *Finder) directSend(ctx context.Context, prefix *string, batchCh chan st
 			i++
 			if i%f.cfg.MessageBatchSize == 0 {
 				wg.Add(1)
-				obj_count += int64(f.cfg.MessageBatchSize)
+				objCount += int64(f.cfg.MessageBatchSize)
 				j++
 				if j%100 == 0 {
 					log.Printf("Found %d batches in prefix /%s\n", j, *prefix)
@@ -382,7 +382,7 @@ func (f *Finder) directSend(ctx context.Context, prefix *string, batchCh chan st
 	// For remainning objects.
 	if i != 0 {
 		j++
-		obj_count += int64(i)
+		objCount += int64(i)
 		wg.Add(1)
 		batchCh <- struct{}{}
 		go func(i int) {
@@ -396,11 +396,11 @@ func (f *Finder) directSend(ctx context.Context, prefix *string, batchCh chan st
 			<-batchCh
 		}(i)
 	}
-	atomic.AddInt64(total_obj_count, obj_count)
+	atomic.AddInt64(totalObjCount, objCount)
 
 	// end := time.Since(start)
 	// log.Printf("Compared and Sent %d batches in %v", j, end)
-	log.Printf("Completed in prefix /%s, found %d batches (%d objects) in total", *prefix, j, obj_count)
+	log.Printf("Completed in prefix /%s, found %d batches (%d objects) in total", *prefix, j, objCount)
 	<-compareCh
 }