diff options
| author | Julie Qiu <julie@golang.org> | 2019-02-27 23:51:51 -0500 |
|---|---|---|
| committer | Julie Qiu <julie@golang.org> | 2020-03-27 16:46:33 -0400 |
| commit | cfb8fdf20bec34c32d3bf48706da01568406a0f8 (patch) | |
| tree | 7e5dc9fd93aab9785e2e65b000dbd1f51d816ecb /internal/postgres/postgres.go | |
| parent | 8f815ef30afbbfda2a9427770d8aa639f243e857 (diff) | |
| download | go-x-pkgsite-cfb8fdf20bec34c32d3bf48706da01568406a0f8.tar.xz | |
internal/cron: create proxy index cron
The proxy index cron is created, with a job to get new versions from the
module index. The cron will:
1. query the module index for new versions since a given timestamp
2. write each version to the version_logs table
3. make a request to the fetch service for each version to be
downloaded
The fetch client is also fixed to make a GET request to
https://<fetch-url>/<module>/@v/<version>.
Change-Id: I838029d94f9b2782e0c1066ec7932931b47fe01e
Reviewed-on: https://team-review.git.corp.google.com/c/golang/discovery/+/426749
Reviewed-by: Andrew Bonventre <andybons@google.com>
Diffstat (limited to 'internal/postgres/postgres.go')
| -rw-r--r-- | internal/postgres/postgres.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/postgres/postgres.go b/internal/postgres/postgres.go index c6a1b530..85d75201 100644 --- a/internal/postgres/postgres.go +++ b/internal/postgres/postgres.go @@ -62,7 +62,7 @@ func (db *DB) LatestProxyIndexUpdate() (time.Time, error) { LIMIT 1` var createdAt time.Time - row := db.QueryRow(query, internal.VersionLogProxyIndex) + row := db.QueryRow(query, internal.VersionSourceProxyIndex) switch err := row.Scan(&createdAt); err { case sql.ErrNoRows: return time.Time{}, nil @@ -81,7 +81,7 @@ func (db *DB) InsertVersionLogs(logs []*internal.VersionLog) error { for _, l := range logs { if _, err := tx.Exec( `INSERT INTO version_logs(name, version, created_at, source, error) - VALUES ($1, $2, $3, $4, $5);`, + VALUES ($1, $2, $3, $4, $5) ON CONFLICT DO NOTHING;`, l.Name, l.Version, l.CreatedAt, l.Source, l.Error, ); err != nil { return err |