Use adjusted 'UpsertStreamed' and 'DeleteStreamed' from icinga-go-lib…

…rary
Icinga · Nov 24, 2023 · 7333404 · 7333404
1 parent 771ef0a
commit 7333404
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/sync/logs.go b/pkg/sync/logs.go
@@ -143,7 +143,7 @@ func (ls *LogSync) MaintainList(ctx context.Context, addChannel <-chan contracts
 	})
 
 	g.Go(func() error {
-		return ls.db.DeleteStreamedByField(ctx, &schema.Log{}, "reference_id", deletes)
+		return ls.db.DeleteStreamed(ctx, &schema.Log{}, deletes, database.ByColumn("reference_id"))
 	})
 
 	return g.Wait()
@@ -224,7 +224,7 @@ func (ls *LogSync) Run(ctx context.Context) error {
 	})
 
 	g.Go(func() error {
-		return ls.db.UpsertStreamedWithStatement(ctx, upserts, upsertStmt, 5)
+		return ls.db.UpsertStreamed(ctx, upserts, database.WithStatement(upsertStmt, 5))
 	})
 
 	return g.Wait()