Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitaly.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPatrick Steinhardt <psteinhardt@gitlab.com>2021-09-21 13:03:49 +0300
committerPatrick Steinhardt <psteinhardt@gitlab.com>2021-10-06 12:53:41 +0300
commit047b1e6afa6d3905c1432c45fd6adc545593c968 (patch)
tree42c1d6b1909a6a6624e862ad568bd906cf565c85
parent9ed7528eb5e1bb2c2a00f938264956eb37e471ae (diff)
remote: Drop FetchInternalRemote RPC
The FetchInternalRemote RPC had been used internally to replicate repositories across different Gitaly nodes. At some point in time, this was converted to do a direct fetch though without an additional RPC call because as it turned out, doing inter-Gitaly mutating RPC calls is problematic in combination with transactions given that the remote side would now try to cast votes against another Gitaly. Nowadays, there are no callers left which use this RPC. Remove the deprecated `FetchInternalRemote()` call. The backing logic which is still internally called remains though for use in other parts of Gitaly. We may eventually want to find a better place for it to live. Changelog: removed
-rw-r--r--internal/gitaly/service/remote/fetch_internal_remote.go53
-rw-r--r--internal/gitaly/service/remote/fetch_internal_remote_test.go90
-rw-r--r--internal/praefect/coordinator.go1
-rw-r--r--internal/praefect/protoregistry/protoregistry_test.go1
-rw-r--r--proto/go/gitalypb/remote.pb.go405
-rw-r--r--proto/go/gitalypb/remote_grpc.pb.go45
-rw-r--r--proto/remote.proto19
-rw-r--r--ruby/proto/gitaly/remote_pb.rb9
-rw-r--r--ruby/proto/gitaly/remote_services_pb.rb4
9 files changed, 152 insertions, 475 deletions
diff --git a/internal/gitaly/service/remote/fetch_internal_remote.go b/internal/gitaly/service/remote/fetch_internal_remote.go
index 06cd4b2dc..f4f3c3d54 100644
--- a/internal/gitaly/service/remote/fetch_internal_remote.go
+++ b/internal/gitaly/service/remote/fetch_internal_remote.go
@@ -6,7 +6,6 @@ import (
"errors"
"fmt"
- "github.com/grpc-ecosystem/go-grpc-middleware/logging/logrus/ctxlogrus"
"gitlab.com/gitlab-org/gitaly/v14/client"
"gitlab.com/gitlab-org/gitaly/v14/internal/git/localrepo"
"gitlab.com/gitlab-org/gitaly/v14/internal/git/remoterepo"
@@ -14,27 +13,12 @@ import (
"gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/service/ref"
"gitlab.com/gitlab-org/gitaly/v14/internal/helper"
"gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"
- "google.golang.org/grpc/codes"
- "google.golang.org/grpc/status"
)
const (
mirrorRefSpec = "+refs/*:refs/*"
)
-type fetchFailedError struct {
- stderr string
- err error
-}
-
-func (e fetchFailedError) Error() string {
- if e.stderr != "" {
- return fmt.Sprintf("FetchInternalRemote: fetch: %v, stderr: %q", e.err, e.stderr)
- }
-
- return fmt.Sprintf("FetchInternalRemote: fetch: %v", e.err)
-}
-
// FetchInternalRemote fetches another Gitaly repository set as a remote
func FetchInternalRemote(
ctx context.Context,
@@ -51,7 +35,7 @@ func FetchInternalRemote(
localrepo.FetchOpts{Prune: true, Stderr: &stderr},
); err != nil {
if errors.As(err, &localrepo.ErrFetchFailed{}) {
- return fetchFailedError{stderr.String(), err}
+ return fmt.Errorf("fetch: %w, stderr: %q", err, stderr.String())
}
return fmt.Errorf("fetch: %w", err)
@@ -80,38 +64,3 @@ func FetchInternalRemote(
return nil
}
-
-// FetchInternalRemote fetches another Gitaly repository set as a remote
-func (s *server) FetchInternalRemote(ctx context.Context, req *gitalypb.FetchInternalRemoteRequest) (*gitalypb.FetchInternalRemoteResponse, error) {
- if err := validateFetchInternalRemoteRequest(req); err != nil {
- return nil, status.Errorf(codes.InvalidArgument, "FetchInternalRemote: %v", err)
- }
-
- repo := s.localrepo(req.GetRepository())
-
- if err := FetchInternalRemote(ctx, s.cfg, s.conns, repo, req.RemoteRepository); err != nil {
- var fetchErr fetchFailedError
-
- if errors.As(err, &fetchErr) {
- // Design quirk: if the fetch fails, this RPC returns Result: false, but no error.
- ctxlogrus.Extract(ctx).WithError(fetchErr.err).WithField("stderr", fetchErr.stderr).Warn("git fetch failed")
- return &gitalypb.FetchInternalRemoteResponse{Result: false}, nil
- }
-
- return nil, err
- }
-
- return &gitalypb.FetchInternalRemoteResponse{Result: true}, nil
-}
-
-func validateFetchInternalRemoteRequest(req *gitalypb.FetchInternalRemoteRequest) error {
- if req.GetRepository() == nil {
- return fmt.Errorf("empty Repository")
- }
-
- if req.GetRemoteRepository() == nil {
- return fmt.Errorf("empty Remote Repository")
- }
-
- return nil
-}
diff --git a/internal/gitaly/service/remote/fetch_internal_remote_test.go b/internal/gitaly/service/remote/fetch_internal_remote_test.go
index 24a16f51c..23c5a75b1 100644
--- a/internal/gitaly/service/remote/fetch_internal_remote_test.go
+++ b/internal/gitaly/service/remote/fetch_internal_remote_test.go
@@ -12,7 +12,9 @@ import (
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
+ "gitlab.com/gitlab-org/gitaly/v14/client"
"gitlab.com/gitlab-org/gitaly/v14/internal/git/gittest"
+ "gitlab.com/gitlab-org/gitaly/v14/internal/git/localrepo"
"gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/config"
gitalyhook "gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/hook"
"gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/service"
@@ -20,12 +22,12 @@ import (
"gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/service/ref"
"gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/service/ssh"
"gitlab.com/gitlab-org/gitaly/v14/internal/gitaly/storage"
+ "gitlab.com/gitlab-org/gitaly/v14/internal/metadata"
"gitlab.com/gitlab-org/gitaly/v14/internal/testhelper"
"gitlab.com/gitlab-org/gitaly/v14/internal/testhelper/testcfg"
"gitlab.com/gitlab-org/gitaly/v14/internal/testhelper/testserver"
"gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"
"google.golang.org/grpc"
- "google.golang.org/grpc/codes"
)
// GitalySSHParams contains parameters used to exec 'gitaly-ssh' binary.
@@ -159,21 +161,17 @@ func TestFetchInternalRemote_successful(t *testing.T) {
))
}, testserver.WithDisablePraefect())
- localCfg, localRepo, localRepoPath := testcfg.BuildWithRepo(t)
+ localCfg, localRepoProto, localRepoPath := testcfg.BuildWithRepo(t)
+ localRepo := localrepo.NewTestRepo(t, localCfg, localRepoProto)
testhelper.BuildGitalySSH(t, localCfg)
testhelper.BuildGitalyHooks(t, localCfg)
gittest.Exec(t, remoteCfg, "-C", localRepoPath, "symbolic-ref", "HEAD", "refs/heads/feature")
referenceTransactionHookCalled := 0
- localAddr := testserver.RunGitalyServer(t, localCfg, nil, func(srv *grpc.Server, deps *service.Dependencies) {
- gitalypb.RegisterRemoteServiceServer(srv, NewServer(
- deps.GetCfg(),
- deps.GetLocator(),
- deps.GetGitCmdFactory(),
- deps.GetCatfileCache(),
- deps.GetTxManager(),
- ))
+ // We do not require the server's address, but it needs to be around regardless such that
+ // `FetchInternalRemote` can reach the hook service which is injected via the config.
+ testserver.RunGitalyServer(t, localCfg, nil, func(srv *grpc.Server, deps *service.Dependencies) {
gitalypb.RegisterHookServiceServer(srv, hook.NewServer(
deps.GetCfg(),
deps.GetHookManager(),
@@ -185,21 +183,16 @@ func TestFetchInternalRemote_successful(t *testing.T) {
return nil
})), testserver.WithDisablePraefect())
- client, conn := newRemoteClient(t, localAddr)
- t.Cleanup(func() { conn.Close() })
-
ctx, err := storage.InjectGitalyServers(ctx, remoteRepo.GetStorageName(), remoteAddr, "")
require.NoError(t, err)
+ ctx = metadata.OutgoingToIncoming(ctx)
getGitalySSHInvocationParams := listenGitalySSHCalls(t, localCfg)
- //nolint:staticcheck
- c, err := client.FetchInternalRemote(ctx, &gitalypb.FetchInternalRemoteRequest{
- Repository: localRepo,
- RemoteRepository: remoteRepo,
- })
- require.NoError(t, err)
- require.True(t, c.GetResult())
+ connsPool := client.NewPool()
+ defer connsPool.Close()
+
+ require.NoError(t, FetchInternalRemote(ctx, localCfg, connsPool, localRepo, remoteRepo))
require.Equal(t,
string(gittest.Exec(t, remoteCfg, "-C", remoteRepoPath, "show-ref", "--head")),
@@ -225,55 +218,20 @@ func TestFetchInternalRemote_successful(t *testing.T) {
func TestFetchInternalRemote_failure(t *testing.T) {
t.Parallel()
- cfg, repo, _, client := setupRemoteService(t)
-
- ctx, cancel := testhelper.Context()
- defer cancel()
- ctx = testhelper.MergeOutgoingMetadata(ctx, testhelper.GitalyServersMetadataFromCfg(t, cfg))
-
- // Non-existing remote repo
- remoteRepo := &gitalypb.Repository{StorageName: repo.GetStorageName(), RelativePath: "fake.git"}
-
- request := &gitalypb.FetchInternalRemoteRequest{
- Repository: repo,
- RemoteRepository: remoteRepo,
- }
-
- //nolint:staticcheck
- c, err := client.FetchInternalRemote(ctx, request)
- require.NoError(t, err, "FetchInternalRemote is not supposed to return an error when 'git fetch' fails")
- require.False(t, c.GetResult())
-}
-
-func TestFetchInternalRemote_validation(t *testing.T) {
- t.Parallel()
-
- _, repo, _, client := setupRemoteService(t)
+ cfg, repoProto, _, _ := setupRemoteService(t)
+ repo := localrepo.NewTestRepo(t, cfg, repoProto)
ctx, cancel := testhelper.Context()
defer cancel()
+ ctx = testhelper.MergeIncomingMetadata(ctx, testhelper.GitalyServersMetadataFromCfg(t, cfg))
- testCases := []struct {
- desc string
- request *gitalypb.FetchInternalRemoteRequest
- }{
- {
- desc: "empty Repository",
- request: &gitalypb.FetchInternalRemoteRequest{RemoteRepository: repo},
- },
- {
- desc: "empty Remote Repository",
- request: &gitalypb.FetchInternalRemoteRequest{Repository: repo},
- },
- }
-
- for _, tc := range testCases {
- t.Run(tc.desc, func(t *testing.T) {
- //nolint:staticcheck
- _, err := client.FetchInternalRemote(ctx, tc.request)
+ connsPool := client.NewPool()
+ defer connsPool.Close()
- testhelper.RequireGrpcError(t, err, codes.InvalidArgument)
- require.Contains(t, err.Error(), tc.desc)
- })
- }
+ err := FetchInternalRemote(ctx, cfg, connsPool, repo, &gitalypb.Repository{
+ StorageName: repoProto.GetStorageName(),
+ RelativePath: "does-not-exist.git",
+ })
+ require.Error(t, err)
+ require.Contains(t, err.Error(), "fatal: Could not read from remote repository")
}
diff --git a/internal/praefect/coordinator.go b/internal/praefect/coordinator.go
index 0cfc43782..181e3a19d 100644
--- a/internal/praefect/coordinator.go
+++ b/internal/praefect/coordinator.go
@@ -64,7 +64,6 @@ var transactionRPCs = map[string]transactionsCondition{
"/gitaly.OperationService/UserUpdateBranch": transactionsEnabled,
"/gitaly.OperationService/UserUpdateSubmodule": transactionsEnabled,
"/gitaly.RefService/DeleteRefs": transactionsEnabled,
- "/gitaly.RemoteService/FetchInternalRemote": transactionsEnabled,
"/gitaly.RepositoryService/ApplyGitattributes": transactionsEnabled,
"/gitaly.RepositoryService/CloneFromPool": transactionsEnabled,
"/gitaly.RepositoryService/CloneFromPoolInternal": transactionsEnabled,
diff --git a/internal/praefect/protoregistry/protoregistry_test.go b/internal/praefect/protoregistry/protoregistry_test.go
index 515c13e3d..dad50cc76 100644
--- a/internal/praefect/protoregistry/protoregistry_test.go
+++ b/internal/praefect/protoregistry/protoregistry_test.go
@@ -99,7 +99,6 @@ func TestNewProtoRegistry(t *testing.T) {
"PackRefs": protoregistry.OpMutator,
},
"RemoteService": {
- "FetchInternalRemote": protoregistry.OpMutator,
"UpdateRemoteMirror": protoregistry.OpAccessor,
"FindRemoteRepository": protoregistry.OpAccessor,
"FindRemoteRootRef": protoregistry.OpAccessor,
diff --git a/proto/go/gitalypb/remote.pb.go b/proto/go/gitalypb/remote.pb.go
index b59e8c04a..3267df36a 100644
--- a/proto/go/gitalypb/remote.pb.go
+++ b/proto/go/gitalypb/remote.pb.go
@@ -20,108 +20,6 @@ const (
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
-type FetchInternalRemoteRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Repository *Repository `protobuf:"bytes,1,opt,name=repository,proto3" json:"repository,omitempty"`
- RemoteRepository *Repository `protobuf:"bytes,2,opt,name=remote_repository,json=remoteRepository,proto3" json:"remote_repository,omitempty"`
-}
-
-func (x *FetchInternalRemoteRequest) Reset() {
- *x = FetchInternalRemoteRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[0]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
-}
-
-func (x *FetchInternalRemoteRequest) String() string {
- return protoimpl.X.MessageStringOf(x)
-}
-
-func (*FetchInternalRemoteRequest) ProtoMessage() {}
-
-func (x *FetchInternalRemoteRequest) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[0]
- 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 FetchInternalRemoteRequest.ProtoReflect.Descriptor instead.
-func (*FetchInternalRemoteRequest) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{0}
-}
-
-func (x *FetchInternalRemoteRequest) GetRepository() *Repository {
- if x != nil {
- return x.Repository
- }
- return nil
-}
-
-func (x *FetchInternalRemoteRequest) GetRemoteRepository() *Repository {
- if x != nil {
- return x.RemoteRepository
- }
- return nil
-}
-
-type FetchInternalRemoteResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
- Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
-}
-
-func (x *FetchInternalRemoteResponse) Reset() {
- *x = FetchInternalRemoteResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[1]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
-}
-
-func (x *FetchInternalRemoteResponse) String() string {
- return protoimpl.X.MessageStringOf(x)
-}
-
-func (*FetchInternalRemoteResponse) ProtoMessage() {}
-
-func (x *FetchInternalRemoteResponse) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[1]
- 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 FetchInternalRemoteResponse.ProtoReflect.Descriptor instead.
-func (*FetchInternalRemoteResponse) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{1}
-}
-
-func (x *FetchInternalRemoteResponse) GetResult() bool {
- if x != nil {
- return x.Result
- }
- return false
-}
-
type UpdateRemoteMirrorRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
@@ -154,7 +52,7 @@ type UpdateRemoteMirrorRequest struct {
func (x *UpdateRemoteMirrorRequest) Reset() {
*x = UpdateRemoteMirrorRequest{}
if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[2]
+ mi := &file_remote_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -167,7 +65,7 @@ func (x *UpdateRemoteMirrorRequest) String() string {
func (*UpdateRemoteMirrorRequest) ProtoMessage() {}
func (x *UpdateRemoteMirrorRequest) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[2]
+ mi := &file_remote_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -180,7 +78,7 @@ func (x *UpdateRemoteMirrorRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use UpdateRemoteMirrorRequest.ProtoReflect.Descriptor instead.
func (*UpdateRemoteMirrorRequest) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{2}
+ return file_remote_proto_rawDescGZIP(), []int{0}
}
func (x *UpdateRemoteMirrorRequest) GetRepository() *Repository {
@@ -238,7 +136,7 @@ type UpdateRemoteMirrorResponse struct {
func (x *UpdateRemoteMirrorResponse) Reset() {
*x = UpdateRemoteMirrorResponse{}
if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[3]
+ mi := &file_remote_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -251,7 +149,7 @@ func (x *UpdateRemoteMirrorResponse) String() string {
func (*UpdateRemoteMirrorResponse) ProtoMessage() {}
func (x *UpdateRemoteMirrorResponse) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[3]
+ mi := &file_remote_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -264,7 +162,7 @@ func (x *UpdateRemoteMirrorResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use UpdateRemoteMirrorResponse.ProtoReflect.Descriptor instead.
func (*UpdateRemoteMirrorResponse) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{3}
+ return file_remote_proto_rawDescGZIP(), []int{1}
}
func (x *UpdateRemoteMirrorResponse) GetDivergentRefs() [][]byte {
@@ -289,7 +187,7 @@ type FindRemoteRepositoryRequest struct {
func (x *FindRemoteRepositoryRequest) Reset() {
*x = FindRemoteRepositoryRequest{}
if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[4]
+ mi := &file_remote_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -302,7 +200,7 @@ func (x *FindRemoteRepositoryRequest) String() string {
func (*FindRemoteRepositoryRequest) ProtoMessage() {}
func (x *FindRemoteRepositoryRequest) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[4]
+ mi := &file_remote_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -315,7 +213,7 @@ func (x *FindRemoteRepositoryRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use FindRemoteRepositoryRequest.ProtoReflect.Descriptor instead.
func (*FindRemoteRepositoryRequest) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{4}
+ return file_remote_proto_rawDescGZIP(), []int{2}
}
func (x *FindRemoteRepositoryRequest) GetRemote() string {
@@ -345,7 +243,7 @@ type FindRemoteRepositoryResponse struct {
func (x *FindRemoteRepositoryResponse) Reset() {
*x = FindRemoteRepositoryResponse{}
if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[5]
+ mi := &file_remote_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -358,7 +256,7 @@ func (x *FindRemoteRepositoryResponse) String() string {
func (*FindRemoteRepositoryResponse) ProtoMessage() {}
func (x *FindRemoteRepositoryResponse) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[5]
+ mi := &file_remote_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -371,7 +269,7 @@ func (x *FindRemoteRepositoryResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use FindRemoteRepositoryResponse.ProtoReflect.Descriptor instead.
func (*FindRemoteRepositoryResponse) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{5}
+ return file_remote_proto_rawDescGZIP(), []int{3}
}
func (x *FindRemoteRepositoryResponse) GetExists() bool {
@@ -401,7 +299,7 @@ type FindRemoteRootRefRequest struct {
func (x *FindRemoteRootRefRequest) Reset() {
*x = FindRemoteRootRefRequest{}
if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[6]
+ mi := &file_remote_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -414,7 +312,7 @@ func (x *FindRemoteRootRefRequest) String() string {
func (*FindRemoteRootRefRequest) ProtoMessage() {}
func (x *FindRemoteRootRefRequest) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[6]
+ mi := &file_remote_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -427,7 +325,7 @@ func (x *FindRemoteRootRefRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use FindRemoteRootRefRequest.ProtoReflect.Descriptor instead.
func (*FindRemoteRootRefRequest) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{6}
+ return file_remote_proto_rawDescGZIP(), []int{4}
}
func (x *FindRemoteRootRefRequest) GetRepository() *Repository {
@@ -465,7 +363,7 @@ type FindRemoteRootRefResponse struct {
func (x *FindRemoteRootRefResponse) Reset() {
*x = FindRemoteRootRefResponse{}
if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[7]
+ mi := &file_remote_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -478,7 +376,7 @@ func (x *FindRemoteRootRefResponse) String() string {
func (*FindRemoteRootRefResponse) ProtoMessage() {}
func (x *FindRemoteRootRefResponse) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[7]
+ mi := &file_remote_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -491,7 +389,7 @@ func (x *FindRemoteRootRefResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use FindRemoteRootRefResponse.ProtoReflect.Descriptor instead.
func (*FindRemoteRootRefResponse) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{7}
+ return file_remote_proto_rawDescGZIP(), []int{5}
}
func (x *FindRemoteRootRefResponse) GetRef() string {
@@ -516,7 +414,7 @@ type UpdateRemoteMirrorRequest_Remote struct {
func (x *UpdateRemoteMirrorRequest_Remote) Reset() {
*x = UpdateRemoteMirrorRequest_Remote{}
if protoimpl.UnsafeEnabled {
- mi := &file_remote_proto_msgTypes[8]
+ mi := &file_remote_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -529,7 +427,7 @@ func (x *UpdateRemoteMirrorRequest_Remote) String() string {
func (*UpdateRemoteMirrorRequest_Remote) ProtoMessage() {}
func (x *UpdateRemoteMirrorRequest_Remote) ProtoReflect() protoreflect.Message {
- mi := &file_remote_proto_msgTypes[8]
+ mi := &file_remote_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -542,7 +440,7 @@ func (x *UpdateRemoteMirrorRequest_Remote) ProtoReflect() protoreflect.Message {
// Deprecated: Use UpdateRemoteMirrorRequest_Remote.ProtoReflect.Descriptor instead.
func (*UpdateRemoteMirrorRequest_Remote) Descriptor() ([]byte, []int) {
- return file_remote_proto_rawDescGZIP(), []int{2, 0}
+ return file_remote_proto_rawDescGZIP(), []int{0, 0}
}
func (x *UpdateRemoteMirrorRequest_Remote) GetUrl() string {
@@ -565,105 +463,86 @@ var file_remote_proto_rawDesc = []byte{
0x0a, 0x0c, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x06,
0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x1a, 0x0a, 0x6c, 0x69, 0x6e, 0x74, 0x2e, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x1a, 0x0c, 0x73, 0x68, 0x61, 0x72, 0x65, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
- 0x22, 0x97, 0x01, 0x0a, 0x1a, 0x46, 0x65, 0x74, 0x63, 0x68, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e,
- 0x61, 0x6c, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 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, 0x3f, 0x0a, 0x11, 0x72, 0x65, 0x6d,
- 0x6f, 0x74, 0x65, 0x5f, 0x72, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x18, 0x02,
- 0x20, 0x01, 0x28, 0x0b, 0x32, 0x12, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x52, 0x65,
- 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x52, 0x10, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65,
- 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x22, 0x35, 0x0a, 0x1b, 0x46, 0x65,
- 0x74, 0x63, 0x68, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x52, 0x65, 0x6d, 0x6f, 0x74,
- 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x73,
- 0x75, 0x6c, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x72, 0x65, 0x73, 0x75, 0x6c,
- 0x74, 0x22, 0x9f, 0x03, 0x0a, 0x19, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f,
- 0x74, 0x65, 0x4d, 0x69, 0x72, 0x72, 0x6f, 0x72, 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, 0x40, 0x0a, 0x06, 0x72, 0x65, 0x6d,
- 0x6f, 0x74, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 0x69, 0x74, 0x61,
- 0x6c, 0x79, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x4d,
- 0x69, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x52, 0x65, 0x6d,
- 0x6f, 0x74, 0x65, 0x52, 0x06, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x12, 0x34, 0x0a, 0x16, 0x6f,
- 0x6e, 0x6c, 0x79, 0x5f, 0x62, 0x72, 0x61, 0x6e, 0x63, 0x68, 0x65, 0x73, 0x5f, 0x6d, 0x61, 0x74,
- 0x63, 0x68, 0x69, 0x6e, 0x67, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0c, 0x52, 0x14, 0x6f, 0x6e, 0x6c,
- 0x79, 0x42, 0x72, 0x61, 0x6e, 0x63, 0x68, 0x65, 0x73, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x69, 0x6e,
- 0x67, 0x12, 0x17, 0x0a, 0x07, 0x73, 0x73, 0x68, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x04, 0x20, 0x01,
- 0x28, 0x09, 0x52, 0x06, 0x73, 0x73, 0x68, 0x4b, 0x65, 0x79, 0x12, 0x1f, 0x0a, 0x0b, 0x6b, 0x6e,
- 0x6f, 0x77, 0x6e, 0x5f, 0x68, 0x6f, 0x73, 0x74, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52,
- 0x0a, 0x6b, 0x6e, 0x6f, 0x77, 0x6e, 0x48, 0x6f, 0x73, 0x74, 0x73, 0x12, 0x2e, 0x0a, 0x13, 0x6b,
- 0x65, 0x65, 0x70, 0x5f, 0x64, 0x69, 0x76, 0x65, 0x72, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x72, 0x65,
- 0x66, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x11, 0x6b, 0x65, 0x65, 0x70, 0x44, 0x69,
- 0x76, 0x65, 0x72, 0x67, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x66, 0x73, 0x1a, 0x56, 0x0a, 0x06, 0x52,
- 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x75, 0x72, 0x6c, 0x18, 0x01, 0x20, 0x01,
- 0x28, 0x09, 0x52, 0x03, 0x75, 0x72, 0x6c, 0x12, 0x3a, 0x0a, 0x19, 0x68, 0x74, 0x74, 0x70, 0x5f,
- 0x61, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x68, 0x65,
- 0x61, 0x64, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x17, 0x68, 0x74, 0x74, 0x70,
- 0x41, 0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x48, 0x65, 0x61,
- 0x64, 0x65, 0x72, 0x4a, 0x04, 0x08, 0x02, 0x10, 0x03, 0x52, 0x08, 0x72, 0x65, 0x66, 0x5f, 0x6e,
- 0x61, 0x6d, 0x65, 0x22, 0x43, 0x0a, 0x1a, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d,
- 0x6f, 0x74, 0x65, 0x4d, 0x69, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
- 0x65, 0x12, 0x25, 0x0a, 0x0e, 0x64, 0x69, 0x76, 0x65, 0x72, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x72,
- 0x65, 0x66, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0c, 0x52, 0x0d, 0x64, 0x69, 0x76, 0x65, 0x72,
- 0x67, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x66, 0x73, 0x22, 0x5e, 0x0a, 0x1b, 0x46, 0x69, 0x6e, 0x64,
- 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79,
- 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x6d, 0x6f, 0x74,
- 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x12,
- 0x27, 0x0a, 0x0c, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18,
- 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x04, 0x88, 0xc6, 0x2c, 0x01, 0x52, 0x0b, 0x73, 0x74, 0x6f,
- 0x72, 0x61, 0x67, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x36, 0x0a, 0x1c, 0x46, 0x69, 0x6e, 0x64,
- 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79,
- 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x65, 0x78, 0x69, 0x73,
- 0x74, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x65, 0x78, 0x69, 0x73, 0x74, 0x73,
- 0x22, 0xbd, 0x01, 0x0a, 0x18, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52,
- 0x6f, 0x6f, 0x74, 0x52, 0x65, 0x66, 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, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x6d, 0x6f, 0x74,
- 0x65, 0x5f, 0x75, 0x72, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x6d,
- 0x6f, 0x74, 0x65, 0x55, 0x72, 0x6c, 0x12, 0x3a, 0x0a, 0x19, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x61,
+ 0x22, 0x9f, 0x03, 0x0a, 0x19, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f, 0x74,
+ 0x65, 0x4d, 0x69, 0x72, 0x72, 0x6f, 0x72, 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, 0x40, 0x0a, 0x06, 0x72, 0x65, 0x6d, 0x6f,
+ 0x74, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x28, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c,
+ 0x79, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x4d, 0x69,
+ 0x72, 0x72, 0x6f, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x52, 0x65, 0x6d, 0x6f,
+ 0x74, 0x65, 0x52, 0x06, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x12, 0x34, 0x0a, 0x16, 0x6f, 0x6e,
+ 0x6c, 0x79, 0x5f, 0x62, 0x72, 0x61, 0x6e, 0x63, 0x68, 0x65, 0x73, 0x5f, 0x6d, 0x61, 0x74, 0x63,
+ 0x68, 0x69, 0x6e, 0x67, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0c, 0x52, 0x14, 0x6f, 0x6e, 0x6c, 0x79,
+ 0x42, 0x72, 0x61, 0x6e, 0x63, 0x68, 0x65, 0x73, 0x4d, 0x61, 0x74, 0x63, 0x68, 0x69, 0x6e, 0x67,
+ 0x12, 0x17, 0x0a, 0x07, 0x73, 0x73, 0x68, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x04, 0x20, 0x01, 0x28,
+ 0x09, 0x52, 0x06, 0x73, 0x73, 0x68, 0x4b, 0x65, 0x79, 0x12, 0x1f, 0x0a, 0x0b, 0x6b, 0x6e, 0x6f,
+ 0x77, 0x6e, 0x5f, 0x68, 0x6f, 0x73, 0x74, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a,
+ 0x6b, 0x6e, 0x6f, 0x77, 0x6e, 0x48, 0x6f, 0x73, 0x74, 0x73, 0x12, 0x2e, 0x0a, 0x13, 0x6b, 0x65,
+ 0x65, 0x70, 0x5f, 0x64, 0x69, 0x76, 0x65, 0x72, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x72, 0x65, 0x66,
+ 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x11, 0x6b, 0x65, 0x65, 0x70, 0x44, 0x69, 0x76,
+ 0x65, 0x72, 0x67, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x66, 0x73, 0x1a, 0x56, 0x0a, 0x06, 0x52, 0x65,
+ 0x6d, 0x6f, 0x74, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x75, 0x72, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28,
+ 0x09, 0x52, 0x03, 0x75, 0x72, 0x6c, 0x12, 0x3a, 0x0a, 0x19, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x61,
0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x68, 0x65, 0x61,
- 0x64, 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x17, 0x68, 0x74, 0x74, 0x70, 0x41,
+ 0x64, 0x65, 0x72, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x17, 0x68, 0x74, 0x74, 0x70, 0x41,
0x75, 0x74, 0x68, 0x6f, 0x72, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x48, 0x65, 0x61, 0x64,
- 0x65, 0x72, 0x4a, 0x04, 0x08, 0x02, 0x10, 0x03, 0x52, 0x06, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65,
- 0x22, 0x2d, 0x0a, 0x19, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x6f,
- 0x6f, 0x74, 0x52, 0x65, 0x66, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a,
- 0x03, 0x72, 0x65, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x72, 0x65, 0x66, 0x32,
- 0xb0, 0x03, 0x0a, 0x0d, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63,
- 0x65, 0x12, 0x69, 0x0a, 0x13, 0x46, 0x65, 0x74, 0x63, 0x68, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e,
- 0x61, 0x6c, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x12, 0x22, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c,
- 0x79, 0x2e, 0x46, 0x65, 0x74, 0x63, 0x68, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x52,
- 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67,
- 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x46, 0x65, 0x74, 0x63, 0x68, 0x49, 0x6e, 0x74, 0x65, 0x72,
- 0x6e, 0x61, 0x6c, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73,
- 0x65, 0x22, 0x09, 0x88, 0x02, 0x01, 0xfa, 0x97, 0x28, 0x02, 0x08, 0x01, 0x12, 0x65, 0x0a, 0x12,
+ 0x65, 0x72, 0x4a, 0x04, 0x08, 0x02, 0x10, 0x03, 0x52, 0x08, 0x72, 0x65, 0x66, 0x5f, 0x6e, 0x61,
+ 0x6d, 0x65, 0x22, 0x43, 0x0a, 0x1a, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f,
+ 0x74, 0x65, 0x4d, 0x69, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
+ 0x12, 0x25, 0x0a, 0x0e, 0x64, 0x69, 0x76, 0x65, 0x72, 0x67, 0x65, 0x6e, 0x74, 0x5f, 0x72, 0x65,
+ 0x66, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0c, 0x52, 0x0d, 0x64, 0x69, 0x76, 0x65, 0x72, 0x67,
+ 0x65, 0x6e, 0x74, 0x52, 0x65, 0x66, 0x73, 0x22, 0x5e, 0x0a, 0x1b, 0x46, 0x69, 0x6e, 0x64, 0x52,
+ 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x52,
+ 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65,
+ 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x12, 0x27,
+ 0x0a, 0x0c, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02,
+ 0x20, 0x01, 0x28, 0x09, 0x42, 0x04, 0x88, 0xc6, 0x2c, 0x01, 0x52, 0x0b, 0x73, 0x74, 0x6f, 0x72,
+ 0x61, 0x67, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x36, 0x0a, 0x1c, 0x46, 0x69, 0x6e, 0x64, 0x52,
+ 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x52,
+ 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x65, 0x78, 0x69, 0x73, 0x74,
+ 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x65, 0x78, 0x69, 0x73, 0x74, 0x73, 0x22,
+ 0xbd, 0x01, 0x0a, 0x18, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x6f,
+ 0x6f, 0x74, 0x52, 0x65, 0x66, 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, 0x1d, 0x0a, 0x0a, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65,
+ 0x5f, 0x75, 0x72, 0x6c, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x6d, 0x6f,
+ 0x74, 0x65, 0x55, 0x72, 0x6c, 0x12, 0x3a, 0x0a, 0x19, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x61, 0x75,
+ 0x74, 0x68, 0x6f, 0x72, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x68, 0x65, 0x61, 0x64,
+ 0x65, 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x17, 0x68, 0x74, 0x74, 0x70, 0x41, 0x75,
+ 0x74, 0x68, 0x6f, 0x72, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x48, 0x65, 0x61, 0x64, 0x65,
+ 0x72, 0x4a, 0x04, 0x08, 0x02, 0x10, 0x03, 0x52, 0x06, 0x72, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x22,
+ 0x2d, 0x0a, 0x19, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x6f, 0x6f,
+ 0x74, 0x52, 0x65, 0x66, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x10, 0x0a, 0x03,
+ 0x72, 0x65, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x72, 0x65, 0x66, 0x32, 0xc5,
+ 0x02, 0x0a, 0x0d, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
+ 0x12, 0x65, 0x0a, 0x12, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65,
+ 0x4d, 0x69, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x21, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e,
0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x4d, 0x69, 0x72, 0x72,
- 0x6f, 0x72, 0x12, 0x21, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x55, 0x70, 0x64, 0x61,
- 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x4d, 0x69, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x65,
- 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x55,
- 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x4d, 0x69, 0x72, 0x72, 0x6f,
- 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02, 0x08,
- 0x02, 0x28, 0x01, 0x12, 0x6b, 0x0a, 0x14, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74,
- 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x12, 0x23, 0x2e, 0x67, 0x69,
+ 0x6f, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x22, 0x2e, 0x67, 0x69, 0x74, 0x61,
+ 0x6c, 0x79, 0x2e, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x4d,
+ 0x69, 0x72, 0x72, 0x6f, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa,
+ 0x97, 0x28, 0x02, 0x08, 0x02, 0x28, 0x01, 0x12, 0x6b, 0x0a, 0x14, 0x46, 0x69, 0x6e, 0x64, 0x52,
+ 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x12,
+ 0x23, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d,
+ 0x6f, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x52, 0x65, 0x71,
+ 0x75, 0x65, 0x73, 0x74, 0x1a, 0x24, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x46, 0x69,
+ 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f,
+ 0x72, 0x79, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x08, 0xfa, 0x97, 0x28, 0x04,
+ 0x08, 0x02, 0x10, 0x02, 0x12, 0x60, 0x0a, 0x11, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f,
+ 0x74, 0x65, 0x52, 0x6f, 0x6f, 0x74, 0x52, 0x65, 0x66, 0x12, 0x20, 0x2e, 0x67, 0x69, 0x74, 0x61,
+ 0x6c, 0x79, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x6f, 0x6f,
+ 0x74, 0x52, 0x65, 0x66, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x69,
0x74, 0x61, 0x6c, 0x79, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52,
- 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
- 0x1a, 0x24, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65,
- 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x65, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x6f, 0x72, 0x79, 0x52, 0x65,
- 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x08, 0xfa, 0x97, 0x28, 0x04, 0x08, 0x02, 0x10, 0x02,
- 0x12, 0x60, 0x0a, 0x11, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x6f,
- 0x6f, 0x74, 0x52, 0x65, 0x66, 0x12, 0x20, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x46,
- 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x6f, 0x6f, 0x74, 0x52, 0x65, 0x66,
- 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x21, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79,
- 0x2e, 0x46, 0x69, 0x6e, 0x64, 0x52, 0x65, 0x6d, 0x6f, 0x74, 0x65, 0x52, 0x6f, 0x6f, 0x74, 0x52,
- 0x65, 0x66, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06, 0xfa, 0x97, 0x28, 0x02,
- 0x08, 0x02, 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,
+ 0x6f, 0x6f, 0x74, 0x52, 0x65, 0x66, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x06,
+ 0xfa, 0x97, 0x28, 0x02, 0x08, 0x02, 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 (
@@ -678,38 +557,32 @@ func file_remote_proto_rawDescGZIP() []byte {
return file_remote_proto_rawDescData
}
-var file_remote_proto_msgTypes = make([]protoimpl.MessageInfo, 9)
+var file_remote_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
var file_remote_proto_goTypes = []interface{}{
- (*FetchInternalRemoteRequest)(nil), // 0: gitaly.FetchInternalRemoteRequest
- (*FetchInternalRemoteResponse)(nil), // 1: gitaly.FetchInternalRemoteResponse
- (*UpdateRemoteMirrorRequest)(nil), // 2: gitaly.UpdateRemoteMirrorRequest
- (*UpdateRemoteMirrorResponse)(nil), // 3: gitaly.UpdateRemoteMirrorResponse
- (*FindRemoteRepositoryRequest)(nil), // 4: gitaly.FindRemoteRepositoryRequest
- (*FindRemoteRepositoryResponse)(nil), // 5: gitaly.FindRemoteRepositoryResponse
- (*FindRemoteRootRefRequest)(nil), // 6: gitaly.FindRemoteRootRefRequest
- (*FindRemoteRootRefResponse)(nil), // 7: gitaly.FindRemoteRootRefResponse
- (*UpdateRemoteMirrorRequest_Remote)(nil), // 8: gitaly.UpdateRemoteMirrorRequest.Remote
- (*Repository)(nil), // 9: gitaly.Repository
+ (*UpdateRemoteMirrorRequest)(nil), // 0: gitaly.UpdateRemoteMirrorRequest
+ (*UpdateRemoteMirrorResponse)(nil), // 1: gitaly.UpdateRemoteMirrorResponse
+ (*FindRemoteRepositoryRequest)(nil), // 2: gitaly.FindRemoteRepositoryRequest
+ (*FindRemoteRepositoryResponse)(nil), // 3: gitaly.FindRemoteRepositoryResponse
+ (*FindRemoteRootRefRequest)(nil), // 4: gitaly.FindRemoteRootRefRequest
+ (*FindRemoteRootRefResponse)(nil), // 5: gitaly.FindRemoteRootRefResponse
+ (*UpdateRemoteMirrorRequest_Remote)(nil), // 6: gitaly.UpdateRemoteMirrorRequest.Remote
+ (*Repository)(nil), // 7: gitaly.Repository
}
var file_remote_proto_depIdxs = []int32{
- 9, // 0: gitaly.FetchInternalRemoteRequest.repository:type_name -> gitaly.Repository
- 9, // 1: gitaly.FetchInternalRemoteRequest.remote_repository:type_name -> gitaly.Repository
- 9, // 2: gitaly.UpdateRemoteMirrorRequest.repository:type_name -> gitaly.Repository
- 8, // 3: gitaly.UpdateRemoteMirrorRequest.remote:type_name -> gitaly.UpdateRemoteMirrorRequest.Remote
- 9, // 4: gitaly.FindRemoteRootRefRequest.repository:type_name -> gitaly.Repository
- 0, // 5: gitaly.RemoteService.FetchInternalRemote:input_type -> gitaly.FetchInternalRemoteRequest
- 2, // 6: gitaly.RemoteService.UpdateRemoteMirror:input_type -> gitaly.UpdateRemoteMirrorRequest
- 4, // 7: gitaly.RemoteService.FindRemoteRepository:input_type -> gitaly.FindRemoteRepositoryRequest
- 6, // 8: gitaly.RemoteService.FindRemoteRootRef:input_type -> gitaly.FindRemoteRootRefRequest
- 1, // 9: gitaly.RemoteService.FetchInternalRemote:output_type -> gitaly.FetchInternalRemoteResponse
- 3, // 10: gitaly.RemoteService.UpdateRemoteMirror:output_type -> gitaly.UpdateRemoteMirrorResponse
- 5, // 11: gitaly.RemoteService.FindRemoteRepository:output_type -> gitaly.FindRemoteRepositoryResponse
- 7, // 12: gitaly.RemoteService.FindRemoteRootRef:output_type -> gitaly.FindRemoteRootRefResponse
- 9, // [9:13] is the sub-list for method output_type
- 5, // [5:9] is the sub-list for method input_type
- 5, // [5:5] is the sub-list for extension type_name
- 5, // [5:5] is the sub-list for extension extendee
- 0, // [0:5] is the sub-list for field type_name
+ 7, // 0: gitaly.UpdateRemoteMirrorRequest.repository:type_name -> gitaly.Repository
+ 6, // 1: gitaly.UpdateRemoteMirrorRequest.remote:type_name -> gitaly.UpdateRemoteMirrorRequest.Remote
+ 7, // 2: gitaly.FindRemoteRootRefRequest.repository:type_name -> gitaly.Repository
+ 0, // 3: gitaly.RemoteService.UpdateRemoteMirror:input_type -> gitaly.UpdateRemoteMirrorRequest
+ 2, // 4: gitaly.RemoteService.FindRemoteRepository:input_type -> gitaly.FindRemoteRepositoryRequest
+ 4, // 5: gitaly.RemoteService.FindRemoteRootRef:input_type -> gitaly.FindRemoteRootRefRequest
+ 1, // 6: gitaly.RemoteService.UpdateRemoteMirror:output_type -> gitaly.UpdateRemoteMirrorResponse
+ 3, // 7: gitaly.RemoteService.FindRemoteRepository:output_type -> gitaly.FindRemoteRepositoryResponse
+ 5, // 8: gitaly.RemoteService.FindRemoteRootRef:output_type -> gitaly.FindRemoteRootRefResponse
+ 6, // [6:9] is the sub-list for method output_type
+ 3, // [3:6] is the sub-list for method input_type
+ 3, // [3:3] is the sub-list for extension type_name
+ 3, // [3:3] is the sub-list for extension extendee
+ 0, // [0:3] is the sub-list for field type_name
}
func init() { file_remote_proto_init() }
@@ -721,30 +594,6 @@ func file_remote_proto_init() {
file_shared_proto_init()
if !protoimpl.UnsafeEnabled {
file_remote_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*FetchInternalRemoteRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_remote_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
- switch v := v.(*FetchInternalRemoteResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_remote_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*UpdateRemoteMirrorRequest); i {
case 0:
return &v.state
@@ -756,7 +605,7 @@ func file_remote_proto_init() {
return nil
}
}
- file_remote_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
+ file_remote_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*UpdateRemoteMirrorResponse); i {
case 0:
return &v.state
@@ -768,7 +617,7 @@ func file_remote_proto_init() {
return nil
}
}
- file_remote_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
+ file_remote_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*FindRemoteRepositoryRequest); i {
case 0:
return &v.state
@@ -780,7 +629,7 @@ func file_remote_proto_init() {
return nil
}
}
- file_remote_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
+ file_remote_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*FindRemoteRepositoryResponse); i {
case 0:
return &v.state
@@ -792,7 +641,7 @@ func file_remote_proto_init() {
return nil
}
}
- file_remote_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
+ file_remote_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*FindRemoteRootRefRequest); i {
case 0:
return &v.state
@@ -804,7 +653,7 @@ func file_remote_proto_init() {
return nil
}
}
- file_remote_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
+ file_remote_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*FindRemoteRootRefResponse); i {
case 0:
return &v.state
@@ -816,7 +665,7 @@ func file_remote_proto_init() {
return nil
}
}
- file_remote_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
+ file_remote_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*UpdateRemoteMirrorRequest_Remote); i {
case 0:
return &v.state
@@ -835,7 +684,7 @@ func file_remote_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_remote_proto_rawDesc,
NumEnums: 0,
- NumMessages: 9,
+ NumMessages: 7,
NumExtensions: 0,
NumServices: 1,
},
diff --git a/proto/go/gitalypb/remote_grpc.pb.go b/proto/go/gitalypb/remote_grpc.pb.go
index c512051f9..f97b453a5 100644
--- a/proto/go/gitalypb/remote_grpc.pb.go
+++ b/proto/go/gitalypb/remote_grpc.pb.go
@@ -18,11 +18,6 @@ const _ = grpc.SupportPackageIsVersion7
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type RemoteServiceClient interface {
- // Deprecated: Do not use.
- // FetchInternalRemote used to fetch changes from a remote repository into
- // the target repository. This RPC call is deprecated and shouldn't be used
- // at all anymore. It will be removed in release v14.4.
- FetchInternalRemote(ctx context.Context, in *FetchInternalRemoteRequest, opts ...grpc.CallOption) (*FetchInternalRemoteResponse, error)
// UpdateRemoteMirror compares the references in the target repository and its remote mirror
// repository. Any differences in the references are then addressed by pushing the differing
// references to the mirror. Created and modified references are updated, removed references are
@@ -46,16 +41,6 @@ func NewRemoteServiceClient(cc grpc.ClientConnInterface) RemoteServiceClient {
return &remoteServiceClient{cc}
}
-// Deprecated: Do not use.
-func (c *remoteServiceClient) FetchInternalRemote(ctx context.Context, in *FetchInternalRemoteRequest, opts ...grpc.CallOption) (*FetchInternalRemoteResponse, error) {
- out := new(FetchInternalRemoteResponse)
- err := c.cc.Invoke(ctx, "/gitaly.RemoteService/FetchInternalRemote", in, out, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
-}
-
func (c *remoteServiceClient) UpdateRemoteMirror(ctx context.Context, opts ...grpc.CallOption) (RemoteService_UpdateRemoteMirrorClient, error) {
stream, err := c.cc.NewStream(ctx, &RemoteService_ServiceDesc.Streams[0], "/gitaly.RemoteService/UpdateRemoteMirror", opts...)
if err != nil {
@@ -112,11 +97,6 @@ func (c *remoteServiceClient) FindRemoteRootRef(ctx context.Context, in *FindRem
// All implementations must embed UnimplementedRemoteServiceServer
// for forward compatibility
type RemoteServiceServer interface {
- // Deprecated: Do not use.
- // FetchInternalRemote used to fetch changes from a remote repository into
- // the target repository. This RPC call is deprecated and shouldn't be used
- // at all anymore. It will be removed in release v14.4.
- FetchInternalRemote(context.Context, *FetchInternalRemoteRequest) (*FetchInternalRemoteResponse, error)
// UpdateRemoteMirror compares the references in the target repository and its remote mirror
// repository. Any differences in the references are then addressed by pushing the differing
// references to the mirror. Created and modified references are updated, removed references are
@@ -137,9 +117,6 @@ type RemoteServiceServer interface {
type UnimplementedRemoteServiceServer struct {
}
-func (UnimplementedRemoteServiceServer) FetchInternalRemote(context.Context, *FetchInternalRemoteRequest) (*FetchInternalRemoteResponse, error) {
- return nil, status.Errorf(codes.Unimplemented, "method FetchInternalRemote not implemented")
-}
func (UnimplementedRemoteServiceServer) UpdateRemoteMirror(RemoteService_UpdateRemoteMirrorServer) error {
return status.Errorf(codes.Unimplemented, "method UpdateRemoteMirror not implemented")
}
@@ -162,24 +139,6 @@ func RegisterRemoteServiceServer(s grpc.ServiceRegistrar, srv RemoteServiceServe
s.RegisterService(&RemoteService_ServiceDesc, srv)
}
-func _RemoteService_FetchInternalRemote_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(FetchInternalRemoteRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(RemoteServiceServer).FetchInternalRemote(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/gitaly.RemoteService/FetchInternalRemote",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(RemoteServiceServer).FetchInternalRemote(ctx, req.(*FetchInternalRemoteRequest))
- }
- return interceptor(ctx, in, info, handler)
-}
-
func _RemoteService_UpdateRemoteMirror_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(RemoteServiceServer).UpdateRemoteMirror(&remoteServiceUpdateRemoteMirrorServer{stream})
}
@@ -250,10 +209,6 @@ var RemoteService_ServiceDesc = grpc.ServiceDesc{
HandlerType: (*RemoteServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
- MethodName: "FetchInternalRemote",
- Handler: _RemoteService_FetchInternalRemote_Handler,
- },
- {
MethodName: "FindRemoteRepository",
Handler: _RemoteService_FindRemoteRepository_Handler,
},
diff --git a/proto/remote.proto b/proto/remote.proto
index 5d58671d3..24cd0d2c1 100644
--- a/proto/remote.proto
+++ b/proto/remote.proto
@@ -9,16 +9,6 @@ import "shared.proto";
service RemoteService {
- // FetchInternalRemote used to fetch changes from a remote repository into
- // the target repository. This RPC call is deprecated and shouldn't be used
- // at all anymore. It will be removed in release v14.4.
- rpc FetchInternalRemote(FetchInternalRemoteRequest) returns (FetchInternalRemoteResponse) {
- option deprecated = true;
- option (op_type) = {
- op: MUTATOR
- };
- }
-
// UpdateRemoteMirror compares the references in the target repository and its remote mirror
// repository. Any differences in the references are then addressed by pushing the differing
// references to the mirror. Created and modified references are updated, removed references are
@@ -48,15 +38,6 @@ service RemoteService {
}
}
-message FetchInternalRemoteRequest {
- Repository repository = 1 [(target_repository)=true];
- Repository remote_repository = 2;
-}
-
-message FetchInternalRemoteResponse {
- bool result = 1;
-}
-
message UpdateRemoteMirrorRequest {
message Remote {
// URL is the URL of the remote repository.
diff --git a/ruby/proto/gitaly/remote_pb.rb b/ruby/proto/gitaly/remote_pb.rb
index 78272e164..a5932587a 100644
--- a/ruby/proto/gitaly/remote_pb.rb
+++ b/ruby/proto/gitaly/remote_pb.rb
@@ -7,13 +7,6 @@ require 'lint_pb'
require 'shared_pb'
Google::Protobuf::DescriptorPool.generated_pool.build do
add_file("remote.proto", :syntax => :proto3) do
- add_message "gitaly.FetchInternalRemoteRequest" do
- optional :repository, :message, 1, "gitaly.Repository"
- optional :remote_repository, :message, 2, "gitaly.Repository"
- end
- add_message "gitaly.FetchInternalRemoteResponse" do
- optional :result, :bool, 1
- end
add_message "gitaly.UpdateRemoteMirrorRequest" do
optional :repository, :message, 1, "gitaly.Repository"
optional :remote, :message, 7, "gitaly.UpdateRemoteMirrorRequest.Remote"
@@ -48,8 +41,6 @@ Google::Protobuf::DescriptorPool.generated_pool.build do
end
module Gitaly
- FetchInternalRemoteRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.FetchInternalRemoteRequest").msgclass
- FetchInternalRemoteResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.FetchInternalRemoteResponse").msgclass
UpdateRemoteMirrorRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.UpdateRemoteMirrorRequest").msgclass
UpdateRemoteMirrorRequest::Remote = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.UpdateRemoteMirrorRequest.Remote").msgclass
UpdateRemoteMirrorResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("gitaly.UpdateRemoteMirrorResponse").msgclass
diff --git a/ruby/proto/gitaly/remote_services_pb.rb b/ruby/proto/gitaly/remote_services_pb.rb
index fe5cb63aa..d6f316220 100644
--- a/ruby/proto/gitaly/remote_services_pb.rb
+++ b/ruby/proto/gitaly/remote_services_pb.rb
@@ -14,10 +14,6 @@ module Gitaly
self.unmarshal_class_method = :decode
self.service_name = 'gitaly.RemoteService'
- # FetchInternalRemote used to fetch changes from a remote repository into
- # the target repository. This RPC call is deprecated and shouldn't be used
- # at all anymore. It will be removed in release v14.4.
- rpc :FetchInternalRemote, Gitaly::FetchInternalRemoteRequest, Gitaly::FetchInternalRemoteResponse
# UpdateRemoteMirror compares the references in the target repository and its remote mirror
# repository. Any differences in the references are then addressed by pushing the differing
# references to the mirror. Created and modified references are updated, removed references are