Method fetchNextBatch

pkg/cache/redis/reference.go:167–178

fetchNextBatch fetches the next batch of keys from Redis matching the pattern "ref:*".

()

// fetchNextBatch fetches the next batch of keys from Redis matching the pattern "ref:*".
func (iter *ReferenceIter) fetchNextBatch() {
	if iter.moreData {
		var err error
		iter.keys, iter.cursor, err = iter.client.Scan(ctx, iter.cursor, withNamespace(iter.namespacePrefix, referencePrefix, "*"), 100).Result()
		if err != nil {
			iter.moreData = false // In case of error, stop further fetching
			return
		}
		// Update moreData based on whether the cursor returned to 0
		iter.moreData = (iter.cursor != 0)
	}
}

// Next retrieves the next reference, advancing the iterator.
func (iter *ReferenceIter) Next() (*plumbing.Reference, error) {