Method EncodedObject

pkg/cache/redis/object.go:57–88

EncodedObject retrieves an encoded object from Redis by its hash.

(t plumbing.ObjectType, h plumbing.Hash)

// EncodedObject retrieves an encoded object from Redis by its hash.
func (s *ObjectStorage) EncodedObject(t plumbing.ObjectType, h plumbing.Hash) (plumbing.EncodedObject, error) {
	// if the object type is AnyObject, we need to try and get the object for each type until we find it.
	if t == plumbing.AnyObject {
		for _, ot := range []plumbing.ObjectType{plumbing.CommitObject, plumbing.TreeObject, plumbing.BlobObject, plumbing.TagObject, plumbing.OFSDeltaObject, plumbing.REFDeltaObject} {
			obj, err := s.EncodedObject(ot, h)
			if err == nil {
				return obj, nil
			}
		}
		return nil, plumbing.ErrObjectNotFound
	}

	// Get object data by hash as key with prefix "object:", type and hash.
	key := fmt.Sprintf("%s:%s", t, h)
	data, err := s.client.Get(ctx, withNamespace(s.namespacePrefix, objectPrefix, key)).Bytes()
	if err != nil {
		if err == redis.Nil {
			return nil, plumbing.ErrObjectNotFound
		}
		return nil, err
	}

	o := &plumbing.MemoryObject{}
	o.SetType(t)
	o.SetSize(int64(len(data)))
	_, err = o.Write(data)
	if err != nil {
		return nil, err
	}

	return o, nil
}

// EncodedObjectSize implements storage.Storer.
func (s *Storage) EncodedObjectSize(h plumbing.Hash) (int64, error) {