minor changes in clickhouse

mosajjal · Jan 28, 2023 · 6ba1a24 · 6ba1a24
1 parent f3bff1e
commit 6ba1a24
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 5 deletions.
diff --git a/.gitignore b/.gitignore
@@ -25,3 +25,4 @@ docker-compose.yml
 .TODO.md
 
 dist/
+cmd/dnsmonster/dnsmonster
diff --git a/cmd/dnsmonster/dnsmonster b/cmd/dnsmonster/dnsmonster
diff --git a/internal/output/clickhouse.go b/internal/output/clickhouse.go
@@ -157,8 +157,6 @@ func (chConfig clickhouseConfig) clickhouseOutputWorker(ctx context.Context) err
 
 	c := uint(0)
 
-	now := time.Now()
-
 	ticker := time.NewTicker(time.Second * 5)
 	div := 0
 
@@ -199,7 +197,7 @@ func (chConfig clickhouseConfig) clickhouseOutputWorker(ctx context.Context) err
 				}
 				err := batch.Append(
 					data.Timestamp,
-					now,
+					time.Now(),
 					util.GeneralFlags.ServerName,
 					data.IPVersion,
 					data.SrcIP.To16(),
@@ -221,7 +219,6 @@ func (chConfig clickhouseConfig) clickhouseOutputWorker(ctx context.Context) err
 					clickhouseFailed.Inc(1)
 				}
 				if int(c%chConfig.ClickhouseBatchSize) == div {
-					now = time.Now()
 					err = batch.Send()
 					if err != nil {
 						log.Warnf("Error while executing batch: %v", err)
@@ -232,7 +229,6 @@ func (chConfig clickhouseConfig) clickhouseOutputWorker(ctx context.Context) err
 				}
 			}
 		case <-ticker.C:
-			now = time.Now()
 			err := batch.Send()
 			if err != nil {
 				log.Warnf("Error while executing batch: %v", err)
Original file line number	Diff line number	Diff line change
Expand Up		@@ -25,3 +25,4 @@ docker-compose.yml
		.TODO.md

		dist/
		cmd/dnsmonster/dnsmonster