Method ForEach

pkg/cache/redis/reference.go:205–224

(cb func(obj *plumbing.Reference) error)

}

func (iter *ReferenceIter) ForEach(cb func(obj *plumbing.Reference) error) error {
	for {
		obj, err := iter.Next()
		if err != nil {
			if err == io.EOF {
				return nil
			}

			return err
		}

		if err := cb(obj); err != nil {
			if err == storer.ErrStop {
				return nil
			}

			return err
		}
	}
}

// Close is a placeholder to satisfy the ReferenceIter interface.
// Redis connections are managed outside the iterator, so there's nothing to close here.