From 4288efbbd690d25567d12cddf10a91722c22f47f Mon Sep 17 00:00:00 2001 From: Ildar Nurislamov Date: Wed, 28 Feb 2024 18:32:50 +0400 Subject: [PATCH] clickhouse logger: set correct event timestamp --- bulkerapp/app/stream_consumer.go | 2 +- ingest/router_ingest_handler.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/bulkerapp/app/stream_consumer.go b/bulkerapp/app/stream_consumer.go index dc60f77..6473f25 100644 --- 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 index 81cbb2d..c320c1c 100644 --- 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() } }()