From 86609d93477e33e351feb2a7210b98e46b82fe68 Mon Sep 17 00:00:00 2001
From: rasmus <rasmus@k-space.ee>
Date: Wed, 9 Nov 2022 16:40:16 +0200
Subject: [PATCH] verify mongo py compatability

---
 pkg/ctx_keys/ctx_keys.go         | 15 ---------------
 pkg/mongo_struct/mongo_struct.go |  9 +++------
 2 files changed, 3 insertions(+), 21 deletions(-)
 delete mode 100644 pkg/ctx_keys/ctx_keys.go

diff --git a/pkg/ctx_keys/ctx_keys.go b/pkg/ctx_keys/ctx_keys.go
deleted file mode 100644
index fb97d09..0000000
--- a/pkg/ctx_keys/ctx_keys.go
+++ /dev/null
@@ -1,15 +0,0 @@
-package ctx_keys
-
-// type Key uint32
-
-// // The operations fsnotify can trigger; see the documentation on [Watcher] for a
-// // full description, and check them with [Event.Has].
-// const (
-// 	PrometheusPrefix Key = 1 << iota
-// )
-
-// var keyMap = map[Key]reflect.Type{}
-
-// func get(ctx context.Context, key Key) (val any, ok bool) {
-// 	ctx.Value()
-// }
diff --git a/pkg/mongo_struct/mongo_struct.go b/pkg/mongo_struct/mongo_struct.go
index 2fef52d..8d5ecd6 100644
--- a/pkg/mongo_struct/mongo_struct.go
+++ b/pkg/mongo_struct/mongo_struct.go
@@ -93,10 +93,7 @@ const (
 	recordKeyNamespace  = "namespace"
 	recordKeyPod        = "pod"
 
-	recordKeyStream = "stderr"
-
-	recordKeyContainerTime = "container_time"
-	recordKeyShipTime      = "ship_time"
+	recordKeyStream = "stream"
 
 	recordKeyEvent          = "event"
 	recordKeyTimeUpstream   = "created"
@@ -139,11 +136,11 @@ func (l *Record) ToBson() bson.M {
 		},
 		recordKeyStream: stream,
 		recordKeyEvent: bson.M{
-			recordKeyTimeUpstream:   l.TimeUpstream,
+			// recordKeyTimeUpstream:   l.TimeUpstream, //TODO: ECS
 			recordKeyTimeKubernetes: l.TimeKubernetes,
 		},
 
-		recordKeyShipTime: time.Now(),
+		recordKeyTimeMower: time.Now(),
 	}
 }