Method fetchNextBatch

pkg/cache/redis/object.go:160–172

fetchNextBatch fetches the next batch of keys from Redis matching the object type pattern.

()

// fetchNextBatch fetches the next batch of keys from Redis matching the object type pattern.
func (iter *EncodedObjectIter) fetchNextBatch() {
	if iter.moreData {
		pattern := withNamespace(iter.namespacePrefix, objectPrefix, fmt.Sprintf("%s:*", iter.t))
		var err error
		iter.keys, iter.cursor, err = iter.client.Scan(ctx, iter.cursor, pattern, 100).Result()
		if err != nil {
			iter.moreData = false // Stop further fetches on error
			return
		}
		// Update moreData based on whether the cursor returned to 0
		iter.moreData = (iter.cursor != 0)
	}
}

// Next moves the iterator to the next object and returns it.
func (iter *EncodedObjectIter) Next() (plumbing.EncodedObject, error) {