internal/worker: add timings to FetchAndUpdateState

fetchTask.timings is added to time FetchModule and each DB insert.  The
results are logged as a single log line, which will be exported to
BigQuery for analysis as needed.

postgres.DeleteModule is rewritten to db.DeleteModule, for consistency
with other exported functions from internal/postgres.

Change-Id: Id6ecd7fccd238fb17a45554ec033ebf404c1020c
Reviewed-on: https://team-review.git.corp.google.com/c/golang/discovery/+/729940
Reviewed-by: Jonathan Amsterdam <jba@google.com>

1 files changed, 2 insertions, 2 deletions

diff --git a/internal/postgres/insert_module.go b/internal/postgres/insert_module.go
index 81213032..796b24c5 100644
--- a/internal/postgres/insert_module.go
+++ b/internal/postgres/insert_module.go
@@ -637,12 +637,12 @@ func removeNonDistributableData(m *internal.Module) {
 }
 
 // DeleteModule deletes a Version from the database.
-func DeleteModule(ctx context.Context, db *database.DB, modulePath, version string) (err error) {
+func (db *DB) DeleteModule(ctx context.Context, modulePath, version string) (err error) {
 	defer derrors.Wrap(&err, "DeleteModule(ctx, db, %q, %q)", modulePath, version)
 	// We only need to delete from the modules table. Thanks to ON DELETE
 	// CASCADE constraints, that will trigger deletions from all other tables.
 	const stmt = `DELETE FROM modules WHERE module_path=$1 AND version=$2`
-	_, err = db.Exec(ctx, stmt, modulePath, version)
+	_, err = db.db.Exec(ctx, stmt, modulePath, version)
 	return err
 }