Merge branch 'pks-list-all-blobs' into 'master'

Implement new ListAllBlobs RPC

Closes #3716

See merge request gitlab-org/gitaly!3703

7 files changed, 798 insertions, 183 deletions

diff --git a/internal/gitaly/service/blob/blobs.go b/internal/gitaly/service/blob/blobs.go
index 9f18fc7ff..9acb4cd8c 100644
--- a/internal/gitaly/service/blob/blobs.go
+++ b/internal/gitaly/service/blob/blobs.go
@@ -1,6 +1,7 @@
 package blob
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"io"
@@ -9,6 +10,7 @@ import (
 
 	"github.com/golang/protobuf/proto"
 	"gitlab.com/gitlab-org/gitaly/v14/internal/git"
+	"gitlab.com/gitlab-org/gitaly/v14/internal/git/catfile"
 	"gitlab.com/gitlab-org/gitaly/v14/internal/git/gitpipe"
 	"gitlab.com/gitlab-org/gitaly/v14/internal/helper"
 	"gitlab.com/gitlab-org/gitaly/v14/internal/helper/chunk"
@@ -73,22 +75,46 @@ func (s *server) ListBlobs(req *gitalypb.ListBlobsRequest, stream gitalypb.BlobS
 		return r.ObjectInfo.Type == "blob"
 	})
 
+	if err := processBlobs(ctx, catfileProcess, catfileInfoIter, req.GetLimit(), req.GetBytesLimit(),
+		func(oid string, size int64, contents []byte) error {
+			return chunker.Send(&gitalypb.ListBlobsResponse_Blob{
+				Oid:  oid,
+				Size: size,
+				Data: contents,
+			})
+		},
+	); err != nil {
+		return helper.ErrInternal(fmt.Errorf("processing blobs: %w", err))
+	}
+
+	if err := chunker.Flush(); err != nil {
+		return helper.ErrInternal(err)
+	}
+
+	return nil
+}
+
+func processBlobs(
+	ctx context.Context,
+	catfileProcess catfile.Batch,
+	catfileInfoIter gitpipe.CatfileInfoIterator,
+	blobsLimit uint32,
+	bytesLimit int64,
+	callback func(oid string, size int64, contents []byte) error,
+) error {
 	// If we have a zero bytes limit, then the caller didn't request any blob contents at all.
 	// We can thus skip reading blob contents completely.
-	if req.GetBytesLimit() == 0 {
+	if bytesLimit == 0 {
 		var i uint32
 		for catfileInfoIter.Next() {
 			blob := catfileInfoIter.Result()
 
-			if err := chunker.Send(&gitalypb.ListBlobsResponse_Blob{
-				Oid:  blob.ObjectInfo.Oid.String(),
-				Size: blob.ObjectInfo.Size,
-			}); err != nil {
+			if err := callback(blob.ObjectInfo.Oid.String(), blob.ObjectInfo.Size, nil); err != nil {
 				return helper.ErrInternal(fmt.Errorf("sending blob chunk: %w", err))
 			}
 
 			i++
-			if req.GetLimit() > 0 && i >= req.GetLimit() {
+			if blobsLimit > 0 && i >= blobsLimit {
 				break
 			}
 		}
@@ -105,24 +131,23 @@ func (s *server) ListBlobs(req *gitalypb.ListBlobsRequest, stream gitalypb.BlobS
 
 			headerSent := false
 			dataChunker := streamio.NewWriter(func(p []byte) error {
-				message := &gitalypb.ListBlobsResponse_Blob{
-					Data: p,
-				}
+				var oid string
+				var size int64
 
 				if !headerSent {
-					message.Oid = blob.ObjectInfo.Oid.String()
-					message.Size = blob.ObjectInfo.Size
+					oid = blob.ObjectInfo.Oid.String()
+					size = blob.ObjectInfo.Size
 					headerSent = true
 				}
 
-				if err := chunker.Send(message); err != nil {
+				if err := callback(oid, size, p); err != nil {
 					return helper.ErrInternal(fmt.Errorf("sending blob chunk: %w", err))
 				}
 
 				return nil
 			})
 
-			readLimit := req.GetBytesLimit()
+			readLimit := bytesLimit
 			if readLimit < 0 {
 				readLimit = blob.ObjectInfo.Size
 			}
@@ -143,16 +168,13 @@ func (s *server) ListBlobs(req *gitalypb.ListBlobsRequest, stream gitalypb.BlobS
 			// itself didn't contain any data. Let's be prepared and send out the blob
 			// header manually in that case.
 			if !headerSent {
-				if err := chunker.Send(&gitalypb.ListBlobsResponse_Blob{
-					Oid:  blob.ObjectInfo.Oid.String(),
-					Size: blob.ObjectInfo.Size,
-				}); err != nil {
+				if err := callback(blob.ObjectInfo.Oid.String(), blob.ObjectInfo.Size, nil); err != nil {
 					return helper.ErrInternal(fmt.Errorf("sending blob chunk: %w", err))
 				}
 			}
 
 			i++
-			if req.GetLimit() > 0 && i >= req.GetLimit() {
+			if blobsLimit > 0 && i >= blobsLimit {
 				break
 			}
 		}
@@ -162,10 +184,6 @@ func (s *server) ListBlobs(req *gitalypb.ListBlobsRequest, stream gitalypb.BlobS
 		}
 	}
 
-	if err := chunker.Flush(); err != nil {
-		return helper.ErrInternal(err)
-	}
-
 	return nil
 }
 
@@ -185,3 +203,68 @@ func (t *blobSender) Append(m proto.Message) {
 func (t *blobSender) Send() error {
 	return t.send(t.blobs)
 }
+
+// ListAllBlobs finds all blobs which exist in the repository, including those which are not
+// reachable via graph walks.
+func (s *server) ListAllBlobs(req *gitalypb.ListAllBlobsRequest, stream gitalypb.BlobService_ListAllBlobsServer) error {
+	ctx := stream.Context()
+
+	if req.GetRepository() == nil {
+		return helper.ErrInvalidArgumentf("empty repository")
+	}
+
+	repo := s.localrepo(req.GetRepository())
+
+	chunker := chunk.New(&allBlobsSender{
+		send: func(blobs []*gitalypb.ListAllBlobsResponse_Blob) error {
+			return stream.Send(&gitalypb.ListAllBlobsResponse{
+				Blobs: blobs,
+			})
+		},
+	})
+
+	catfileProcess, err := s.catfileCache.BatchProcess(ctx, repo)
+	if err != nil {
+		return helper.ErrInternal(fmt.Errorf("creating catfile process: %w", err))
+	}
+
+	catfileInfoIter := gitpipe.CatfileInfoAllObjects(ctx, repo)
+	catfileInfoIter = gitpipe.CatfileInfoFilter(ctx, catfileInfoIter, func(r gitpipe.CatfileInfoResult) bool {
+		return r.ObjectInfo.Type == "blob"
+	})
+
+	if err := processBlobs(ctx, catfileProcess, catfileInfoIter, req.GetLimit(), req.GetBytesLimit(),
+		func(oid string, size int64, contents []byte) error {
+			return chunker.Send(&gitalypb.ListAllBlobsResponse_Blob{
+				Oid:  oid,
+				Size: size,
+				Data: contents,
+			})
+		},
+	); err != nil {
+		return helper.ErrInternal(fmt.Errorf("processing blobs: %w", err))
+	}
+
+	if err := chunker.Flush(); err != nil {
+		return helper.ErrInternal(fmt.Errorf("flushing blobs: %w", err))
+	}
+
+	return nil
+}
+
+type allBlobsSender struct {
+	blobs []*gitalypb.ListAllBlobsResponse_Blob
+	send  func([]*gitalypb.ListAllBlobsResponse_Blob) error
+}
+
+func (t *allBlobsSender) Reset() {
+	t.blobs = t.blobs[:0]
+}
+
+func (t *allBlobsSender) Append(m proto.Message) {
+	t.blobs = append(t.blobs, m.(*gitalypb.ListAllBlobsResponse_Blob))
+}
+
+func (t *allBlobsSender) Send() error {
+	return t.send(t.blobs)
+}
diff --git a/internal/gitaly/service/blob/blobs_test.go b/internal/gitaly/service/blob/blobs_test.go
index d92a9fc21..4afa10b1b 100644
--- a/internal/gitaly/service/blob/blobs_test.go
+++ b/internal/gitaly/service/blob/blobs_test.go
@@ -8,12 +8,15 @@ import (
 
 	"github.com/stretchr/testify/require"
 	"gitlab.com/gitlab-org/gitaly/v14/internal/git/gittest"
+	"gitlab.com/gitlab-org/gitaly/v14/internal/git/quarantine"
+	"gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/config"
 	"gitlab.com/gitlab-org/gitaly/v14/internal/testhelper"
 	"gitlab.com/gitlab-org/gitaly/v14/internal/testhelper/testassert"
 	"gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"
 	"gitlab.com/gitlab-org/gitaly/v14/streamio"
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/status"
+	"google.golang.org/protobuf/proto"
 )
 
 const (
@@ -242,3 +245,143 @@ func TestListBlobs(t *testing.T) {
 		})
 	}
 }
+
+func TestListAllBlobs(t *testing.T) {
+	cfg, repo, _, client := setup(t)
+
+	ctx, cancel := testhelper.Context()
+	defer cancel()
+
+	quarantine, err := quarantine.New(ctx, repo, config.NewLocator(cfg))
+	require.NoError(t, err)
+
+	quarantineRepoWithoutAlternates := proto.Clone(quarantine.QuarantinedRepo()).(*gitalypb.Repository)
+	quarantineRepoWithoutAlternates.GitAlternateObjectDirectories = []string{}
+
+	emptyRepo, _, cleanup := gittest.InitBareRepoAt(t, cfg, cfg.Storages[0])
+	defer cleanup()
+
+	singleBlobRepo, singleBlobRepoPath, cleanup := gittest.InitBareRepoAt(t, cfg, cfg.Storages[0])
+	defer cleanup()
+	blobID := gittest.WriteBlob(t, cfg, singleBlobRepoPath, []byte("foobar"))
+
+	for _, tc := range []struct {
+		desc    string
+		request *gitalypb.ListAllBlobsRequest
+		verify  func(*testing.T, []*gitalypb.ListAllBlobsResponse_Blob)
+	}{
+		{
+			desc: "empty repo",
+			request: &gitalypb.ListAllBlobsRequest{
+				Repository: emptyRepo,
+			},
+			verify: func(t *testing.T, blobs []*gitalypb.ListAllBlobsResponse_Blob) {
+				require.Empty(t, blobs)
+			},
+		},
+		{
+			desc: "repo with single blob",
+			request: &gitalypb.ListAllBlobsRequest{
+				Repository: singleBlobRepo,
+				BytesLimit: -1,
+			},
+			verify: func(t *testing.T, blobs []*gitalypb.ListAllBlobsResponse_Blob) {
+				require.Equal(t, []*gitalypb.ListAllBlobsResponse_Blob{{
+					Oid:  blobID.String(),
+					Size: 6,
+					Data: []byte("foobar"),
+				}}, blobs)
+			},
+		},
+		{
+			desc: "repo with single blob and bytes limit",
+			request: &gitalypb.ListAllBlobsRequest{
+				Repository: singleBlobRepo,
+				BytesLimit: 1,
+			},
+			verify: func(t *testing.T, blobs []*gitalypb.ListAllBlobsResponse_Blob) {
+				require.Equal(t, []*gitalypb.ListAllBlobsResponse_Blob{{
+					Oid:  blobID.String(),
+					Size: 6,
+					Data: []byte("f"),
+				}}, blobs)
+			},
+		},
+		{
+			desc: "normal repo",
+			request: &gitalypb.ListAllBlobsRequest{
+				Repository: repo,
+			},
+			verify: func(t *testing.T, blobs []*gitalypb.ListAllBlobsResponse_Blob) {
+				require.Greater(t, len(blobs), 300)
+			},
+		},
+		{
+			desc: "normal repo with limit",
+			request: &gitalypb.ListAllBlobsRequest{
+				Repository: repo,
+				Limit:      2,
+			},
+			verify: func(t *testing.T, blobs []*gitalypb.ListAllBlobsResponse_Blob) {
+				require.Len(t, blobs, 2)
+			},
+		},
+		{
+			desc: "normal repo with bytes limit",
+			request: &gitalypb.ListAllBlobsRequest{
+				Repository: repo,
+				BytesLimit: 1,
+			},
+			verify: func(t *testing.T, blobs []*gitalypb.ListAllBlobsResponse_Blob) {
+				require.Greater(t, len(blobs), 300)
+				for _, blob := range blobs {
+					emptyBlobID := "e69de29bb2d1d6434b8b29ae775ad8c2e48c5391"
+					if blob.Oid == emptyBlobID {
+						require.Empty(t, blob.Data)
+						require.Equal(t, int64(0), blob.Size)
+					} else {
+						require.Len(t, blob.Data, 1)
+					}
+				}
+			},
+		},
+		{
+			desc: "quarantine repo with alternates",
+			request: &gitalypb.ListAllBlobsRequest{
+				Repository: quarantine.QuarantinedRepo(),
+			},
+			verify: func(t *testing.T, blobs []*gitalypb.ListAllBlobsResponse_Blob) {
+				require.Greater(t, len(blobs), 300)
+			},
+		},
+		{
+			desc: "quarantine repo without alternates",
+			request: &gitalypb.ListAllBlobsRequest{
+				Repository: quarantineRepoWithoutAlternates,
+			},
+			verify: func(t *testing.T, blobs []*gitalypb.ListAllBlobsResponse_Blob) {
+				require.Empty(t, blobs)
+			},
+		},
+	} {
+		t.Run(tc.desc, func(t *testing.T) {
+			stream, err := client.ListAllBlobs(ctx, tc.request)
+			require.NoError(t, err)
+
+			var blobs []*gitalypb.ListAllBlobsResponse_Blob
+			for {
+				resp, err := stream.Recv()
+				if err != nil {
+					if !errors.Is(err, io.EOF) {
+						require.NoError(t, err)
+					}
+					break
+				}
+
+				blobs = append(blobs, resp.Blobs...)
+			}
+
+			tc.verify(t, blobs)
+		})
+	}
+}
diff --git a/proto/blob.proto b/proto/blob.proto
index 634a6fc74..f3b16cceb 100644
--- a/proto/blob.proto
+++ b/proto/blob.proto
@@ -31,6 +31,14 @@ service BlobService {
     };
   }
 
+  // ListAllBlobs retrieves all blobs pointers in the repository, including
+  // those not reachable by any reference.
+  rpc ListAllBlobs(ListAllBlobsRequest) returns (stream ListAllBlobsResponse) {
+    option (op_type) = {
+      op: ACCESSOR
+    };
+  }
+
   // GetLFSPointers retrieves LFS pointers from a given set of object IDs.
   // This RPC filters all requested objects and only returns those which refer
   // to a valid LFS pointer.
@@ -149,6 +157,42 @@ message ListBlobsResponse {
   repeated Blob blobs = 1;
 }
 
+// ListAllBlobsRequest is a request for the ListAllBlobs RPC.
+message ListAllBlobsRequest {
+  // Repository is the repository in which blobs should be enumerated.
+  Repository repository = 1 [(target_repository)=true];
+  // Limit is the maximum number of blobs to return. If set to its default
+  // (`0`), then all found blobs wll be returned.
+  uint32 limit = 2;
+  // BytesLimit is the maximum number of bytes to receive for each blob. If set
+  // to `0`, then no blob data will be sent. If `-1`, then all blob data will
+  // be sent without any limits.
+  int64 bytes_limit = 3;
+}
+
+// ListAllBlobsResponse is a response for the ListAllBlobs RPC.
+message ListAllBlobsResponse {
+  // Blob represents a Git blob object.
+  message Blob {
+    // Oid is the object ID of the blob. Will only be set for the first
+    // message of each specific blob.
+    string oid = 1;
+    // Size is the size of the blob. Will only be set for the first message
+    // of each specific blob.
+    int64 size = 2;
+    // Data is the contents of the blob. This field is optional and depends on
+    // the BytesLimit in the original request.
+    bytes data = 3;
+  }
+
+  // Blobs is the blobs which have been found. In case blob contents were
+  // requested and contents of a blob exceed the maximum gRPC message size,
+  // then this blob will be split up into multiple blob messages which span
+  // across multiple responses. In that case, metadata of the blob will only be
+  // sent on the first such message for this specific blob.
+  repeated Blob blobs = 1;
+}
+
 // LFSPointer is a git blob which points to an LFS object.
 message LFSPointer {
   // Size is the size of the blob. This is not the size of the LFS object
diff --git a/proto/go/gitalypb/blob.pb.go b/proto/go/gitalypb/blob.pb.go
index 692b166b6..f26183e1d 100644
--- a/proto/go/gitalypb/blob.pb.go
+++ b/proto/go/gitalypb/blob.pb.go
@@ -457,6 +457,129 @@ func (x *ListBlobsResponse) GetBlobs() []*ListBlobsResponse_Blob {
 	return nil
 }
 
+// ListAllBlobsRequest is a request for the ListAllBlobs RPC.
+type ListAllBlobsRequest struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	// Repository is the repository in which blobs should be enumerated.
+	Repository *Repository `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"`
+	// Limit is the maximum number of blobs to return. If set to its default
+	// (`0`), then all found blobs wll be returned.
+	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
+	// BytesLimit is the maximum number of bytes to receive for each blob. If set
+	// to `0`, then no blob data will be sent. If `-1`, then all blob data will
+	// be sent without any limits.
+	BytesLimit int64 `protobuf:"varint,3,opt,name=bytes_limit,json=bytesLimit,proto3" json:"bytes_limit,omitempty"`
+}
+
+func (x *ListAllBlobsRequest) Reset() {
+	*x = ListAllBlobsRequest{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_blob_proto_msgTypes[6]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *ListAllBlobsRequest) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ListAllBlobsRequest) ProtoMessage() {}
+
+func (x *ListAllBlobsRequest) ProtoReflect() protoreflect.Message {
+	mi := &file_blob_proto_msgTypes[6]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use ListAllBlobsRequest.ProtoReflect.Descriptor instead.
+func (*ListAllBlobsRequest) Descriptor() ([]byte, []int) {
+	return file_blob_proto_rawDescGZIP(), []int{6}
+}
+
+func (x *ListAllBlobsRequest) GetRepository() *Repository {
+	if x != nil {
+		return x.Repository
+	}
+	return nil
+}
+
+func (x *ListAllBlobsRequest) GetLimit() uint32 {
+	if x != nil {
+		return x.Limit
+	}
+	return 0
+}
+
+func (x *ListAllBlobsRequest) GetBytesLimit() int64 {
+	if x != nil {
+		return x.BytesLimit
+	}
+	return 0
+}
+
+// ListAllBlobsResponse is a response for the ListAllBlobs RPC.
+type ListAllBlobsResponse struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	// Blobs is the blobs which have been found. In case blob contents were
+	// requested and contents of a blob exceed the maximum gRPC message size,
+	// then this blob will be split up into multiple blob messages which span
+	// across multiple responses. In that case, metadata of the blob will only be
+	// sent on the first such message for this specific blob.
+	Blobs []*ListAllBlobsResponse_Blob `protobuf:"bytes,1,rep,name=blobs,proto3" json:"blobs,omitempty"`
+}
+
+func (x *ListAllBlobsResponse) Reset() {
+	*x = ListAllBlobsResponse{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_blob_proto_msgTypes[7]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *ListAllBlobsResponse) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ListAllBlobsResponse) ProtoMessage() {}
+
+func (x *ListAllBlobsResponse) ProtoReflect() protoreflect.Message {
+	mi := &file_blob_proto_msgTypes[7]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use ListAllBlobsResponse.ProtoReflect.Descriptor instead.
+func (*ListAllBlobsResponse) Descriptor() ([]byte, []int) {
+	return file_blob_proto_rawDescGZIP(), []int{7}
+}
+
+func (x *ListAllBlobsResponse) GetBlobs() []*ListAllBlobsResponse_Blob {
+	if x != nil {
+		return x.Blobs
+	}
+	return nil
+}
+
 // LFSPointer is a git blob which points to an LFS object.
 type LFSPointer struct {
 	state         protoimpl.MessageState
@@ -476,7 +599,7 @@ type LFSPointer struct {
 func (x *LFSPointer) Reset() {
 	*x = LFSPointer{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[6]
+		mi := &file_blob_proto_msgTypes[8]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -489,7 +612,7 @@ func (x *LFSPointer) String() string {
 func (*LFSPointer) ProtoMessage() {}
 
 func (x *LFSPointer) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[6]
+	mi := &file_blob_proto_msgTypes[8]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -502,7 +625,7 @@ func (x *LFSPointer) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use LFSPointer.ProtoReflect.Descriptor instead.
 func (*LFSPointer) Descriptor() ([]byte, []int) {
-	return file_blob_proto_rawDescGZIP(), []int{6}
+	return file_blob_proto_rawDescGZIP(), []int{8}
 }
 
 func (x *LFSPointer) GetSize() int64 {
@@ -539,7 +662,7 @@ type NewBlobObject struct {
 func (x *NewBlobObject) Reset() {
 	*x = NewBlobObject{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[7]
+		mi := &file_blob_proto_msgTypes[9]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -552,7 +675,7 @@ func (x *NewBlobObject) String() string {
 func (*NewBlobObject) ProtoMessage() {}
 
 func (x *NewBlobObject) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[7]
+	mi := &file_blob_proto_msgTypes[9]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -565,7 +688,7 @@ func (x *NewBlobObject) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use NewBlobObject.ProtoReflect.Descriptor instead.
 func (*NewBlobObject) Descriptor() ([]byte, []int) {
-	return file_blob_proto_rawDescGZIP(), []int{7}
+	return file_blob_proto_rawDescGZIP(), []int{9}
 }
 
 func (x *NewBlobObject) GetSize() int64 {
@@ -606,7 +729,7 @@ type GetLFSPointersRequest struct {
 func (x *GetLFSPointersRequest) Reset() {
 	*x = GetLFSPointersRequest{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[8]
+		mi := &file_blob_proto_msgTypes[10]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -619,7 +742,7 @@ func (x *GetLFSPointersRequest) String() string {
 func (*GetLFSPointersRequest) ProtoMessage() {}
 
 func (x *GetLFSPointersRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[8]
+	mi := &file_blob_proto_msgTypes[10]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -632,7 +755,7 @@ func (x *GetLFSPointersRequest) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use GetLFSPointersRequest.ProtoReflect.Descriptor instead.
 func (*GetLFSPointersRequest) Descriptor() ([]byte, []int) {
-	return file_blob_proto_rawDescGZIP(), []int{8}
+	return file_blob_proto_rawDescGZIP(), []int{10}
 }
 
 func (x *GetLFSPointersRequest) GetRepository() *Repository {
@@ -662,7 +785,7 @@ type GetLFSPointersResponse struct {
 func (x *GetLFSPointersResponse) Reset() {
 	*x = GetLFSPointersResponse{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[9]
+		mi := &file_blob_proto_msgTypes[11]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -675,7 +798,7 @@ func (x *GetLFSPointersResponse) String() string {
 func (*GetLFSPointersResponse) ProtoMessage() {}
 
 func (x *GetLFSPointersResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[9]
+	mi := &file_blob_proto_msgTypes[11]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -688,7 +811,7 @@ func (x *GetLFSPointersResponse) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use GetLFSPointersResponse.ProtoReflect.Descriptor instead.
 func (*GetLFSPointersResponse) Descriptor() ([]byte, []int) {
-	return file_blob_proto_rawDescGZIP(), []int{9}
+	return file_blob_proto_rawDescGZIP(), []int{11}
 }
 
 func (x *GetLFSPointersResponse) GetLfsPointers() []*LFSPointer {
@@ -717,7 +840,7 @@ type ListLFSPointersRequest struct {
 func (x *ListLFSPointersRequest) Reset() {
 	*x = ListLFSPointersRequest{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[10]
+		mi := &file_blob_proto_msgTypes[12]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -730,7 +853,7 @@ func (x *ListLFSPointersRequest) String() string {
 func (*ListLFSPointersRequest) ProtoMessage() {}
 
 func (x *ListLFSPointersRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[10]
+	mi := &file_blob_proto_msgTypes[12]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -743,7 +866,7 @@ func (x *ListLFSPointersRequest) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ListLFSPointersRequest.ProtoReflect.Descriptor instead.
 func (*ListLFSPointersRequest) Descriptor() ([]byte, []int) {
-	return file_blob_proto_rawDescGZIP(), []int{10}
+	return file_blob_proto_rawDescGZIP(), []int{12}
 }
 
 func (x *ListLFSPointersRequest) GetRepository() *Repository {
@@ -780,7 +903,7 @@ type ListLFSPointersResponse struct {
 func (x *ListLFSPointersResponse) Reset() {
 	*x = ListLFSPointersResponse{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[11]
+		mi := &file_blob_proto_msgTypes[13]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -793,7 +916,7 @@ func (x *ListLFSPointersResponse) String() string {
 func (*ListLFSPointersResponse) ProtoMessage() {}
 
 func (x *ListLFSPointersResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[11]
+	mi := &file_blob_proto_msgTypes[13]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -806,7 +929,7 @@ func (x *ListLFSPointersResponse) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ListLFSPointersResponse.ProtoReflect.Descriptor instead.
 func (*ListLFSPointersResponse) Descriptor() ([]byte, []int) {
-	return file_blob_proto_rawDescGZIP(), []int{11}
+	return file_blob_proto_rawDescGZIP(), []int{13}
 }
 
 func (x *ListLFSPointersResponse) GetLfsPointers() []*LFSPointer {
@@ -832,7 +955,7 @@ type ListAllLFSPointersRequest struct {
 func (x *ListAllLFSPointersRequest) Reset() {
 	*x = ListAllLFSPointersRequest{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[12]
+		mi := &file_blob_proto_msgTypes[14]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -845,7 +968,7 @@ func (x *ListAllLFSPointersRequest) String() string {
 func (*ListAllLFSPointersRequest) ProtoMessage() {}
 
 func (x *ListAllLFSPointersRequest) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[12]
+	mi := &file_blob_proto_msgTypes[14]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -858,7 +981,7 @@ func (x *ListAllLFSPointersRequest) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ListAllLFSPointersRequest.ProtoReflect.Descriptor instead.
 func (*ListAllLFSPointersRequest) Descriptor() ([]byte, []int) {
-	return file_blob_proto_rawDescGZIP(), []int{12}
+	return file_blob_proto_rawDescGZIP(), []int{14}
 }
 
 func (x *ListAllLFSPointersRequest) GetRepository() *Repository {
@@ -888,7 +1011,7 @@ type ListAllLFSPointersResponse struct {
 func (x *ListAllLFSPointersResponse) Reset() {
 	*x = ListAllLFSPointersResponse{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[13]
+		mi := &file_blob_proto_msgTypes[15]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -901,7 +1024,7 @@ func (x *ListAllLFSPointersResponse) String() string {
 func (*ListAllLFSPointersResponse) ProtoMessage() {}
 
 func (x *ListAllLFSPointersResponse) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[13]
+	mi := &file_blob_proto_msgTypes[15]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -914,7 +1037,7 @@ func (x *ListAllLFSPointersResponse) ProtoReflect() protoreflect.Message {
 
 // Deprecated: Use ListAllLFSPointersResponse.ProtoReflect.Descriptor instead.
 func (*ListAllLFSPointersResponse) Descriptor() ([]byte, []int) {
-	return file_blob_proto_rawDescGZIP(), []int{13}
+	return file_blob_proto_rawDescGZIP(), []int{15}
 }
 
 func (x *ListAllLFSPointersResponse) GetLfsPointers() []*LFSPointer {
@@ -936,7 +1059,7 @@ type GetBlobsRequest_RevisionPath struct {
 func (x *GetBlobsRequest_RevisionPath) Reset() {
 	*x = GetBlobsRequest_RevisionPath{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[14]
+		mi := &file_blob_proto_msgTypes[16]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -949,7 +1072,7 @@ func (x *GetBlobsRequest_RevisionPath) String() string {
 func (*GetBlobsRequest_RevisionPath) ProtoMessage() {}
 
 func (x *GetBlobsRequest_RevisionPath) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[14]
+	mi := &file_blob_proto_msgTypes[16]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -999,7 +1122,7 @@ type ListBlobsResponse_Blob struct {
 func (x *ListBlobsResponse_Blob) Reset() {
 	*x = ListBlobsResponse_Blob{}
 	if protoimpl.UnsafeEnabled {
-		mi := &file_blob_proto_msgTypes[15]
+		mi := &file_blob_proto_msgTypes[17]
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		ms.StoreMessageInfo(mi)
 	}
@@ -1012,7 +1135,7 @@ func (x *ListBlobsResponse_Blob) String() string {
 func (*ListBlobsResponse_Blob) ProtoMessage() {}
 
 func (x *ListBlobsResponse_Blob) ProtoReflect() protoreflect.Message {
-	mi := &file_blob_proto_msgTypes[15]
+	mi := &file_blob_proto_msgTypes[17]
 	if protoimpl.UnsafeEnabled && x != nil {
 		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
 		if ms.LoadMessageInfo() == nil {
@@ -1049,6 +1172,76 @@ func (x *ListBlobsResponse_Blob) GetData() []byte {
 	return nil
 }
 
+// Blob represents a Git blob object.
+type ListAllBlobsResponse_Blob struct {
+	state         protoimpl.MessageState
+	sizeCache     protoimpl.SizeCache
+	unknownFields protoimpl.UnknownFields
+
+	// Oid is the object ID of the blob. Will only be set for the first
+	// message of each specific blob.
+	Oid string `protobuf:"bytes,1,opt,name=oid,proto3" json:"oid,omitempty"`
+	// Size is the size of the blob. Will only be set for the first message
+	// of each specific blob.
+	Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
+	// Data is the contents of the blob. This field is optional and depends on
+	// the BytesLimit in the original request.
+	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
+}
+
+func (x *ListAllBlobsResponse_Blob) Reset() {
+	*x = ListAllBlobsResponse_Blob{}
+	if protoimpl.UnsafeEnabled {
+		mi := &file_blob_proto_msgTypes[18]
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		ms.StoreMessageInfo(mi)
+	}
+}
+
+func (x *ListAllBlobsResponse_Blob) String() string {
+	return protoimpl.X.MessageStringOf(x)
+}
+
+func (*ListAllBlobsResponse_Blob) ProtoMessage() {}
+
+func (x *ListAllBlobsResponse_Blob) ProtoReflect() protoreflect.Message {
+	mi := &file_blob_proto_msgTypes[18]
+	if protoimpl.UnsafeEnabled && x != nil {
+		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+		if ms.LoadMessageInfo() == nil {
+			ms.StoreMessageInfo(mi)
+		}
+		return ms
+	}
+	return mi.MessageOf(x)
+}
+
+// Deprecated: Use ListAllBlobsResponse_Blob.ProtoReflect.Descriptor instead.
+func (*ListAllBlobsResponse_Blob) Descriptor() ([]byte, []int) {
+	return file_blob_proto_rawDescGZIP(), []int{7, 0}
+}
+
+func (x *ListAllBlobsResponse_Blob) GetOid() string {
+	if x != nil {
+		return x.Oid
+	}
+	return ""
+}
+
+func (x *ListAllBlobsResponse_Blob) GetSize() int64 {
+	if x != nil {
+		return x.Size
+	}
+	return 0
+}
+
+func (x *ListAllBlobsResponse_Blob) GetData() []byte {
+	if x != nil {
+		return x.Data
+	}
+	return nil
+}
+
 var File_blob_proto protoreflect.FileDescriptor
 
 var file_blob_proto_rawDesc = []byte{
@@ -1115,90 +1308,113 @@ var file_blob_proto_rawDesc = []byte{
 	0x01, 0x28, 0x09, 0x52, 0x03, 0x6f, 0x69, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x73, 0x69, 0x7a, 0x65,
 	0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x73, 0x69, 0x7a, 0x65, 0x12, 0x12, 0x0a, 0x04,
 	0x64, 0x61, 0x74, 0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61,
-	0x22, 0x46, 0x0a, 0x0a, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x12, 0x12,
-	0x0a, 0x04, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x73, 0x69,
-	0x7a, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c,
-	0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x10, 0x0a, 0x03, 0x6f, 0x69, 0x64, 0x18, 0x03, 0x20,
-	0x01, 0x28, 0x09, 0x52, 0x03, 0x6f, 0x69, 0x64, 0x22, 0x49, 0x0a, 0x0d, 0x4e, 0x65, 0x77, 0x42,
-	0x6c, 0x6f, 0x62, 0x4f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x73, 0x69, 0x7a,
-	0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x73, 0x69, 0x7a, 0x65, 0x12, 0x10, 0x0a,
-	0x03, 0x6f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6f, 0x69, 0x64, 0x12,
-	0x12, 0x0a, 0x04, 0x70, 0x61, 0x74, 0x68, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x70,
-	0x61, 0x74, 0x68, 0x22, 0x6c, 0x0a, 0x15, 0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69,
-	0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x0a,
-	0x72, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
-	0x32, 0x12, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69,
-	0x74, 0x6f, 0x72, 0x79, 0x42, 0x04, 0x98, 0xc6, 0x2c, 0x01, 0x52, 0x0a, 0x72, 0x65, 0x70, 0x6f,
-	0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x12, 0x19, 0x0a, 0x08, 0x62, 0x6c, 0x6f, 0x62, 0x5f, 0x69,
-	0x64, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x62, 0x6c, 0x6f, 0x62, 0x49, 0x64,
-	0x73, 0x22, 0x4f, 0x0a, 0x16, 0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74,
-	0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x35, 0x0a, 0x0c, 0x6c,
-	0x66, 0x73, 0x5f, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28,
-	0x0b, 0x32, 0x12, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x46, 0x53, 0x50, 0x6f,
-	0x69, 0x6e, 0x74, 0x65, 0x72, 0x52, 0x0b, 0x6c, 0x66, 0x73, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65,
-	0x72, 0x73, 0x22, 0x86, 0x01, 0x0a, 0x16, 0x4c, 0x69, 0x73, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f,
-	0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a,
-	0x0a, 0x72, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28,
-	0x0b, 0x32, 0x12, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x73,
-	0x69, 0x74, 0x6f, 0x72, 0x79, 0x42, 0x04, 0x98, 0xc6, 0x2c, 0x01, 0x52, 0x0a, 0x72, 0x65, 0x70,
-	0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x12, 0x1c, 0x0a, 0x09, 0x72, 0x65, 0x76, 0x69, 0x73,
-	0x69, 0x6f, 0x6e, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x76, 0x69,
-	0x73, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x03,
-	0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x22, 0x50, 0x0a, 0x17, 0x4c,
-	0x69, 0x73, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65,
-	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x35, 0x0a, 0x0c, 0x6c, 0x66, 0x73, 0x5f, 0x70, 0x6f,
-	0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67,
-	0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72,
-	0x52, 0x0b, 0x6c, 0x66, 0x73, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x22, 0x6b, 0x0a,
-	0x19, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74,
+	0x22, 0x86, 0x01, 0x0a, 0x13, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x42, 0x6c, 0x6f, 0x62,
+	0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x0a, 0x72, 0x65, 0x70, 0x6f,
+	0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67,
+	0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79,
+	0x42, 0x04, 0x98, 0xc6, 0x2c, 0x01, 0x52, 0x0a, 0x72, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f,
+	0x72, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28,
+	0x0d, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x12, 0x1f, 0x0a, 0x0b, 0x62, 0x79, 0x74, 0x65,
+	0x73, 0x5f, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0a, 0x62,
+	0x79, 0x74, 0x65, 0x73, 0x4c, 0x69, 0x6d, 0x69, 0x74, 0x22, 0x91, 0x01, 0x0a, 0x14, 0x4c, 0x69,
+	0x73, 0x74, 0x41, 0x6c, 0x6c, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+	0x73, 0x65, 0x12, 0x37, 0x0a, 0x05, 0x62, 0x6c, 0x6f, 0x62, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28,
+	0x0b, 0x32, 0x21, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41,
+	0x6c, 0x6c, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e,
+	0x42, 0x6c, 0x6f, 0x62, 0x52, 0x05, 0x62, 0x6c, 0x6f, 0x62, 0x73, 0x1a, 0x40, 0x0a, 0x04, 0x42,
+	0x6c, 0x6f, 0x62, 0x12, 0x10, 0x0a, 0x03, 0x6f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
+	0x52, 0x03, 0x6f, 0x69, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x02, 0x20,
+	0x01, 0x28, 0x03, 0x52, 0x04, 0x73, 0x69, 0x7a, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74,
+	0x61, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x22, 0x46, 0x0a,
+	0x0a, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x12, 0x12, 0x0a, 0x04, 0x73,
+	0x69, 0x7a, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x73, 0x69, 0x7a, 0x65, 0x12,
+	0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64,
+	0x61, 0x74, 0x61, 0x12, 0x10, 0x0a, 0x03, 0x6f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09,
+	0x52, 0x03, 0x6f, 0x69, 0x64, 0x22, 0x49, 0x0a, 0x0d, 0x4e, 0x65, 0x77, 0x42, 0x6c, 0x6f, 0x62,
+	0x4f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x73, 0x69, 0x7a, 0x65, 0x18, 0x01,
+	0x20, 0x01, 0x28, 0x03, 0x52, 0x04, 0x73, 0x69, 0x7a, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6f, 0x69,
+	0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6f, 0x69, 0x64, 0x12, 0x12, 0x0a, 0x04,
+	0x70, 0x61, 0x74, 0x68, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x70, 0x61, 0x74, 0x68,
+	0x22, 0x6c, 0x0a, 0x15, 0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65,
+	0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x0a, 0x72, 0x65, 0x70,
+	0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e,
+	0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72,
+	0x79, 0x42, 0x04, 0x98, 0xc6, 0x2c, 0x01, 0x52, 0x0a, 0x72, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74,
+	0x6f, 0x72, 0x79, 0x12, 0x19, 0x0a, 0x08, 0x62, 0x6c, 0x6f, 0x62, 0x5f, 0x69, 0x64, 0x73, 0x18,
+	0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x62, 0x6c, 0x6f, 0x62, 0x49, 0x64, 0x73, 0x22, 0x4f,
+	0x0a, 0x16, 0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73,
+	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x35, 0x0a, 0x0c, 0x6c, 0x66, 0x73, 0x5f,
+	0x70, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12,
+	0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74,
+	0x65, 0x72, 0x52, 0x0b, 0x6c, 0x66, 0x73, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x22,
+	0x86, 0x01, 0x0a, 0x16, 0x4c, 0x69, 0x73, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74,
 	0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x0a, 0x72, 0x65,
 	0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12,
 	0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f,
 	0x72, 0x79, 0x42, 0x04, 0x98, 0xc6, 0x2c, 0x01, 0x52, 0x0a, 0x72, 0x65, 0x70, 0x6f, 0x73, 0x69,
-	0x74, 0x6f, 0x72, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x03, 0x20,
-	0x01, 0x28, 0x05, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x22, 0x53, 0x0a, 0x1a, 0x4c, 0x69,
+	0x74, 0x6f, 0x72, 0x79, 0x12, 0x1c, 0x0a, 0x09, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f, 0x6e,
+	0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x76, 0x69, 0x73, 0x69, 0x6f,
+	0x6e, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28,
+	0x05, 0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x22, 0x50, 0x0a, 0x17, 0x4c, 0x69, 0x73, 0x74,
+	0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f,
+	0x6e, 0x73, 0x65, 0x12, 0x35, 0x0a, 0x0c, 0x6c, 0x66, 0x73, 0x5f, 0x70, 0x6f, 0x69, 0x6e, 0x74,
+	0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x69, 0x74, 0x61,
+	0x6c, 0x79, 0x2e, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x52, 0x0b, 0x6c,
+	0x66, 0x73, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x22, 0x6b, 0x0a, 0x19, 0x4c, 0x69,
 	0x73, 0x74, 0x41, 0x6c, 0x6c, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73,
-	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x35, 0x0a, 0x0c, 0x6c, 0x66, 0x73, 0x5f,
-	0x70, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12,
-	0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74,
-	0x65, 0x72, 0x52, 0x0b, 0x6c, 0x66, 0x73, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x32,
-	0x88, 0x04, 0x0a, 0x0b, 0x42, 0x6c, 0x6f, 0x62, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12,
-	0x44, 0x0a, 0x07, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x12, 0x16, 0x2e, 0x67, 0x69, 0x74,
-	0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65,
-	0x73, 0x74, 0x1a, 0x17, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x42,
-	0x6c, 0x6f, 0x62, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28,
-	0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x47, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62,
-	0x73, 0x12, 0x17, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x42, 0x6c,
-	0x6f, 0x62, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x67, 0x69, 0x74,
-	0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70,
-	0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x4a,
-	0x0a, 0x09, 0x4c, 0x69, 0x73, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x12, 0x18, 0x2e, 0x67, 0x69,
-	0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65,
-	0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x19, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c,
-	0x69, 0x73, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
-	0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x59, 0x0a, 0x0e, 0x47, 0x65,
-	0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x12, 0x1d, 0x2e, 0x67,
-	0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e,
-	0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x67, 0x69,
-	0x74, 0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74,
+	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x38, 0x0a, 0x0a, 0x72, 0x65, 0x70, 0x6f, 0x73,
+	0x69, 0x74, 0x6f, 0x72, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x69,
+	0x74, 0x61, 0x6c, 0x79, 0x2e, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x42,
+	0x04, 0x98, 0xc6, 0x2c, 0x01, 0x52, 0x0a, 0x72, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72,
+	0x79, 0x12, 0x14, 0x0a, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05,
+	0x52, 0x05, 0x6c, 0x69, 0x6d, 0x69, 0x74, 0x22, 0x53, 0x0a, 0x1a, 0x4c, 0x69, 0x73, 0x74, 0x41,
+	0x6c, 0x6c, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73,
+	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x35, 0x0a, 0x0c, 0x6c, 0x66, 0x73, 0x5f, 0x70, 0x6f, 0x69,
+	0x6e, 0x74, 0x65, 0x72, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x69,
+	0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x52,
+	0x0b, 0x6c, 0x66, 0x73, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x32, 0xdd, 0x04, 0x0a,
+	0x0b, 0x42, 0x6c, 0x6f, 0x62, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x44, 0x0a, 0x07,
+	0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x12, 0x16, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79,
+	0x2e, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
+	0x17, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62,
+	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02,
+	0x30, 0x01, 0x12, 0x47, 0x0a, 0x08, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x12, 0x17,
+	0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73,
+	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79,
+	0x2e, 0x47, 0x65, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
+	0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x4a, 0x0a, 0x09, 0x4c,
+	0x69, 0x73, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x12, 0x18, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c,
+	0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
+	0x73, 0x74, 0x1a, 0x19, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74,
+	0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa,
+	0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x53, 0x0a, 0x0c, 0x4c, 0x69, 0x73, 0x74, 0x41,
+	0x6c, 0x6c, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x12, 0x1b, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79,
+	0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x71,
+	0x75, 0x65, 0x73, 0x74, 0x1a, 0x1c, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69,
+	0x73, 0x74, 0x41, 0x6c, 0x6c, 0x42, 0x6c, 0x6f, 0x62, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+	0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x59, 0x0a, 0x0e,
+	0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x12, 0x1d,
+	0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f,
+	0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e,
+	0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x47, 0x65, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69,
+	0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa,
+	0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x5c, 0x0a, 0x0f, 0x4c, 0x69, 0x73, 0x74, 0x4c,
+	0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x12, 0x1e, 0x2e, 0x67, 0x69, 0x74,
+	0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74,
+	0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x67, 0x69, 0x74,
+	0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74,
 	0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28,
-	0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x5c, 0x0a, 0x0f, 0x4c, 0x69, 0x73, 0x74, 0x4c, 0x46, 0x53,
-	0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x12, 0x1e, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c,
-	0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72,
-	0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c,
-	0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72,
-	0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08,
-	0x02, 0x30, 0x01, 0x12, 0x65, 0x0a, 0x12, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x4c, 0x46,
-	0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x12, 0x21, 0x2e, 0x67, 0x69, 0x74, 0x61,
-	0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69,
-	0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x67,
-	0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x4c, 0x46, 0x53,
-	0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
-	0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x42, 0x34, 0x5a, 0x32, 0x67, 0x69,
-	0x74, 0x6c, 0x61, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x69, 0x74, 0x6c, 0x61, 0x62, 0x2d,
-	0x6f, 0x72, 0x67, 0x2f, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2f, 0x76, 0x31, 0x34, 0x2f, 0x70,
-	0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x70, 0x62,
-	0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
+	0x02, 0x08, 0x02, 0x30, 0x01, 0x12, 0x65, 0x0a, 0x12, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c,
+	0x4c, 0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x12, 0x21, 0x2e, 0x67, 0x69,
+	0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x4c, 0x46, 0x53, 0x50,
+	0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22,
+	0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x41, 0x6c, 0x6c, 0x4c,
+	0x46, 0x53, 0x50, 0x6f, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+	0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 0x30, 0x01, 0x42, 0x34, 0x5a, 0x32,
+	0x67, 0x69, 0x74, 0x6c, 0x61, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x69, 0x74, 0x6c, 0x61,
+	0x62, 0x2d, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2f, 0x76, 0x31, 0x34,
+	0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79,
+	0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
@@ -1213,7 +1429,7 @@ func file_blob_proto_rawDescGZIP() []byte {
 	return file_blob_proto_rawDescData
 }
 
-var file_blob_proto_msgTypes = make([]protoimpl.MessageInfo, 16)
+var file_blob_proto_msgTypes = make([]protoimpl.MessageInfo, 19)
 var file_blob_proto_goTypes = []interface{}{
 	(*GetBlobRequest)(nil),               // 0: gitaly.GetBlobRequest
 	(*GetBlobResponse)(nil),              // 1: gitaly.GetBlobResponse
@@ -1221,49 +1437,56 @@ var file_blob_proto_goTypes = []interface{}{
 	(*GetBlobsResponse)(nil),             // 3: gitaly.GetBlobsResponse
 	(*ListBlobsRequest)(nil),             // 4: gitaly.ListBlobsRequest
 	(*ListBlobsResponse)(nil),            // 5: gitaly.ListBlobsResponse
-	(*LFSPointer)(nil),                   // 6: gitaly.LFSPointer
-	(*NewBlobObject)(nil),                // 7: gitaly.NewBlobObject
-	(*GetLFSPointersRequest)(nil),        // 8: gitaly.GetLFSPointersRequest
-	(*GetLFSPointersResponse)(nil),       // 9: gitaly.GetLFSPointersResponse
-	(*ListLFSPointersRequest)(nil),       // 10: gitaly.ListLFSPointersRequest
-	(*ListLFSPointersResponse)(nil),      // 11: gitaly.ListLFSPointersResponse
-	(*ListAllLFSPointersRequest)(nil),    // 12: gitaly.ListAllLFSPointersRequest
-	(*ListAllLFSPointersResponse)(nil),   // 13: gitaly.ListAllLFSPointersResponse
-	(*GetBlobsRequest_RevisionPath)(nil), // 14: gitaly.GetBlobsRequest.RevisionPath
-	(*ListBlobsResponse_Blob)(nil),       // 15: gitaly.ListBlobsResponse.Blob
-	(*Repository)(nil),                   // 16: gitaly.Repository
-	(ObjectType)(0),                      // 17: gitaly.ObjectType
+	(*ListAllBlobsRequest)(nil),          // 6: gitaly.ListAllBlobsRequest
+	(*ListAllBlobsResponse)(nil),         // 7: gitaly.ListAllBlobsResponse
+	(*LFSPointer)(nil),                   // 8: gitaly.LFSPointer
+	(*NewBlobObject)(nil),                // 9: gitaly.NewBlobObject
+	(*GetLFSPointersRequest)(nil),        // 10: gitaly.GetLFSPointersRequest
+	(*GetLFSPointersResponse)(nil),       // 11: gitaly.GetLFSPointersResponse
+	(*ListLFSPointersRequest)(nil),       // 12: gitaly.ListLFSPointersRequest
+	(*ListLFSPointersResponse)(nil),      // 13: gitaly.ListLFSPointersResponse
+	(*ListAllLFSPointersRequest)(nil),    // 14: gitaly.ListAllLFSPointersRequest
+	(*ListAllLFSPointersResponse)(nil),   // 15: gitaly.ListAllLFSPointersResponse
+	(*GetBlobsRequest_RevisionPath)(nil), // 16: gitaly.GetBlobsRequest.RevisionPath
+	(*ListBlobsResponse_Blob)(nil),       // 17: gitaly.ListBlobsResponse.Blob
+	(*ListAllBlobsResponse_Blob)(nil),    // 18: gitaly.ListAllBlobsResponse.Blob
+	(*Repository)(nil),                   // 19: gitaly.Repository
+	(ObjectType)(0),                      // 20: gitaly.ObjectType
 }
 var file_blob_proto_depIdxs = []int32{
-	16, // 0: gitaly.GetBlobRequest.repository:type_name -> gitaly.Repository
-	16, // 1: gitaly.GetBlobsRequest.repository:type_name -> gitaly.Repository
-	14, // 2: gitaly.GetBlobsRequest.revision_paths:type_name -> gitaly.GetBlobsRequest.RevisionPath
-	17, // 3: gitaly.GetBlobsResponse.type:type_name -> gitaly.ObjectType
-	16, // 4: gitaly.ListBlobsRequest.repository:type_name -> gitaly.Repository
-	15, // 5: gitaly.ListBlobsResponse.blobs:type_name -> gitaly.ListBlobsResponse.Blob
-	16, // 6: gitaly.GetLFSPointersRequest.repository:type_name -> gitaly.Repository
-	6,  // 7: gitaly.GetLFSPointersResponse.lfs_pointers:type_name -> gitaly.LFSPointer
-	16, // 8: gitaly.ListLFSPointersRequest.repository:type_name -> gitaly.Repository
-	6,  // 9: gitaly.ListLFSPointersResponse.lfs_pointers:type_name -> gitaly.LFSPointer
-	16, // 10: gitaly.ListAllLFSPointersRequest.repository:type_name -> gitaly.Repository
-	6,  // 11: gitaly.ListAllLFSPointersResponse.lfs_pointers:type_name -> gitaly.LFSPointer
-	0,  // 12: gitaly.BlobService.GetBlob:input_type -> gitaly.GetBlobRequest
-	2,  // 13: gitaly.BlobService.GetBlobs:input_type -> gitaly.GetBlobsRequest
-	4,  // 14: gitaly.BlobService.ListBlobs:input_type -> gitaly.ListBlobsRequest
-	8,  // 15: gitaly.BlobService.GetLFSPointers:input_type -> gitaly.GetLFSPointersRequest
-	10, // 16: gitaly.BlobService.ListLFSPointers:input_type -> gitaly.ListLFSPointersRequest
-	12, // 17: gitaly.BlobService.ListAllLFSPointers:input_type -> gitaly.ListAllLFSPointersRequest
-	1,  // 18: gitaly.BlobService.GetBlob:output_type -> gitaly.GetBlobResponse
-	3,  // 19: gitaly.BlobService.GetBlobs:output_type -> gitaly.GetBlobsResponse
-	5,  // 20: gitaly.BlobService.ListBlobs:output_type -> gitaly.ListBlobsResponse
-	9,  // 21: gitaly.BlobService.GetLFSPointers:output_type -> gitaly.GetLFSPointersResponse
-	11, // 22: gitaly.BlobService.ListLFSPointers:output_type -> gitaly.ListLFSPointersResponse
-	13, // 23: gitaly.BlobService.ListAllLFSPointers:output_type -> gitaly.ListAllLFSPointersResponse
-	18, // [18:24] is the sub-list for method output_type
-	12, // [12:18] is the sub-list for method input_type
-	12, // [12:12] is the sub-list for extension type_name
-	12, // [12:12] is the sub-list for extension extendee
-	0,  // [0:12] is the sub-list for field type_name
+	19, // 0: gitaly.GetBlobRequest.repository:type_name -> gitaly.Repository
+	19, // 1: gitaly.GetBlobsRequest.repository:type_name -> gitaly.Repository
+	16, // 2: gitaly.GetBlobsRequest.revision_paths:type_name -> gitaly.GetBlobsRequest.RevisionPath
+	20, // 3: gitaly.GetBlobsResponse.type:type_name -> gitaly.ObjectType
+	19, // 4: gitaly.ListBlobsRequest.repository:type_name -> gitaly.Repository
+	17, // 5: gitaly.ListBlobsResponse.blobs:type_name -> gitaly.ListBlobsResponse.Blob
+	19, // 6: gitaly.ListAllBlobsRequest.repository:type_name -> gitaly.Repository
+	18, // 7: gitaly.ListAllBlobsResponse.blobs:type_name -> gitaly.ListAllBlobsResponse.Blob
+	19, // 8: gitaly.GetLFSPointersRequest.repository:type_name -> gitaly.Repository
+	8,  // 9: gitaly.GetLFSPointersResponse.lfs_pointers:type_name -> gitaly.LFSPointer
+	19, // 10: gitaly.ListLFSPointersRequest.repository:type_name -> gitaly.Repository
+	8,  // 11: gitaly.ListLFSPointersResponse.lfs_pointers:type_name -> gitaly.LFSPointer
+	19, // 12: gitaly.ListAllLFSPointersRequest.repository:type_name -> gitaly.Repository
+	8,  // 13: gitaly.ListAllLFSPointersResponse.lfs_pointers:type_name -> gitaly.LFSPointer
+	0,  // 14: gitaly.BlobService.GetBlob:input_type -> gitaly.GetBlobRequest
+	2,  // 15: gitaly.BlobService.GetBlobs:input_type -> gitaly.GetBlobsRequest
+	4,  // 16: gitaly.BlobService.ListBlobs:input_type -> gitaly.ListBlobsRequest
+	6,  // 17: gitaly.BlobService.ListAllBlobs:input_type -> gitaly.ListAllBlobsRequest
+	10, // 18: gitaly.BlobService.GetLFSPointers:input_type -> gitaly.GetLFSPointersRequest
+	12, // 19: gitaly.BlobService.ListLFSPointers:input_type -> gitaly.ListLFSPointersRequest
+	14, // 20: gitaly.BlobService.ListAllLFSPointers:input_type -> gitaly.ListAllLFSPointersRequest
+	1,  // 21: gitaly.BlobService.GetBlob:output_type -> gitaly.GetBlobResponse
+	3,  // 22: gitaly.BlobService.GetBlobs:output_type -> gitaly.GetBlobsResponse
+	5,  // 23: gitaly.BlobService.ListBlobs:output_type -> gitaly.ListBlobsResponse
+	7,  // 24: gitaly.BlobService.ListAllBlobs:output_type -> gitaly.ListAllBlobsResponse
+	11, // 25: gitaly.BlobService.GetLFSPointers:output_type -> gitaly.GetLFSPointersResponse
+	13, // 26: gitaly.BlobService.ListLFSPointers:output_type -> gitaly.ListLFSPointersResponse
+	15, // 27: gitaly.BlobService.ListAllLFSPointers:output_type -> gitaly.ListAllLFSPointersResponse
+	21, // [21:28] is the sub-list for method output_type
+	14, // [14:21] is the sub-list for method input_type
+	14, // [14:14] is the sub-list for extension type_name
+	14, // [14:14] is the sub-list for extension extendee
+	0,  // [0:14] is the sub-list for field type_name
 }
 
 func init() { file_blob_proto_init() }
@@ -1347,7 +1570,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*LFSPointer); i {
+			switch v := v.(*ListAllBlobsRequest); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1359,7 +1582,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*NewBlobObject); i {
+			switch v := v.(*ListAllBlobsResponse); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1371,7 +1594,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*GetLFSPointersRequest); i {
+			switch v := v.(*LFSPointer); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1383,7 +1606,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*GetLFSPointersResponse); i {
+			switch v := v.(*NewBlobObject); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1395,7 +1618,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*ListLFSPointersRequest); i {
+			switch v := v.(*GetLFSPointersRequest); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1407,7 +1630,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*ListLFSPointersResponse); i {
+			switch v := v.(*GetLFSPointersResponse); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1419,7 +1642,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*ListAllLFSPointersRequest); i {
+			switch v := v.(*ListLFSPointersRequest); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1431,7 +1654,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*ListAllLFSPointersResponse); i {
+			switch v := v.(*ListLFSPointersResponse); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1443,7 +1666,7 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
-			switch v := v.(*GetBlobsRequest_RevisionPath); i {
+			switch v := v.(*ListAllLFSPointersRequest); i {
 			case 0:
 				return &v.state
 			case 1:
@@ -1455,6 +1678,30 @@ func file_blob_proto_init() {
 			}
 		}
 		file_blob_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*ListAllLFSPointersResponse); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_blob_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*GetBlobsRequest_RevisionPath); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
+		file_blob_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
 			switch v := v.(*ListBlobsResponse_Blob); i {
 			case 0:
 				return &v.state
@@ -1466,6 +1713,18 @@ func file_blob_proto_init() {
 				return nil
 			}
 		}
+		file_blob_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
+			switch v := v.(*ListAllBlobsResponse_Blob); i {
+			case 0:
+				return &v.state
+			case 1:
+				return &v.sizeCache
+			case 2:
+				return &v.unknownFields
+			default:
+				return nil
+			}
+		}
 	}
 	type x struct{}
 	out := protoimpl.TypeBuilder{
@@ -1473,7 +1732,7 @@ func file_blob_proto_init() {
 			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
 			RawDescriptor: file_blob_proto_rawDesc,
 			NumEnums:      0,
-			NumMessages:   16,
+			NumMessages:   19,
 			NumExtensions: 0,
 			NumServices:   1,
 		},
diff --git a/proto/go/gitalypb/blob_grpc.pb.go b/proto/go/gitalypb/blob_grpc.pb.go
index ceacafe01..ffc48c044 100644
--- a/proto/go/gitalypb/blob_grpc.pb.go
+++ b/proto/go/gitalypb/blob_grpc.pb.go
@@ -27,6 +27,9 @@ type BlobServiceClient interface {
 	// doing a graph walk. It is not valid to pass revisions which do not resolve
 	// to an existing object.
 	ListBlobs(ctx context.Context, in *ListBlobsRequest, opts ...grpc.CallOption) (BlobService_ListBlobsClient, error)
+	// ListAllBlobs retrieves all blobs pointers in the repository, including
+	// those not reachable by any reference.
+	ListAllBlobs(ctx context.Context, in *ListAllBlobsRequest, opts ...grpc.CallOption) (BlobService_ListAllBlobsClient, error)
 	// GetLFSPointers retrieves LFS pointers from a given set of object IDs.
 	// This RPC filters all requested objects and only returns those which refer
 	// to a valid LFS pointer.
@@ -147,8 +150,40 @@ func (x *blobServiceListBlobsClient) Recv() (*ListBlobsResponse, error) {
 	return m, nil
 }
 
+func (c *blobServiceClient) ListAllBlobs(ctx context.Context, in *ListAllBlobsRequest, opts ...grpc.CallOption) (BlobService_ListAllBlobsClient, error) {
+	stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[3], "/gitaly.BlobService/ListAllBlobs", opts...)
+	if err != nil {
+		return nil, err
+	}
+	x := &blobServiceListAllBlobsClient{stream}
+	if err := x.ClientStream.SendMsg(in); err != nil {
+		return nil, err
+	}
+	if err := x.ClientStream.CloseSend(); err != nil {
+		return nil, err
+	}
+	return x, nil
+}
+
+type BlobService_ListAllBlobsClient interface {
+	Recv() (*ListAllBlobsResponse, error)
+	grpc.ClientStream
+}
+
+type blobServiceListAllBlobsClient struct {
+	grpc.ClientStream
+}
+
+func (x *blobServiceListAllBlobsClient) Recv() (*ListAllBlobsResponse, error) {
+	m := new(ListAllBlobsResponse)
+	if err := x.ClientStream.RecvMsg(m); err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
 func (c *blobServiceClient) GetLFSPointers(ctx context.Context, in *GetLFSPointersRequest, opts ...grpc.CallOption) (BlobService_GetLFSPointersClient, error) {
-	stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[3], "/gitaly.BlobService/GetLFSPointers", opts...)
+	stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[4], "/gitaly.BlobService/GetLFSPointers", opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -180,7 +215,7 @@ func (x *blobServiceGetLFSPointersClient) Recv() (*GetLFSPointersResponse, error
 }
 
 func (c *blobServiceClient) ListLFSPointers(ctx context.Context, in *ListLFSPointersRequest, opts ...grpc.CallOption) (BlobService_ListLFSPointersClient, error) {
-	stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[4], "/gitaly.BlobService/ListLFSPointers", opts...)
+	stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[5], "/gitaly.BlobService/ListLFSPointers", opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -212,7 +247,7 @@ func (x *blobServiceListLFSPointersClient) Recv() (*ListLFSPointersResponse, err
 }
 
 func (c *blobServiceClient) ListAllLFSPointers(ctx context.Context, in *ListAllLFSPointersRequest, opts ...grpc.CallOption) (BlobService_ListAllLFSPointersClient, error) {
-	stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[5], "/gitaly.BlobService/ListAllLFSPointers", opts...)
+	stream, err := c.cc.NewStream(ctx, &BlobService_ServiceDesc.Streams[6], "/gitaly.BlobService/ListAllLFSPointers", opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -256,6 +291,9 @@ type BlobServiceServer interface {
 	// doing a graph walk. It is not valid to pass revisions which do not resolve
 	// to an existing object.
 	ListBlobs(*ListBlobsRequest, BlobService_ListBlobsServer) error
+	// ListAllBlobs retrieves all blobs pointers in the repository, including
+	// those not reachable by any reference.
+	ListAllBlobs(*ListAllBlobsRequest, BlobService_ListAllBlobsServer) error
 	// GetLFSPointers retrieves LFS pointers from a given set of object IDs.
 	// This RPC filters all requested objects and only returns those which refer
 	// to a valid LFS pointer.
@@ -286,6 +324,9 @@ func (UnimplementedBlobServiceServer) GetBlobs(*GetBlobsRequest, BlobService_Get
 func (UnimplementedBlobServiceServer) ListBlobs(*ListBlobsRequest, BlobService_ListBlobsServer) error {
 	return status.Errorf(codes.Unimplemented, "method ListBlobs not implemented")
 }
+func (UnimplementedBlobServiceServer) ListAllBlobs(*ListAllBlobsRequest, BlobService_ListAllBlobsServer) error {
+	return status.Errorf(codes.Unimplemented, "method ListAllBlobs not implemented")
+}
 func (UnimplementedBlobServiceServer) GetLFSPointers(*GetLFSPointersRequest, BlobService_GetLFSPointersServer) error {
 	return status.Errorf(codes.Unimplemented, "method GetLFSPointers not implemented")
 }
@@ -371,6 +412,27 @@ func (x *blobServiceListBlobsServer) Send(m *ListBlobsResponse) error {
 	return x.ServerStream.SendMsg(m)
 }
 
+func _BlobService_ListAllBlobs_Handler(srv interface{}, stream grpc.ServerStream) error {
+	m := new(ListAllBlobsRequest)
+	if err := stream.RecvMsg(m); err != nil {
+		return err
+	}
+	return srv.(BlobServiceServer).ListAllBlobs(m, &blobServiceListAllBlobsServer{stream})
+}
+
+type BlobService_ListAllBlobsServer interface {
+	Send(*ListAllBlobsResponse) error
+	grpc.ServerStream
+}
+
+type blobServiceListAllBlobsServer struct {
+	grpc.ServerStream
+}
+
+func (x *blobServiceListAllBlobsServer) Send(m *ListAllBlobsResponse) error {
+	return x.ServerStream.SendMsg(m)
+}
+
 func _BlobService_GetLFSPointers_Handler(srv interface{}, stream grpc.ServerStream) error {
 	m := new(GetLFSPointersRequest)
 	if err := stream.RecvMsg(m); err != nil {
@@ -458,6 +520,11 @@ var BlobService_ServiceDesc = grpc.ServiceDesc{
 			ServerStreams: true,
 		},
 		{
+			StreamName:    "ListAllBlobs",
+			Handler:       _BlobService_ListAllBlobs_Handler,
+			ServerStreams: true,
+		},
+		{
 			StreamName:    "GetLFSPointers",
 			Handler:       _BlobService_GetLFSPointers_Handler,
 			ServerStreams: true,
diff --git a/ruby/proto/gitaly/blob_pb.rb b/ruby/proto/gitaly/blob_pb.rb
index 6805ee63b..3ade3769c 100644
--- a/ruby/proto/gitaly/blob_pb.rb
+++ b/ruby/proto/gitaly/blob_pb.rb
@@ -50,6 +50,19 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
       optional :size, :int64, 2
       optional :data, :bytes, 3
     end
+    add_message "gitaly.ListAllBlobsRequest" do
+      optional :repository, :message, 1, "gitaly.Repository"
+      optional :limit, :uint32, 2
+      optional :bytes_limit, :int64, 3
+    end
+    add_message "gitaly.ListAllBlobsResponse" do
+      repeated :blobs, :message, 1, "gitaly.ListAllBlobsResponse.Blob"
+    end
+    add_message "gitaly.ListAllBlobsResponse.Blob" do
+      optional :oid, :string, 1
+      optional :size, :int64, 2
+      optional :data, :bytes, 3
+    end
     add_message "gitaly.LFSPointer" do
       optional :size, :int64, 1
       optional :data, :bytes, 2
@@ -94,6 +107,9 @@ module Gitaly
   ListBlobsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.ListBlobsRequest").msgclass
   ListBlobsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.ListBlobsResponse").msgclass
   ListBlobsResponse::Blob = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.ListBlobsResponse.Blob").msgclass
+  ListAllBlobsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.ListAllBlobsRequest").msgclass
+  ListAllBlobsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.ListAllBlobsResponse").msgclass
+  ListAllBlobsResponse::Blob = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.ListAllBlobsResponse.Blob").msgclass
   LFSPointer = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.LFSPointer").msgclass
   NewBlobObject = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.NewBlobObject").msgclass
   GetLFSPointersRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.GetLFSPointersRequest").msgclass
diff --git a/ruby/proto/gitaly/blob_services_pb.rb b/ruby/proto/gitaly/blob_services_pb.rb
index b06824da5..5eb951f5e 100644
--- a/ruby/proto/gitaly/blob_services_pb.rb
+++ b/ruby/proto/gitaly/blob_services_pb.rb
@@ -23,6 +23,9 @@ module Gitaly
       # doing a graph walk. It is not valid to pass revisions which do not resolve
       # to an existing object.
       rpc :ListBlobs, ::Gitaly::ListBlobsRequest, stream(::Gitaly::ListBlobsResponse)
+      # ListAllBlobs retrieves all blobs pointers in the repository, including
+      # those not reachable by any reference.
+      rpc :ListAllBlobs, ::Gitaly::ListAllBlobsRequest, stream(::Gitaly::ListAllBlobsResponse)
       # GetLFSPointers retrieves LFS pointers from a given set of object IDs.
       # This RPC filters all requested objects and only returns those which refer
       # to a valid LFS pointer.