Adding occurred_at

Signed-off-by: rodneyosodo <blackd0t@protonmail.com>
absmach · Jul 11, 2023 · 32d0120 · 32d0120
1 parent a76220c
commit 32d0120
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/clients/redis/producer.go b/internal/clients/redis/producer.go
@@ -55,6 +55,8 @@ func (es *eventStore) Publish(ctx context.Context, event Event) error {
 	if err != nil {
 		return err
 	}
+	values["occurred_at"] = time.Now().UnixNano()
+
 	record := &redis.XAddArgs{
 		Stream:       es.streamID,
 		MaxLenApprox: es.streamLen,