aboutsummaryrefslogtreecommitdiff
path: root/internal/postgres/versionstate.go
diff options
context:
space:
mode:
authorJonathan Amsterdam <jba@google.com>2020-06-01 15:32:59 -0400
committerJonathan Amsterdam <jba@google.com>2020-06-02 15:12:19 +0000
commite66341ffa9aaedd9fee511576e2e501738faa281 (patch)
tree081bf2bea81e7118e164dafd3787ad638658153e /internal/postgres/versionstate.go
parent7557ba489297ee225fc0cad232619d21fbc93f83 (diff)
downloadgo-x-pkgsite-e66341ffa9aaedd9fee511576e2e501738faa281.tar.xz
internal/database: Transact supports any isolation level
- Add an arg to Transact for the isolation level - Remove TransactSerializable This makes it possible to use other levels, and makes it easier to see which level is being used for each transaction. Change-Id: Iba5e2920b4139e5e2f0f8c6b331a658d7c84f60f Reviewed-on: https://team-review.git.corp.google.com/c/golang/discovery/+/758942 CI-Result: Cloud Build <devtools-proctor-result-processor@system.gserviceaccount.com> Reviewed-by: Julie Qiu <julieqiu@google.com>
Diffstat (limited to 'internal/postgres/versionstate.go')
-rw-r--r--internal/postgres/versionstate.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/postgres/versionstate.go b/internal/postgres/versionstate.go
index 22a38e13..f2bfc99d 100644
--- a/internal/postgres/versionstate.go
+++ b/internal/postgres/versionstate.go
@@ -36,7 +36,7 @@ func (db *DB) InsertIndexVersions(ctx context.Context, versions []*internal.Inde
DO UPDATE SET
index_timestamp=excluded.index_timestamp,
next_processed_after=CURRENT_TIMESTAMP`
- return db.db.Transact(ctx, func(tx *database.DB) error {
+ return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
return tx.BulkInsert(ctx, "module_version_states", cols, vals, conflictAction)
})
}
@@ -57,7 +57,7 @@ func (db *DB) UpsertModuleVersionState(ctx context.Context, modulePath, vers, ap
numPackages = &n
}
- return db.db.Transact(ctx, func(tx *database.DB) error {
+ return db.db.Transact(ctx, sql.LevelDefault, func(tx *database.DB) error {
if err := upsertModuleVersionState(ctx, tx, modulePath, vers, appVersion, numPackages, timestamp, status, goModPath, fetchErr); err != nil {
return err
}