debug write to questdb

e1769f5f · Your Name · e48d7d0e · e1769f5f
Commit e1769f5f authored Feb 22, 2024 by Your Name
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

main.go main.go +4 -0

No files found.
--- a/main.go
+++ b/main.go
@@ -223,6 +223,8 @@ func batchToQuestDb(done chan interface{}, reqStream chan pbUpstream.TaskContent
 			nanoseconds := int64(task.TaskTimestamp)
 			seconds := nanoseconds / 1e9

+			fmt.Println("questdb <- resStream", "task.TaskId", task.TaskId, "task.TaskUid", task.TaskUid)
+
 			sender.Table(resTableName).
 				Symbol("type", fmt.Sprintf("%d", task.TaskType)).
 				Symbol("uid", task.TaskUid).
@@ -263,6 +265,8 @@ func batchToQuestDb(done chan interface{}, reqStream chan pbUpstream.TaskContent
 				continue
 			}

+			fmt.Println("questdb <- reqStream", "task.TaskId", task.TaskId, "task.TaskUid", task.TaskUid)
+
 			nanoseconds := int64(task.TaskTimestamp)
 			seconds := nanoseconds / 1e9