Method Next

pkg/cache/redis/reference.go:181–203

Next retrieves the next reference, advancing the iterator.

()

// Next retrieves the next reference, advancing the iterator.
func (iter *ReferenceIter) Next() (*plumbing.Reference, error) {
	if len(iter.keys) == 0 && iter.moreData {
		iter.fetchNextBatch()
	}
	if len(iter.keys) > 0 {
		// Assume key to be the key itself and value to be something sensible
		key := iter.keys[0]
		iter.keys = iter.keys[1:]

		data, err := iter.client.Get(ctx, key).Bytes()
		if err != nil {
			return nil, err
		}

		ref, err := jsonToReference(data)
		if err != nil {
			return nil, err
		}

		return ref, nil
	}
	return nil, io.EOF
}

func (iter *ReferenceIter) ForEach(cb func(obj *plumbing.Reference) error) error {
	for {