Remove DB interface

Remove the DB interface, as there will only be one implementation for it
elastic · Jan 17, 2024 · c9cf706 · c9cf706
1 parent f35b4c7
commit c9cf706
Show file tree

Hide file tree

Showing 5 changed files with 689 additions and 711 deletions.
diff --git a/x-pack/auditbeat/processors/add_session_metadata/add_session_metadata.go b/x-pack/auditbeat/processors/add_session_metadata/add_session_metadata.go
@@ -50,7 +50,7 @@ func New(cfg *config.C) (beat.Processor, error) {
 
 	ctx := context.TODO()
 	reader := procfs.NewProcfsReader(*logger)
-	db := processdb.NewSimpleDB(reader, *logger)
+	db := processdb.NewDB(reader, *logger)
 
 	backfilledPIDs := db.ScrapeProcfs()
 	logger.Debugf("backfilled %d processes", len(backfilledPIDs))

diff --git a/x-pack/auditbeat/processors/add_session_metadata/add_session_metadata_test.go b/x-pack/auditbeat/processors/add_session_metadata/add_session_metadata_test.go
@@ -156,7 +156,7 @@ var (
 func TestEnrich(t *testing.T) {
 	for _, tt := range enrichTests {
 		reader := procfs.NewMockReader()
-		db := processdb.NewSimpleDB(reader, *logger)
+		db := processdb.NewDB(reader, *logger)
 
 		for _, ev := range tt.mockProcesses {
 			err := db.InsertExec(ev)