Merge pull request #194 from intelops/data

Client changes
intelops · Sep 2, 2023 · 2895d81 · 2895d81
2 parents 6e742c8 + d24f9fd
commit 2895d81
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/client/pkg/clickhouse/db_client.go b/client/pkg/clickhouse/db_client.go
@@ -258,6 +258,9 @@ func (c *DBClient) InsertKubvizEvent(metrics model.Metrics) {
 	)
 	defer stmt.Close()
 	eventJson, _ := json.Marshal(metrics.Event)
+	formattedFirstTimestamp := metrics.Event.FirstTimestamp.Time.UTC().Format("2006-01-02 15:04:05")
+	formattedLastTimestamp := metrics.Event.LastTimestamp.Time.UTC().Format("2006-01-02 15:04:05")
+
 	if _, err := stmt.Exec(
 		metrics.ClusterName,
 		string(metrics.Event.UID),
@@ -270,8 +273,8 @@ func (c *DBClient) InsertKubvizEvent(metrics model.Metrics) {
 		metrics.Event.Reason,
 		metrics.Event.Source.Host,
 		string(eventJson),
-		metrics.Event.FirstTimestamp.Time.UTC(),
-		metrics.Event.LastTimestamp.Time.UTC(),
+		formattedFirstTimestamp,
+		formattedLastTimestamp,
 	); err != nil {
 		log.Fatal(err)
 	}

diff --git a/client/pkg/clickhouse/statements.go b/client/pkg/clickhouse/statements.go
@@ -15,8 +15,8 @@ const kubvizTable DBStatement = `
 		Reason       String,
 		Host         String,
 		Event        String,
-		FirstTime   DateTime('UTC'),
-		LastTime    DateTime('UTC')
+		FirstTime   String,
+		LastTime    String
 	) engine=File(TabSeparated)
 `
 const rakeesTable DBStatement = `