clickhouse logger: set correct event timestamp

jitsucom · Feb 28, 2024 · 4288efb · 4288efb
1 parent 7862db2
commit 4288efb
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/bulkerapp/app/stream_consumer.go b/bulkerapp/app/stream_consumer.go
@@ -319,5 +319,5 @@ func (sc *StreamConsumerImpl) postEventsLog(message []byte, representation any,
 		object["status"] = "FAILED"
 		level = eventslog.LevelError
 	}
-	sc.eventsLogService.PostAsync(&eventslog.ActorEvent{eventslog.EventTypeProcessed, level, sc.destination.Id(), object})
+	sc.eventsLogService.PostAsync(&eventslog.ActorEvent{EventType: eventslog.EventTypeProcessed, Level: level, ActorId: sc.destination.Id(), Event: object})
 }
diff --git a/ingest/router_ingest_handler.go b/ingest/router_ingest_handler.go
@@ -45,7 +45,7 @@ func (r *Router) IngestHandler(c *gin.Context) {
 				obj["status"] = "SKIPPED"
 				obj["error"] = "no destinations found for stream"
 			}
-			r.eventsLogService.PostAsync(&eventslog.ActorEvent{eventslog.EventTypeIncoming, eventslog.LevelInfo, eventsLogId, obj})
+			r.eventsLogService.PostAsync(&eventslog.ActorEvent{EventType: eventslog.EventTypeIncoming, Level: eventslog.LevelInfo, ActorId: eventsLogId, Event: obj})
 			IngestHandlerRequests(domain, "success", "").Inc()
 		}
 	}()