JakeHillion/storj
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

satellite/metabase: make name clearer in iterator

Browse Source 
Change-Id: I49f1539f23aa6fa05a02467e4cfa166cbf4e8968
This commit is contained in:
Egon Elbre 2023-10-16 17:44:33 +03:00 committed by Storj Robot
parent 0c7ad88857
commit 1891f6501d
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
satellite/metabase/iterator.go
View File

@ -106,7 +106,7 @@ func iteratePendingObjectsByKey(ctx context.Context, db *DB, opts IteratePending
Version: 0,
StreamID: opts.Cursor.StreamID,
},
doNextQuery: doNextQueryStreamsByKey,
doNextQuery: doNextQueryPendingObjectsByKey,
}
return iterate(ctx, it, fn)
@ -312,7 +312,7 @@ func nextBucket(b []byte) []byte {
}
// doNextQuery executes query to fetch the next batch returning the rows.
func doNextQueryStreamsByKey(ctx context.Context, it *objectsIterator) (_ tagsql.Rows, err error) {
func doNextQueryPendingObjectsByKey(ctx context.Context, it *objectsIterator) (_ tagsql.Rows, err error) {
defer mon.Task()(&ctx)(&err)
return it.db.db.QueryContext(ctx, `
@ -324,8 +324,7 @@ func doNextQueryStreamsByKey(ctx context.Context, it *objectsIterator) (_ tagsql
encrypted_metadata_nonce, encrypted_metadata, encrypted_metadata_encrypted_key
FROM objects
WHERE
project_id = $1 AND bucket_name = $2
AND object_key = $3
(project_id, bucket_name, object_key) = ($1, $2, $3)
AND stream_id > $4::BYTEA
AND status = `+statusPending+`
ORDER BY stream_id ASC