diff options
author | Patrick Steinhardt <psteinhardt@gitlab.com> | 2022-05-02 12:42:47 +0300 |
---|---|---|
committer | Patrick Steinhardt <psteinhardt@gitlab.com> | 2022-05-09 13:10:27 +0300 |
commit | 4c7a9be67a16746bf6f44a68caf75a7cffd5e969 (patch) | |
tree | 9c091fa5d827808b66c0a1053e7cff3d15e23482 | |
parent | 95c3d0fc69bf4ed0f850e123eb03b909c8547199 (diff) |
proto: Enforce comment-linting for RPC definitions
Enforce that RPC definitions must have a comment and add a placeholder
for all instances where such a comment is missing.
50 files changed, 544 insertions, 12 deletions
diff --git a/proto/.protolint.yaml b/proto/.protolint.yaml index c415ec768..ef55edfec 100644 --- a/proto/.protolint.yaml +++ b/proto/.protolint.yaml @@ -14,7 +14,6 @@ lint: # opt-in to enable these linting warnings, but right now we just want to # get protolint included in our workflow with minimal required changes. - FILE_HAS_COMMENT - - RPCS_HAVE_COMMENT - FIELDS_HAVE_COMMENT - MESSAGES_HAVE_COMMENT - ENUMS_HAVE_COMMENT diff --git a/proto/blob.proto b/proto/blob.proto index f6ded95b8..f176fa967 100644 --- a/proto/blob.proto +++ b/proto/blob.proto @@ -10,6 +10,7 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // BlobService is a service which provides RPCs to retrieve Git blobs from a // specific repository. service BlobService { + // GetBlob returns the contents of a blob object referenced by its object // ID. We use a stream to return a chunked arbitrarily large binary // response @@ -18,6 +19,8 @@ service BlobService { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc GetBlobs(GetBlobsRequest) returns (stream GetBlobsResponse) { option (op_type) = { op: ACCESSOR diff --git a/proto/cleanup.proto b/proto/cleanup.proto index 13e575785..0aac850ab 100644 --- a/proto/cleanup.proto +++ b/proto/cleanup.proto @@ -9,11 +9,14 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // CleanupService provides RPCs to clean up a repository's contents. service CleanupService { + + // This comment is left unintentionally blank. rpc ApplyBfgObjectMapStream(stream ApplyBfgObjectMapStreamRequest) returns (stream ApplyBfgObjectMapStreamResponse) { option (op_type) = { op: MUTATOR }; } + } message ApplyBfgObjectMapStreamRequest { diff --git a/proto/commit.proto b/proto/commit.proto index f61fffb35..938e6d9bc 100644 --- a/proto/commit.proto +++ b/proto/commit.proto @@ -29,104 +29,140 @@ service CommitService { }; } + // This comment is left unintentionally blank. rpc CommitIsAncestor(CommitIsAncestorRequest) returns (CommitIsAncestorResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc TreeEntry(TreeEntryRequest) returns (stream TreeEntryResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc CountCommits(CountCommitsRequest) returns (CountCommitsResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc CountDivergingCommits(CountDivergingCommitsRequest) returns (CountDivergingCommitsResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc GetTreeEntries(GetTreeEntriesRequest) returns (stream GetTreeEntriesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc ListFiles(ListFilesRequest) returns (stream ListFilesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc FindCommit(FindCommitRequest) returns (FindCommitResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc CommitStats(CommitStatsRequest) returns (CommitStatsResponse) { option (op_type) = { op: ACCESSOR }; } + // Use a stream to paginate the result set rpc FindAllCommits(FindAllCommitsRequest) returns (stream FindAllCommitsResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc FindCommits(FindCommitsRequest) returns (stream FindCommitsResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc CommitLanguages(CommitLanguagesRequest) returns (CommitLanguagesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc RawBlame(RawBlameRequest) returns (stream RawBlameResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc LastCommitForPath(LastCommitForPathRequest) returns (LastCommitForPathResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc ListLastCommitsForTree(ListLastCommitsForTreeRequest) returns (stream ListLastCommitsForTreeResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc CommitsByMessage(CommitsByMessageRequest) returns (stream CommitsByMessageResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc ListCommitsByOid(ListCommitsByOidRequest) returns (stream ListCommitsByOidResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc ListCommitsByRefName(ListCommitsByRefNameRequest) returns (stream ListCommitsByRefNameResponse) { option (op_type) = { op: ACCESSOR }; } + // This comment is left unintentionally blank. rpc FilterShasWithSignatures(stream FilterShasWithSignaturesRequest) returns (stream FilterShasWithSignaturesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc GetCommitSignatures(GetCommitSignaturesRequest) returns (stream GetCommitSignaturesResponse) { option (op_type) = { op: ACCESSOR }; } + // This comment is left unintentionally blank. rpc GetCommitMessages(GetCommitMessagesRequest) returns (stream GetCommitMessagesResponse) { option (op_type) = { op: ACCESSOR @@ -142,6 +178,7 @@ service CommitService { op: ACCESSOR }; } + } // ListCommitsRequest is a request for the ListCommits RPC. diff --git a/proto/conflicts.proto b/proto/conflicts.proto index 25eb0965e..14c8f3c76 100644 --- a/proto/conflicts.proto +++ b/proto/conflicts.proto @@ -11,6 +11,9 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // ConflictsService is a service which provides RPCs to interact with conflicts // resulting from a merge. service ConflictsService { + + // ListConflictFiles returns all conflicting files which result from a merge + // of two specified commit objects. rpc ListConflictFiles(ListConflictFilesRequest) returns (stream ListConflictFilesResponse) { option (op_type) = { op: ACCESSOR @@ -25,6 +28,7 @@ service ConflictsService { op: MUTATOR }; } + } message ListConflictFilesRequest { diff --git a/proto/diff.proto b/proto/diff.proto index 8ff8347a0..f2e269167 100644 --- a/proto/diff.proto +++ b/proto/diff.proto @@ -10,39 +10,49 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // DiffService is a service which provides RPCs to inspect differences // introduced between a set of commits. service DiffService { + // Returns stream of CommitDiffResponse with patches chunked over messages rpc CommitDiff(CommitDiffRequest) returns (stream CommitDiffResponse) { option (op_type) = { op: ACCESSOR }; } + // Return a stream so we can divide the response in chunks of deltas rpc CommitDelta(CommitDeltaRequest) returns (stream CommitDeltaResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc RawDiff(RawDiffRequest) returns (stream RawDiffResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc RawPatch(RawPatchRequest) returns (stream RawPatchResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc DiffStats(DiffStatsRequest) returns (stream DiffStatsResponse) { option (op_type) = { op: ACCESSOR }; } + // Return a list of files changed along with the status of each file rpc FindChangedPaths(FindChangedPathsRequest) returns (stream FindChangedPathsResponse) { option (op_type) = { op: ACCESSOR }; } + } message CommitDiffRequest { diff --git a/proto/go/gitalypb/blob_grpc.pb.go b/proto/go/gitalypb/blob_grpc.pb.go index ffc48c044..02dbd20b2 100644 --- a/proto/go/gitalypb/blob_grpc.pb.go +++ b/proto/go/gitalypb/blob_grpc.pb.go @@ -22,6 +22,7 @@ type BlobServiceClient interface { // ID. We use a stream to return a chunked arbitrarily large binary // response GetBlob(ctx context.Context, in *GetBlobRequest, opts ...grpc.CallOption) (BlobService_GetBlobClient, error) + // This comment is left unintentionally blank. GetBlobs(ctx context.Context, in *GetBlobsRequest, opts ...grpc.CallOption) (BlobService_GetBlobsClient, error) // ListBlobs will list all blobs reachable from a given set of revisions by // doing a graph walk. It is not valid to pass revisions which do not resolve @@ -286,6 +287,7 @@ type BlobServiceServer interface { // ID. We use a stream to return a chunked arbitrarily large binary // response GetBlob(*GetBlobRequest, BlobService_GetBlobServer) error + // This comment is left unintentionally blank. GetBlobs(*GetBlobsRequest, BlobService_GetBlobsServer) error // ListBlobs will list all blobs reachable from a given set of revisions by // doing a graph walk. It is not valid to pass revisions which do not resolve diff --git a/proto/go/gitalypb/cleanup_grpc.pb.go b/proto/go/gitalypb/cleanup_grpc.pb.go index f49c5560c..dce610b19 100644 --- a/proto/go/gitalypb/cleanup_grpc.pb.go +++ b/proto/go/gitalypb/cleanup_grpc.pb.go @@ -18,6 +18,7 @@ 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 CleanupServiceClient interface { + // This comment is left unintentionally blank. ApplyBfgObjectMapStream(ctx context.Context, opts ...grpc.CallOption) (CleanupService_ApplyBfgObjectMapStreamClient, error) } @@ -64,6 +65,7 @@ func (x *cleanupServiceApplyBfgObjectMapStreamClient) Recv() (*ApplyBfgObjectMap // All implementations must embed UnimplementedCleanupServiceServer // for forward compatibility type CleanupServiceServer interface { + // This comment is left unintentionally blank. ApplyBfgObjectMapStream(CleanupService_ApplyBfgObjectMapStreamServer) error mustEmbedUnimplementedCleanupServiceServer() } diff --git a/proto/go/gitalypb/commit_grpc.pb.go b/proto/go/gitalypb/commit_grpc.pb.go index 0e1f603bd..54ce4ad3f 100644 --- a/proto/go/gitalypb/commit_grpc.pb.go +++ b/proto/go/gitalypb/commit_grpc.pb.go @@ -25,26 +25,45 @@ type CommitServiceClient interface { // ListAllCommits lists all commits present in the repository, including // those not reachable by any reference. ListAllCommits(ctx context.Context, in *ListAllCommitsRequest, opts ...grpc.CallOption) (CommitService_ListAllCommitsClient, error) + // This comment is left unintentionally blank. CommitIsAncestor(ctx context.Context, in *CommitIsAncestorRequest, opts ...grpc.CallOption) (*CommitIsAncestorResponse, error) + // This comment is left unintentionally blank. TreeEntry(ctx context.Context, in *TreeEntryRequest, opts ...grpc.CallOption) (CommitService_TreeEntryClient, error) + // This comment is left unintentionally blank. CountCommits(ctx context.Context, in *CountCommitsRequest, opts ...grpc.CallOption) (*CountCommitsResponse, error) + // This comment is left unintentionally blank. CountDivergingCommits(ctx context.Context, in *CountDivergingCommitsRequest, opts ...grpc.CallOption) (*CountDivergingCommitsResponse, error) + // This comment is left unintentionally blank. GetTreeEntries(ctx context.Context, in *GetTreeEntriesRequest, opts ...grpc.CallOption) (CommitService_GetTreeEntriesClient, error) + // This comment is left unintentionally blank. ListFiles(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (CommitService_ListFilesClient, error) + // This comment is left unintentionally blank. FindCommit(ctx context.Context, in *FindCommitRequest, opts ...grpc.CallOption) (*FindCommitResponse, error) + // This comment is left unintentionally blank. CommitStats(ctx context.Context, in *CommitStatsRequest, opts ...grpc.CallOption) (*CommitStatsResponse, error) // Use a stream to paginate the result set FindAllCommits(ctx context.Context, in *FindAllCommitsRequest, opts ...grpc.CallOption) (CommitService_FindAllCommitsClient, error) + // This comment is left unintentionally blank. FindCommits(ctx context.Context, in *FindCommitsRequest, opts ...grpc.CallOption) (CommitService_FindCommitsClient, error) + // This comment is left unintentionally blank. CommitLanguages(ctx context.Context, in *CommitLanguagesRequest, opts ...grpc.CallOption) (*CommitLanguagesResponse, error) + // This comment is left unintentionally blank. RawBlame(ctx context.Context, in *RawBlameRequest, opts ...grpc.CallOption) (CommitService_RawBlameClient, error) + // This comment is left unintentionally blank. LastCommitForPath(ctx context.Context, in *LastCommitForPathRequest, opts ...grpc.CallOption) (*LastCommitForPathResponse, error) + // This comment is left unintentionally blank. ListLastCommitsForTree(ctx context.Context, in *ListLastCommitsForTreeRequest, opts ...grpc.CallOption) (CommitService_ListLastCommitsForTreeClient, error) + // This comment is left unintentionally blank. CommitsByMessage(ctx context.Context, in *CommitsByMessageRequest, opts ...grpc.CallOption) (CommitService_CommitsByMessageClient, error) + // This comment is left unintentionally blank. ListCommitsByOid(ctx context.Context, in *ListCommitsByOidRequest, opts ...grpc.CallOption) (CommitService_ListCommitsByOidClient, error) + // This comment is left unintentionally blank. ListCommitsByRefName(ctx context.Context, in *ListCommitsByRefNameRequest, opts ...grpc.CallOption) (CommitService_ListCommitsByRefNameClient, error) + // This comment is left unintentionally blank. FilterShasWithSignatures(ctx context.Context, opts ...grpc.CallOption) (CommitService_FilterShasWithSignaturesClient, error) + // This comment is left unintentionally blank. GetCommitSignatures(ctx context.Context, in *GetCommitSignaturesRequest, opts ...grpc.CallOption) (CommitService_GetCommitSignaturesClient, error) + // This comment is left unintentionally blank. GetCommitMessages(ctx context.Context, in *GetCommitMessagesRequest, opts ...grpc.CallOption) (CommitService_GetCommitMessagesClient, error) // CheckObjectsExist will check for the existence of revisions against a // repository. It returns two sets of data. An array containing the revisions @@ -645,26 +664,45 @@ type CommitServiceServer interface { // ListAllCommits lists all commits present in the repository, including // those not reachable by any reference. ListAllCommits(*ListAllCommitsRequest, CommitService_ListAllCommitsServer) error + // This comment is left unintentionally blank. CommitIsAncestor(context.Context, *CommitIsAncestorRequest) (*CommitIsAncestorResponse, error) + // This comment is left unintentionally blank. TreeEntry(*TreeEntryRequest, CommitService_TreeEntryServer) error + // This comment is left unintentionally blank. CountCommits(context.Context, *CountCommitsRequest) (*CountCommitsResponse, error) + // This comment is left unintentionally blank. CountDivergingCommits(context.Context, *CountDivergingCommitsRequest) (*CountDivergingCommitsResponse, error) + // This comment is left unintentionally blank. GetTreeEntries(*GetTreeEntriesRequest, CommitService_GetTreeEntriesServer) error + // This comment is left unintentionally blank. ListFiles(*ListFilesRequest, CommitService_ListFilesServer) error + // This comment is left unintentionally blank. FindCommit(context.Context, *FindCommitRequest) (*FindCommitResponse, error) + // This comment is left unintentionally blank. CommitStats(context.Context, *CommitStatsRequest) (*CommitStatsResponse, error) // Use a stream to paginate the result set FindAllCommits(*FindAllCommitsRequest, CommitService_FindAllCommitsServer) error + // This comment is left unintentionally blank. FindCommits(*FindCommitsRequest, CommitService_FindCommitsServer) error + // This comment is left unintentionally blank. CommitLanguages(context.Context, *CommitLanguagesRequest) (*CommitLanguagesResponse, error) + // This comment is left unintentionally blank. RawBlame(*RawBlameRequest, CommitService_RawBlameServer) error + // This comment is left unintentionally blank. LastCommitForPath(context.Context, *LastCommitForPathRequest) (*LastCommitForPathResponse, error) + // This comment is left unintentionally blank. ListLastCommitsForTree(*ListLastCommitsForTreeRequest, CommitService_ListLastCommitsForTreeServer) error + // This comment is left unintentionally blank. CommitsByMessage(*CommitsByMessageRequest, CommitService_CommitsByMessageServer) error + // This comment is left unintentionally blank. ListCommitsByOid(*ListCommitsByOidRequest, CommitService_ListCommitsByOidServer) error + // This comment is left unintentionally blank. ListCommitsByRefName(*ListCommitsByRefNameRequest, CommitService_ListCommitsByRefNameServer) error + // This comment is left unintentionally blank. FilterShasWithSignatures(CommitService_FilterShasWithSignaturesServer) error + // This comment is left unintentionally blank. GetCommitSignatures(*GetCommitSignaturesRequest, CommitService_GetCommitSignaturesServer) error + // This comment is left unintentionally blank. GetCommitMessages(*GetCommitMessagesRequest, CommitService_GetCommitMessagesServer) error // CheckObjectsExist will check for the existence of revisions against a // repository. It returns two sets of data. An array containing the revisions diff --git a/proto/go/gitalypb/conflicts_grpc.pb.go b/proto/go/gitalypb/conflicts_grpc.pb.go index ec73fb129..f50ae2a56 100644 --- a/proto/go/gitalypb/conflicts_grpc.pb.go +++ b/proto/go/gitalypb/conflicts_grpc.pb.go @@ -18,6 +18,8 @@ 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 ConflictsServiceClient interface { + // ListConflictFiles returns all conflicting files which result from a merge + // of two specified commit objects. ListConflictFiles(ctx context.Context, in *ListConflictFilesRequest, opts ...grpc.CallOption) (ConflictsService_ListConflictFilesClient, error) // ResolveConflicts tries to resolve a conflicting merge with a set of // user-provided merge resolutions. If resolving the conflict succeeds, the @@ -103,6 +105,8 @@ func (x *conflictsServiceResolveConflictsClient) CloseAndRecv() (*ResolveConflic // All implementations must embed UnimplementedConflictsServiceServer // for forward compatibility type ConflictsServiceServer interface { + // ListConflictFiles returns all conflicting files which result from a merge + // of two specified commit objects. ListConflictFiles(*ListConflictFilesRequest, ConflictsService_ListConflictFilesServer) error // ResolveConflicts tries to resolve a conflicting merge with a set of // user-provided merge resolutions. If resolving the conflict succeeds, the diff --git a/proto/go/gitalypb/diff_grpc.pb.go b/proto/go/gitalypb/diff_grpc.pb.go index 7fdc2a73c..c946202b6 100644 --- a/proto/go/gitalypb/diff_grpc.pb.go +++ b/proto/go/gitalypb/diff_grpc.pb.go @@ -22,8 +22,11 @@ type DiffServiceClient interface { CommitDiff(ctx context.Context, in *CommitDiffRequest, opts ...grpc.CallOption) (DiffService_CommitDiffClient, error) // Return a stream so we can divide the response in chunks of deltas CommitDelta(ctx context.Context, in *CommitDeltaRequest, opts ...grpc.CallOption) (DiffService_CommitDeltaClient, error) + // This comment is left unintentionally blank. RawDiff(ctx context.Context, in *RawDiffRequest, opts ...grpc.CallOption) (DiffService_RawDiffClient, error) + // This comment is left unintentionally blank. RawPatch(ctx context.Context, in *RawPatchRequest, opts ...grpc.CallOption) (DiffService_RawPatchClient, error) + // This comment is left unintentionally blank. DiffStats(ctx context.Context, in *DiffStatsRequest, opts ...grpc.CallOption) (DiffService_DiffStatsClient, error) // Return a list of files changed along with the status of each file FindChangedPaths(ctx context.Context, in *FindChangedPathsRequest, opts ...grpc.CallOption) (DiffService_FindChangedPathsClient, error) @@ -237,8 +240,11 @@ type DiffServiceServer interface { CommitDiff(*CommitDiffRequest, DiffService_CommitDiffServer) error // Return a stream so we can divide the response in chunks of deltas CommitDelta(*CommitDeltaRequest, DiffService_CommitDeltaServer) error + // This comment is left unintentionally blank. RawDiff(*RawDiffRequest, DiffService_RawDiffServer) error + // This comment is left unintentionally blank. RawPatch(*RawPatchRequest, DiffService_RawPatchServer) error + // This comment is left unintentionally blank. DiffStats(*DiffStatsRequest, DiffService_DiffStatsServer) error // Return a list of files changed along with the status of each file FindChangedPaths(*FindChangedPathsRequest, DiffService_FindChangedPathsServer) error diff --git a/proto/go/gitalypb/hook_grpc.pb.go b/proto/go/gitalypb/hook_grpc.pb.go index 8e9b0e989..a87c5f932 100644 --- a/proto/go/gitalypb/hook_grpc.pb.go +++ b/proto/go/gitalypb/hook_grpc.pb.go @@ -18,9 +18,13 @@ 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 HookServiceClient interface { + // This comment is left unintentionally blank. PreReceiveHook(ctx context.Context, opts ...grpc.CallOption) (HookService_PreReceiveHookClient, error) + // This comment is left unintentionally blank. PostReceiveHook(ctx context.Context, opts ...grpc.CallOption) (HookService_PostReceiveHookClient, error) + // This comment is left unintentionally blank. UpdateHook(ctx context.Context, in *UpdateHookRequest, opts ...grpc.CallOption) (HookService_UpdateHookClient, error) + // This comment is left unintentionally blank. ReferenceTransactionHook(ctx context.Context, opts ...grpc.CallOption) (HookService_ReferenceTransactionHookClient, error) // PackObjectsHookWithSidechannel is an optimized version of PackObjectsHook that uses // a unix socket side channel. @@ -173,9 +177,13 @@ func (c *hookServiceClient) PackObjectsHookWithSidechannel(ctx context.Context, // All implementations must embed UnimplementedHookServiceServer // for forward compatibility type HookServiceServer interface { + // This comment is left unintentionally blank. PreReceiveHook(HookService_PreReceiveHookServer) error + // This comment is left unintentionally blank. PostReceiveHook(HookService_PostReceiveHookServer) error + // This comment is left unintentionally blank. UpdateHook(*UpdateHookRequest, HookService_UpdateHookServer) error + // This comment is left unintentionally blank. ReferenceTransactionHook(HookService_ReferenceTransactionHookServer) error // PackObjectsHookWithSidechannel is an optimized version of PackObjectsHook that uses // a unix socket side channel. diff --git a/proto/go/gitalypb/namespace_grpc.pb.go b/proto/go/gitalypb/namespace_grpc.pb.go index 33ff20ee3..b7d1b33ab 100644 --- a/proto/go/gitalypb/namespace_grpc.pb.go +++ b/proto/go/gitalypb/namespace_grpc.pb.go @@ -18,9 +18,13 @@ 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 NamespaceServiceClient interface { + // This comment is left unintentionally blank. AddNamespace(ctx context.Context, in *AddNamespaceRequest, opts ...grpc.CallOption) (*AddNamespaceResponse, error) + // This comment is left unintentionally blank. RemoveNamespace(ctx context.Context, in *RemoveNamespaceRequest, opts ...grpc.CallOption) (*RemoveNamespaceResponse, error) + // This comment is left unintentionally blank. RenameNamespace(ctx context.Context, in *RenameNamespaceRequest, opts ...grpc.CallOption) (*RenameNamespaceResponse, error) + // This comment is left unintentionally blank. NamespaceExists(ctx context.Context, in *NamespaceExistsRequest, opts ...grpc.CallOption) (*NamespaceExistsResponse, error) } @@ -72,9 +76,13 @@ func (c *namespaceServiceClient) NamespaceExists(ctx context.Context, in *Namesp // All implementations must embed UnimplementedNamespaceServiceServer // for forward compatibility type NamespaceServiceServer interface { + // This comment is left unintentionally blank. AddNamespace(context.Context, *AddNamespaceRequest) (*AddNamespaceResponse, error) + // This comment is left unintentionally blank. RemoveNamespace(context.Context, *RemoveNamespaceRequest) (*RemoveNamespaceResponse, error) + // This comment is left unintentionally blank. RenameNamespace(context.Context, *RenameNamespaceRequest) (*RenameNamespaceResponse, error) + // This comment is left unintentionally blank. NamespaceExists(context.Context, *NamespaceExistsRequest) (*NamespaceExistsResponse, error) mustEmbedUnimplementedNamespaceServiceServer() } diff --git a/proto/go/gitalypb/objectpool_grpc.pb.go b/proto/go/gitalypb/objectpool_grpc.pb.go index b46a4bc1c..c052d4ec3 100644 --- a/proto/go/gitalypb/objectpool_grpc.pb.go +++ b/proto/go/gitalypb/objectpool_grpc.pb.go @@ -18,13 +18,19 @@ 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 ObjectPoolServiceClient interface { + // This comment is left unintentionally blank. CreateObjectPool(ctx context.Context, in *CreateObjectPoolRequest, opts ...grpc.CallOption) (*CreateObjectPoolResponse, error) + // This comment is left unintentionally blank. DeleteObjectPool(ctx context.Context, in *DeleteObjectPoolRequest, opts ...grpc.CallOption) (*DeleteObjectPoolResponse, error) // Repositories are assumed to be stored on the same disk LinkRepositoryToObjectPool(ctx context.Context, in *LinkRepositoryToObjectPoolRequest, opts ...grpc.CallOption) (*LinkRepositoryToObjectPoolResponse, error) + // This comment is left unintentionally blank. ReduplicateRepository(ctx context.Context, in *ReduplicateRepositoryRequest, opts ...grpc.CallOption) (*ReduplicateRepositoryResponse, error) + // This comment is left unintentionally blank. DisconnectGitAlternates(ctx context.Context, in *DisconnectGitAlternatesRequest, opts ...grpc.CallOption) (*DisconnectGitAlternatesResponse, error) + // This comment is left unintentionally blank. FetchIntoObjectPool(ctx context.Context, in *FetchIntoObjectPoolRequest, opts ...grpc.CallOption) (*FetchIntoObjectPoolResponse, error) + // This comment is left unintentionally blank. GetObjectPool(ctx context.Context, in *GetObjectPoolRequest, opts ...grpc.CallOption) (*GetObjectPoolResponse, error) } @@ -103,13 +109,19 @@ func (c *objectPoolServiceClient) GetObjectPool(ctx context.Context, in *GetObje // All implementations must embed UnimplementedObjectPoolServiceServer // for forward compatibility type ObjectPoolServiceServer interface { + // This comment is left unintentionally blank. CreateObjectPool(context.Context, *CreateObjectPoolRequest) (*CreateObjectPoolResponse, error) + // This comment is left unintentionally blank. DeleteObjectPool(context.Context, *DeleteObjectPoolRequest) (*DeleteObjectPoolResponse, error) // Repositories are assumed to be stored on the same disk LinkRepositoryToObjectPool(context.Context, *LinkRepositoryToObjectPoolRequest) (*LinkRepositoryToObjectPoolResponse, error) + // This comment is left unintentionally blank. ReduplicateRepository(context.Context, *ReduplicateRepositoryRequest) (*ReduplicateRepositoryResponse, error) + // This comment is left unintentionally blank. DisconnectGitAlternates(context.Context, *DisconnectGitAlternatesRequest) (*DisconnectGitAlternatesResponse, error) + // This comment is left unintentionally blank. FetchIntoObjectPool(context.Context, *FetchIntoObjectPoolRequest) (*FetchIntoObjectPoolResponse, error) + // This comment is left unintentionally blank. GetObjectPool(context.Context, *GetObjectPoolRequest) (*GetObjectPoolResponse, error) mustEmbedUnimplementedObjectPoolServiceServer() } diff --git a/proto/go/gitalypb/operations_grpc.pb.go b/proto/go/gitalypb/operations_grpc.pb.go index 45c083841..a1db433bc 100644 --- a/proto/go/gitalypb/operations_grpc.pb.go +++ b/proto/go/gitalypb/operations_grpc.pb.go @@ -18,11 +18,15 @@ 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 OperationServiceClient interface { + // This comment is left unintentionally blank. UserCreateBranch(ctx context.Context, in *UserCreateBranchRequest, opts ...grpc.CallOption) (*UserCreateBranchResponse, error) + // This comment is left unintentionally blank. UserUpdateBranch(ctx context.Context, in *UserUpdateBranchRequest, opts ...grpc.CallOption) (*UserUpdateBranchResponse, error) + // This comment is left unintentionally blank. UserDeleteBranch(ctx context.Context, in *UserDeleteBranchRequest, opts ...grpc.CallOption) (*UserDeleteBranchResponse, error) // UserCreateTag creates a new tag. UserCreateTag(ctx context.Context, in *UserCreateTagRequest, opts ...grpc.CallOption) (*UserCreateTagResponse, error) + // This comment is left unintentionally blank. UserDeleteTag(ctx context.Context, in *UserDeleteTagRequest, opts ...grpc.CallOption) (*UserDeleteTagResponse, error) // UserMergeRef creates a merge commit and updates target_ref to point to that // new commit. The first parent of the merge commit (the main line) is taken @@ -316,11 +320,15 @@ func (c *operationServiceClient) UserUpdateSubmodule(ctx context.Context, in *Us // All implementations must embed UnimplementedOperationServiceServer // for forward compatibility type OperationServiceServer interface { + // This comment is left unintentionally blank. UserCreateBranch(context.Context, *UserCreateBranchRequest) (*UserCreateBranchResponse, error) + // This comment is left unintentionally blank. UserUpdateBranch(context.Context, *UserUpdateBranchRequest) (*UserUpdateBranchResponse, error) + // This comment is left unintentionally blank. UserDeleteBranch(context.Context, *UserDeleteBranchRequest) (*UserDeleteBranchResponse, error) // UserCreateTag creates a new tag. UserCreateTag(context.Context, *UserCreateTagRequest) (*UserCreateTagResponse, error) + // This comment is left unintentionally blank. UserDeleteTag(context.Context, *UserDeleteTagRequest) (*UserDeleteTagResponse, error) // UserMergeRef creates a merge commit and updates target_ref to point to that // new commit. The first parent of the merge commit (the main line) is taken diff --git a/proto/go/gitalypb/praefect_grpc.pb.go b/proto/go/gitalypb/praefect_grpc.pb.go index b01e699f6..d1e45fa50 100644 --- a/proto/go/gitalypb/praefect_grpc.pb.go +++ b/proto/go/gitalypb/praefect_grpc.pb.go @@ -18,6 +18,7 @@ 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 PraefectInfoServiceClient interface { + // This comment is left unintentionally blank. RepositoryReplicas(ctx context.Context, in *RepositoryReplicasRequest, opts ...grpc.CallOption) (*RepositoryReplicasResponse, error) // DatalossCheck checks for unavailable repositories. DatalossCheck(ctx context.Context, in *DatalossCheckRequest, opts ...grpc.CallOption) (*DatalossCheckResponse, error) @@ -107,6 +108,7 @@ func (c *praefectInfoServiceClient) GetRepositoryMetadata(ctx context.Context, i // All implementations must embed UnimplementedPraefectInfoServiceServer // for forward compatibility type PraefectInfoServiceServer interface { + // This comment is left unintentionally blank. RepositoryReplicas(context.Context, *RepositoryReplicasRequest) (*RepositoryReplicasResponse, error) // DatalossCheck checks for unavailable repositories. DatalossCheck(context.Context, *DatalossCheckRequest) (*DatalossCheckResponse, error) diff --git a/proto/go/gitalypb/ref_grpc.pb.go b/proto/go/gitalypb/ref_grpc.pb.go index 825002030..5d9f4a540 100644 --- a/proto/go/gitalypb/ref_grpc.pb.go +++ b/proto/go/gitalypb/ref_grpc.pb.go @@ -18,28 +18,39 @@ 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 RefServiceClient interface { + // This comment is left unintentionally blank. FindDefaultBranchName(ctx context.Context, in *FindDefaultBranchNameRequest, opts ...grpc.CallOption) (*FindDefaultBranchNameResponse, error) + // This comment is left unintentionally blank. FindAllBranchNames(ctx context.Context, in *FindAllBranchNamesRequest, opts ...grpc.CallOption) (RefService_FindAllBranchNamesClient, error) + // This comment is left unintentionally blank. FindAllTagNames(ctx context.Context, in *FindAllTagNamesRequest, opts ...grpc.CallOption) (RefService_FindAllTagNamesClient, error) // Return a stream so we can divide the response in chunks of branches FindLocalBranches(ctx context.Context, in *FindLocalBranchesRequest, opts ...grpc.CallOption) (RefService_FindLocalBranchesClient, error) + // This comment is left unintentionally blank. FindAllBranches(ctx context.Context, in *FindAllBranchesRequest, opts ...grpc.CallOption) (RefService_FindAllBranchesClient, error) // Returns a stream of tags repository has. FindAllTags(ctx context.Context, in *FindAllTagsRequest, opts ...grpc.CallOption) (RefService_FindAllTagsClient, error) + // This comment is left unintentionally blank. FindTag(ctx context.Context, in *FindTagRequest, opts ...grpc.CallOption) (*FindTagResponse, error) + // This comment is left unintentionally blank. FindAllRemoteBranches(ctx context.Context, in *FindAllRemoteBranchesRequest, opts ...grpc.CallOption) (RefService_FindAllRemoteBranchesClient, error) + // This comment is left unintentionally blank. RefExists(ctx context.Context, in *RefExistsRequest, opts ...grpc.CallOption) (*RefExistsResponse, error) // FindBranch finds a branch by its unqualified name (like "master") and // returns the commit it currently points to. FindBranch(ctx context.Context, in *FindBranchRequest, opts ...grpc.CallOption) (*FindBranchResponse, error) + // This comment is left unintentionally blank. DeleteRefs(ctx context.Context, in *DeleteRefsRequest, opts ...grpc.CallOption) (*DeleteRefsResponse, error) + // This comment is left unintentionally blank. ListBranchNamesContainingCommit(ctx context.Context, in *ListBranchNamesContainingCommitRequest, opts ...grpc.CallOption) (RefService_ListBranchNamesContainingCommitClient, error) + // This comment is left unintentionally blank. ListTagNamesContainingCommit(ctx context.Context, in *ListTagNamesContainingCommitRequest, opts ...grpc.CallOption) (RefService_ListTagNamesContainingCommitClient, error) // GetTagSignatures returns signatures for annotated tags resolved from a set of revisions. Revisions // which don't resolve to an annotated tag are silently discarded. Revisions which cannot be resolved // result in an error. Tags which are annotated but not signed will return a TagSignature response // which has no signature, but its unsigned contents will still be returned. GetTagSignatures(ctx context.Context, in *GetTagSignaturesRequest, opts ...grpc.CallOption) (RefService_GetTagSignaturesClient, error) + // This comment is left unintentionally blank. GetTagMessages(ctx context.Context, in *GetTagMessagesRequest, opts ...grpc.CallOption) (RefService_GetTagMessagesClient, error) // Deprecated: Do not use. // PackRefs is deprecated in favor of OptimizeRepository. @@ -482,28 +493,39 @@ func (c *refServiceClient) FindRefsByOID(ctx context.Context, in *FindRefsByOIDR // All implementations must embed UnimplementedRefServiceServer // for forward compatibility type RefServiceServer interface { + // This comment is left unintentionally blank. FindDefaultBranchName(context.Context, *FindDefaultBranchNameRequest) (*FindDefaultBranchNameResponse, error) + // This comment is left unintentionally blank. FindAllBranchNames(*FindAllBranchNamesRequest, RefService_FindAllBranchNamesServer) error + // This comment is left unintentionally blank. FindAllTagNames(*FindAllTagNamesRequest, RefService_FindAllTagNamesServer) error // Return a stream so we can divide the response in chunks of branches FindLocalBranches(*FindLocalBranchesRequest, RefService_FindLocalBranchesServer) error + // This comment is left unintentionally blank. FindAllBranches(*FindAllBranchesRequest, RefService_FindAllBranchesServer) error // Returns a stream of tags repository has. FindAllTags(*FindAllTagsRequest, RefService_FindAllTagsServer) error + // This comment is left unintentionally blank. FindTag(context.Context, *FindTagRequest) (*FindTagResponse, error) + // This comment is left unintentionally blank. FindAllRemoteBranches(*FindAllRemoteBranchesRequest, RefService_FindAllRemoteBranchesServer) error + // This comment is left unintentionally blank. RefExists(context.Context, *RefExistsRequest) (*RefExistsResponse, error) // FindBranch finds a branch by its unqualified name (like "master") and // returns the commit it currently points to. FindBranch(context.Context, *FindBranchRequest) (*FindBranchResponse, error) + // This comment is left unintentionally blank. DeleteRefs(context.Context, *DeleteRefsRequest) (*DeleteRefsResponse, error) + // This comment is left unintentionally blank. ListBranchNamesContainingCommit(*ListBranchNamesContainingCommitRequest, RefService_ListBranchNamesContainingCommitServer) error + // This comment is left unintentionally blank. ListTagNamesContainingCommit(*ListTagNamesContainingCommitRequest, RefService_ListTagNamesContainingCommitServer) error // GetTagSignatures returns signatures for annotated tags resolved from a set of revisions. Revisions // which don't resolve to an annotated tag are silently discarded. Revisions which cannot be resolved // result in an error. Tags which are annotated but not signed will return a TagSignature response // which has no signature, but its unsigned contents will still be returned. GetTagSignatures(*GetTagSignaturesRequest, RefService_GetTagSignaturesServer) error + // This comment is left unintentionally blank. GetTagMessages(*GetTagMessagesRequest, RefService_GetTagMessagesServer) error // Deprecated: Do not use. // PackRefs is deprecated in favor of OptimizeRepository. diff --git a/proto/go/gitalypb/remote_grpc.pb.go b/proto/go/gitalypb/remote_grpc.pb.go index f97b453a5..0c8591cdf 100644 --- a/proto/go/gitalypb/remote_grpc.pb.go +++ b/proto/go/gitalypb/remote_grpc.pb.go @@ -24,6 +24,7 @@ type RemoteServiceClient interface { // deleted from the mirror. UpdateRemoteMirror updates all tags. Branches are updated if they match // the patterns specified in the requests. UpdateRemoteMirror(ctx context.Context, opts ...grpc.CallOption) (RemoteService_UpdateRemoteMirrorClient, error) + // This comment is left unintentionally blank. FindRemoteRepository(ctx context.Context, in *FindRemoteRepositoryRequest, opts ...grpc.CallOption) (*FindRemoteRepositoryResponse, error) // FindRemoteRootRef tries to find the root reference of a remote // repository. The root reference is the default branch as pointed to by @@ -103,6 +104,7 @@ type RemoteServiceServer interface { // deleted from the mirror. UpdateRemoteMirror updates all tags. Branches are updated if they match // the patterns specified in the requests. UpdateRemoteMirror(RemoteService_UpdateRemoteMirrorServer) error + // This comment is left unintentionally blank. FindRemoteRepository(context.Context, *FindRemoteRepositoryRequest) (*FindRemoteRepositoryResponse, error) // FindRemoteRootRef tries to find the root reference of a remote // repository. The root reference is the default branch as pointed to by diff --git a/proto/go/gitalypb/repository_grpc.pb.go b/proto/go/gitalypb/repository_grpc.pb.go index b05caa251..c4a979a21 100644 --- a/proto/go/gitalypb/repository_grpc.pb.go +++ b/proto/go/gitalypb/repository_grpc.pb.go @@ -18,6 +18,7 @@ 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 RepositoryServiceClient interface { + // This comment is left unintentionally blank. RepositoryExists(ctx context.Context, in *RepositoryExistsRequest, opts ...grpc.CallOption) (*RepositoryExistsResponse, error) // Deprecated: Do not use. // RepackIncremental is deprecated in favor of OptimizeRepository. @@ -34,21 +35,31 @@ type RepositoryServiceClient interface { // Deprecated: Do not use. // WriteCommitGraph is deprecated in favor of OptimizeRepository. WriteCommitGraph(ctx context.Context, in *WriteCommitGraphRequest, opts ...grpc.CallOption) (*WriteCommitGraphResponse, error) + // This comment is left unintentionally blank. RepositorySize(ctx context.Context, in *RepositorySizeRequest, opts ...grpc.CallOption) (*RepositorySizeResponse, error) + // This comment is left unintentionally blank. ApplyGitattributes(ctx context.Context, in *ApplyGitattributesRequest, opts ...grpc.CallOption) (*ApplyGitattributesResponse, error) // FetchRemote fetches references from a remote repository into the local // repository. FetchRemote(ctx context.Context, in *FetchRemoteRequest, opts ...grpc.CallOption) (*FetchRemoteResponse, error) + // This comment is left unintentionally blank. CreateRepository(ctx context.Context, in *CreateRepositoryRequest, opts ...grpc.CallOption) (*CreateRepositoryResponse, error) + // This comment is left unintentionally blank. GetArchive(ctx context.Context, in *GetArchiveRequest, opts ...grpc.CallOption) (RepositoryService_GetArchiveClient, error) + // This comment is left unintentionally blank. HasLocalBranches(ctx context.Context, in *HasLocalBranchesRequest, opts ...grpc.CallOption) (*HasLocalBranchesResponse, error) // FetchSourceBranch fetches a branch from a second (potentially remote) // repository into the given repository. FetchSourceBranch(ctx context.Context, in *FetchSourceBranchRequest, opts ...grpc.CallOption) (*FetchSourceBranchResponse, error) + // This comment is left unintentionally blank. Fsck(ctx context.Context, in *FsckRequest, opts ...grpc.CallOption) (*FsckResponse, error) + // This comment is left unintentionally blank. WriteRef(ctx context.Context, in *WriteRefRequest, opts ...grpc.CallOption) (*WriteRefResponse, error) + // This comment is left unintentionally blank. FindMergeBase(ctx context.Context, in *FindMergeBaseRequest, opts ...grpc.CallOption) (*FindMergeBaseResponse, error) + // This comment is left unintentionally blank. CreateFork(ctx context.Context, in *CreateForkRequest, opts ...grpc.CallOption) (*CreateForkResponse, error) + // This comment is left unintentionally blank. CreateRepositoryFromURL(ctx context.Context, in *CreateRepositoryFromURLRequest, opts ...grpc.CallOption) (*CreateRepositoryFromURLResponse, error) // CreateBundle creates a bundle from all refs CreateBundle(ctx context.Context, in *CreateBundleRequest, opts ...grpc.CallOption) (RepositoryService_CreateBundleClient, error) @@ -59,29 +70,43 @@ type RepositoryServiceClient interface { // Refs will be mirrored to the target repository with the refspec // "+refs/*:refs/*" and refs that do not exist in the bundle will be removed. FetchBundle(ctx context.Context, opts ...grpc.CallOption) (RepositoryService_FetchBundleClient, error) + // This comment is left unintentionally blank. CreateRepositoryFromBundle(ctx context.Context, opts ...grpc.CallOption) (RepositoryService_CreateRepositoryFromBundleClient, error) // GetConfig reads the target repository's gitconfig and streams its contents // back. Returns a NotFound error in case no gitconfig was found. GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (RepositoryService_GetConfigClient, error) + // This comment is left unintentionally blank. FindLicense(ctx context.Context, in *FindLicenseRequest, opts ...grpc.CallOption) (*FindLicenseResponse, error) + // This comment is left unintentionally blank. GetInfoAttributes(ctx context.Context, in *GetInfoAttributesRequest, opts ...grpc.CallOption) (RepositoryService_GetInfoAttributesClient, error) + // This comment is left unintentionally blank. CalculateChecksum(ctx context.Context, in *CalculateChecksumRequest, opts ...grpc.CallOption) (*CalculateChecksumResponse, error) // Deprecated: Do not use. // Cleanup is deprecated in favor of OptimizeRepository. Cleanup(ctx context.Context, in *CleanupRequest, opts ...grpc.CallOption) (*CleanupResponse, error) + // This comment is left unintentionally blank. GetSnapshot(ctx context.Context, in *GetSnapshotRequest, opts ...grpc.CallOption) (RepositoryService_GetSnapshotClient, error) + // This comment is left unintentionally blank. CreateRepositoryFromSnapshot(ctx context.Context, in *CreateRepositoryFromSnapshotRequest, opts ...grpc.CallOption) (*CreateRepositoryFromSnapshotResponse, error) + // This comment is left unintentionally blank. GetRawChanges(ctx context.Context, in *GetRawChangesRequest, opts ...grpc.CallOption) (RepositoryService_GetRawChangesClient, error) + // This comment is left unintentionally blank. SearchFilesByContent(ctx context.Context, in *SearchFilesByContentRequest, opts ...grpc.CallOption) (RepositoryService_SearchFilesByContentClient, error) + // This comment is left unintentionally blank. SearchFilesByName(ctx context.Context, in *SearchFilesByNameRequest, opts ...grpc.CallOption) (RepositoryService_SearchFilesByNameClient, error) + // This comment is left unintentionally blank. RestoreCustomHooks(ctx context.Context, opts ...grpc.CallOption) (RepositoryService_RestoreCustomHooksClient, error) + // This comment is left unintentionally blank. BackupCustomHooks(ctx context.Context, in *BackupCustomHooksRequest, opts ...grpc.CallOption) (RepositoryService_BackupCustomHooksClient, error) + // This comment is left unintentionally blank. GetObjectDirectorySize(ctx context.Context, in *GetObjectDirectorySizeRequest, opts ...grpc.CallOption) (*GetObjectDirectorySizeResponse, error) // RemoveRepository will move the repository to `+gitaly/tmp/<relative_path>_removed` and // eventually remove it. This ensures that even on networked filesystems the // data is actually removed even if there's someone still handling the data. RemoveRepository(ctx context.Context, in *RemoveRepositoryRequest, opts ...grpc.CallOption) (*RemoveRepositoryResponse, error) + // This comment is left unintentionally blank. RenameRepository(ctx context.Context, in *RenameRepositoryRequest, opts ...grpc.CallOption) (*RenameRepositoryResponse, error) + // This comment is left unintentionally blank. ReplicateRepository(ctx context.Context, in *ReplicateRepositoryRequest, opts ...grpc.CallOption) (*ReplicateRepositoryResponse, error) // OptimizeRepository performs all maintenance tasks in a repository to keep // it in an efficient state. It cleans up stale data, repacks objects, @@ -800,6 +825,7 @@ func (c *repositoryServiceClient) SetFullPath(ctx context.Context, in *SetFullPa // All implementations must embed UnimplementedRepositoryServiceServer // for forward compatibility type RepositoryServiceServer interface { + // This comment is left unintentionally blank. RepositoryExists(context.Context, *RepositoryExistsRequest) (*RepositoryExistsResponse, error) // Deprecated: Do not use. // RepackIncremental is deprecated in favor of OptimizeRepository. @@ -816,21 +842,31 @@ type RepositoryServiceServer interface { // Deprecated: Do not use. // WriteCommitGraph is deprecated in favor of OptimizeRepository. WriteCommitGraph(context.Context, *WriteCommitGraphRequest) (*WriteCommitGraphResponse, error) + // This comment is left unintentionally blank. RepositorySize(context.Context, *RepositorySizeRequest) (*RepositorySizeResponse, error) + // This comment is left unintentionally blank. ApplyGitattributes(context.Context, *ApplyGitattributesRequest) (*ApplyGitattributesResponse, error) // FetchRemote fetches references from a remote repository into the local // repository. FetchRemote(context.Context, *FetchRemoteRequest) (*FetchRemoteResponse, error) + // This comment is left unintentionally blank. CreateRepository(context.Context, *CreateRepositoryRequest) (*CreateRepositoryResponse, error) + // This comment is left unintentionally blank. GetArchive(*GetArchiveRequest, RepositoryService_GetArchiveServer) error + // This comment is left unintentionally blank. HasLocalBranches(context.Context, *HasLocalBranchesRequest) (*HasLocalBranchesResponse, error) // FetchSourceBranch fetches a branch from a second (potentially remote) // repository into the given repository. FetchSourceBranch(context.Context, *FetchSourceBranchRequest) (*FetchSourceBranchResponse, error) + // This comment is left unintentionally blank. Fsck(context.Context, *FsckRequest) (*FsckResponse, error) + // This comment is left unintentionally blank. WriteRef(context.Context, *WriteRefRequest) (*WriteRefResponse, error) + // This comment is left unintentionally blank. FindMergeBase(context.Context, *FindMergeBaseRequest) (*FindMergeBaseResponse, error) + // This comment is left unintentionally blank. CreateFork(context.Context, *CreateForkRequest) (*CreateForkResponse, error) + // This comment is left unintentionally blank. CreateRepositoryFromURL(context.Context, *CreateRepositoryFromURLRequest) (*CreateRepositoryFromURLResponse, error) // CreateBundle creates a bundle from all refs CreateBundle(*CreateBundleRequest, RepositoryService_CreateBundleServer) error @@ -841,29 +877,43 @@ type RepositoryServiceServer interface { // Refs will be mirrored to the target repository with the refspec // "+refs/*:refs/*" and refs that do not exist in the bundle will be removed. FetchBundle(RepositoryService_FetchBundleServer) error + // This comment is left unintentionally blank. CreateRepositoryFromBundle(RepositoryService_CreateRepositoryFromBundleServer) error // GetConfig reads the target repository's gitconfig and streams its contents // back. Returns a NotFound error in case no gitconfig was found. GetConfig(*GetConfigRequest, RepositoryService_GetConfigServer) error + // This comment is left unintentionally blank. FindLicense(context.Context, *FindLicenseRequest) (*FindLicenseResponse, error) + // This comment is left unintentionally blank. GetInfoAttributes(*GetInfoAttributesRequest, RepositoryService_GetInfoAttributesServer) error + // This comment is left unintentionally blank. CalculateChecksum(context.Context, *CalculateChecksumRequest) (*CalculateChecksumResponse, error) // Deprecated: Do not use. // Cleanup is deprecated in favor of OptimizeRepository. Cleanup(context.Context, *CleanupRequest) (*CleanupResponse, error) + // This comment is left unintentionally blank. GetSnapshot(*GetSnapshotRequest, RepositoryService_GetSnapshotServer) error + // This comment is left unintentionally blank. CreateRepositoryFromSnapshot(context.Context, *CreateRepositoryFromSnapshotRequest) (*CreateRepositoryFromSnapshotResponse, error) + // This comment is left unintentionally blank. GetRawChanges(*GetRawChangesRequest, RepositoryService_GetRawChangesServer) error + // This comment is left unintentionally blank. SearchFilesByContent(*SearchFilesByContentRequest, RepositoryService_SearchFilesByContentServer) error + // This comment is left unintentionally blank. SearchFilesByName(*SearchFilesByNameRequest, RepositoryService_SearchFilesByNameServer) error + // This comment is left unintentionally blank. RestoreCustomHooks(RepositoryService_RestoreCustomHooksServer) error + // This comment is left unintentionally blank. BackupCustomHooks(*BackupCustomHooksRequest, RepositoryService_BackupCustomHooksServer) error + // This comment is left unintentionally blank. GetObjectDirectorySize(context.Context, *GetObjectDirectorySizeRequest) (*GetObjectDirectorySizeResponse, error) // RemoveRepository will move the repository to `+gitaly/tmp/<relative_path>_removed` and // eventually remove it. This ensures that even on networked filesystems the // data is actually removed even if there's someone still handling the data. RemoveRepository(context.Context, *RemoveRepositoryRequest) (*RemoveRepositoryResponse, error) + // This comment is left unintentionally blank. RenameRepository(context.Context, *RenameRepositoryRequest) (*RenameRepositoryResponse, error) + // This comment is left unintentionally blank. ReplicateRepository(context.Context, *ReplicateRepositoryRequest) (*ReplicateRepositoryResponse, error) // OptimizeRepository performs all maintenance tasks in a repository to keep // it in an efficient state. It cleans up stale data, repacks objects, diff --git a/proto/go/gitalypb/server.pb.go b/proto/go/gitalypb/server.pb.go index a109a94d4..fde95b7b3 100644 --- a/proto/go/gitalypb/server.pb.go +++ b/proto/go/gitalypb/server.pb.go @@ -520,7 +520,7 @@ var file_server_proto_rawDesc = []byte{ 0x73, 0x22, 0x2d, 0x0a, 0x13, 0x43, 0x6c, 0x6f, 0x63, 0x6b, 0x53, 0x79, 0x6e, 0x63, 0x65, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x79, 0x6e, 0x63, 0x65, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x73, 0x79, 0x6e, 0x63, 0x65, 0x64, - 0x32, 0xf5, 0x01, 0x0a, 0x0d, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, + 0x32, 0xf3, 0x01, 0x0a, 0x0d, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x43, 0x0a, 0x0a, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x19, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1a, 0x2e, 0x67, 0x69, @@ -530,16 +530,16 @@ var file_server_proto_rawDesc = []byte{ 0x6c, 0x79, 0x2e, 0x44, 0x69, 0x73, 0x6b, 0x53, 0x74, 0x61, 0x74, 0x69, 0x73, 0x74, 0x69, 0x63, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1e, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x44, 0x69, 0x73, 0x6b, 0x53, 0x74, 0x61, 0x74, 0x69, 0x73, 0x74, 0x69, 0x63, 0x73, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x48, 0x0a, 0x0b, 0x43, 0x6c, 0x6f, 0x63, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x46, 0x0a, 0x0b, 0x43, 0x6c, 0x6f, 0x63, 0x6b, 0x53, 0x79, 0x6e, 0x63, 0x65, 0x64, 0x12, 0x1a, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x43, 0x6c, 0x6f, 0x63, 0x6b, 0x53, 0x79, 0x6e, 0x63, 0x65, 0x64, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1b, 0x2e, 0x67, 0x69, 0x74, 0x61, 0x6c, 0x79, 0x2e, 0x43, 0x6c, 0x6f, 0x63, 0x6b, 0x53, 0x79, 0x6e, 0x63, 0x65, 0x64, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, - 0x22, 0x00, 0x1a, 0x04, 0xf0, 0x97, 0x28, 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, + 0x1a, 0x04, 0xf0, 0x97, 0x28, 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 ( diff --git a/proto/go/gitalypb/server_grpc.pb.go b/proto/go/gitalypb/server_grpc.pb.go index 7c23f806f..bb3ea1dfc 100644 --- a/proto/go/gitalypb/server_grpc.pb.go +++ b/proto/go/gitalypb/server_grpc.pb.go @@ -18,7 +18,9 @@ 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 ServerServiceClient interface { + // This comment is left unintentionally blank. ServerInfo(ctx context.Context, in *ServerInfoRequest, opts ...grpc.CallOption) (*ServerInfoResponse, error) + // This comment is left unintentionally blank. DiskStatistics(ctx context.Context, in *DiskStatisticsRequest, opts ...grpc.CallOption) (*DiskStatisticsResponse, error) // ClockSynced checks if machine clock is synced // (the offset is less that the one passed in the request). @@ -64,7 +66,9 @@ func (c *serverServiceClient) ClockSynced(ctx context.Context, in *ClockSyncedRe // All implementations must embed UnimplementedServerServiceServer // for forward compatibility type ServerServiceServer interface { + // This comment is left unintentionally blank. ServerInfo(context.Context, *ServerInfoRequest) (*ServerInfoResponse, error) + // This comment is left unintentionally blank. DiskStatistics(context.Context, *DiskStatisticsRequest) (*DiskStatisticsResponse, error) // ClockSynced checks if machine clock is synced // (the offset is less that the one passed in the request). diff --git a/proto/go/gitalypb/transaction_grpc.pb.go b/proto/go/gitalypb/transaction_grpc.pb.go index e0bff1022..6d8d589b0 100644 --- a/proto/go/gitalypb/transaction_grpc.pb.go +++ b/proto/go/gitalypb/transaction_grpc.pb.go @@ -18,7 +18,28 @@ 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 RefTransactionClient interface { + // VoteTransaction casts a vote on a transaction to establish whether the + // node is doing the same change as all the other nodes part of the + // transaction. This RPC blocks until quorum has been reached, which may be + // _before_ all nodes have cast a vote. + // + // This RPC may return one of the following error codes: + // + // - `NotFound` in case the transaction could not be found. + // - `Canceled` in case the transaction has been canceled before quorum was + // reached. VoteTransaction(ctx context.Context, in *VoteTransactionRequest, opts ...grpc.CallOption) (*VoteTransactionResponse, error) + // StopTransaction gracefully stops a transaction. This RPC can be used if + // only a subset of nodes executes specific code which may cause the + // transaction to fail. One such example is Git hooks, which only execute on + // the primary Gitaly noded. Other nodes which vote on this transaction will + // get a response with the `STOP` state being set. + // + // This RPC may return one of the following error codes: + // + // - `NotFound` in case the transaction could not be found. + // - `Canceled` in case the transaction has been canceled before quorum was + // reached. StopTransaction(ctx context.Context, in *StopTransactionRequest, opts ...grpc.CallOption) (*StopTransactionResponse, error) } @@ -52,7 +73,28 @@ func (c *refTransactionClient) StopTransaction(ctx context.Context, in *StopTran // All implementations must embed UnimplementedRefTransactionServer // for forward compatibility type RefTransactionServer interface { + // VoteTransaction casts a vote on a transaction to establish whether the + // node is doing the same change as all the other nodes part of the + // transaction. This RPC blocks until quorum has been reached, which may be + // _before_ all nodes have cast a vote. + // + // This RPC may return one of the following error codes: + // + // - `NotFound` in case the transaction could not be found. + // - `Canceled` in case the transaction has been canceled before quorum was + // reached. VoteTransaction(context.Context, *VoteTransactionRequest) (*VoteTransactionResponse, error) + // StopTransaction gracefully stops a transaction. This RPC can be used if + // only a subset of nodes executes specific code which may cause the + // transaction to fail. One such example is Git hooks, which only execute on + // the primary Gitaly noded. Other nodes which vote on this transaction will + // get a response with the `STOP` state being set. + // + // This RPC may return one of the following error codes: + // + // - `NotFound` in case the transaction could not be found. + // - `Canceled` in case the transaction has been canceled before quorum was + // reached. StopTransaction(context.Context, *StopTransactionRequest) (*StopTransactionResponse, error) mustEmbedUnimplementedRefTransactionServer() } diff --git a/proto/go/gitalypb/wiki_grpc.pb.go b/proto/go/gitalypb/wiki_grpc.pb.go index 3c1f5bf96..588539968 100644 --- a/proto/go/gitalypb/wiki_grpc.pb.go +++ b/proto/go/gitalypb/wiki_grpc.pb.go @@ -18,11 +18,15 @@ 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 WikiServiceClient interface { + // This comment is left unintentionally blank. WikiWritePage(ctx context.Context, opts ...grpc.CallOption) (WikiService_WikiWritePageClient, error) + // This comment is left unintentionally blank. WikiUpdatePage(ctx context.Context, opts ...grpc.CallOption) (WikiService_WikiUpdatePageClient, error) // WikiFindPage returns a stream because the page's raw_data field may be arbitrarily large. WikiFindPage(ctx context.Context, in *WikiFindPageRequest, opts ...grpc.CallOption) (WikiService_WikiFindPageClient, error) + // This comment is left unintentionally blank. WikiGetAllPages(ctx context.Context, in *WikiGetAllPagesRequest, opts ...grpc.CallOption) (WikiService_WikiGetAllPagesClient, error) + // This comment is left unintentionally blank. WikiListPages(ctx context.Context, in *WikiListPagesRequest, opts ...grpc.CallOption) (WikiService_WikiListPagesClient, error) } @@ -202,11 +206,15 @@ func (x *wikiServiceWikiListPagesClient) Recv() (*WikiListPagesResponse, error) // All implementations must embed UnimplementedWikiServiceServer // for forward compatibility type WikiServiceServer interface { + // This comment is left unintentionally blank. WikiWritePage(WikiService_WikiWritePageServer) error + // This comment is left unintentionally blank. WikiUpdatePage(WikiService_WikiUpdatePageServer) error // WikiFindPage returns a stream because the page's raw_data field may be arbitrarily large. WikiFindPage(*WikiFindPageRequest, WikiService_WikiFindPageServer) error + // This comment is left unintentionally blank. WikiGetAllPages(*WikiGetAllPagesRequest, WikiService_WikiGetAllPagesServer) error + // This comment is left unintentionally blank. WikiListPages(*WikiListPagesRequest, WikiService_WikiListPagesServer) error mustEmbedUnimplementedWikiServiceServer() } diff --git a/proto/hook.proto b/proto/hook.proto index 960c898ba..8b699ef41 100644 --- a/proto/hook.proto +++ b/proto/hook.proto @@ -11,26 +11,35 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // Git hooks. These are typically invoked via the `gitaly-hooks` binary to // ensure that the actual hook logic is executed in the context of the server. service HookService { + + // This comment is left unintentionally blank. rpc PreReceiveHook(stream PreReceiveHookRequest) returns (stream PreReceiveHookResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc PostReceiveHook(stream PostReceiveHookRequest) returns (stream PostReceiveHookResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc UpdateHook(UpdateHookRequest) returns (stream UpdateHookResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc ReferenceTransactionHook(stream ReferenceTransactionHookRequest) returns (stream ReferenceTransactionHookResponse) { option (op_type) = { op: ACCESSOR }; } + // PackObjectsHookWithSidechannel is an optimized version of PackObjectsHook that uses // a unix socket side channel. rpc PackObjectsHookWithSidechannel(PackObjectsHookWithSidechannelRequest) returns (PackObjectsHookWithSidechannelResponse) { @@ -38,6 +47,7 @@ service HookService { op: ACCESSOR }; } + } message PreReceiveHookRequest { diff --git a/proto/namespace.proto b/proto/namespace.proto index cc23a35ca..e4acbd16d 100644 --- a/proto/namespace.proto +++ b/proto/namespace.proto @@ -10,30 +10,39 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // storage. Namespaces had been used before Gitaly migrated to hashed storages // and shouldn't be used nowadays anymore. service NamespaceService { + + // This comment is left unintentionally blank. rpc AddNamespace(AddNamespaceRequest) returns (AddNamespaceResponse) { option (op_type) = { op: MUTATOR scope_level: STORAGE, }; } + + // This comment is left unintentionally blank. rpc RemoveNamespace(RemoveNamespaceRequest) returns (RemoveNamespaceResponse) { option (op_type) = { op: MUTATOR scope_level: STORAGE, }; } + + // This comment is left unintentionally blank. rpc RenameNamespace(RenameNamespaceRequest) returns (RenameNamespaceResponse) { option (op_type) = { op: MUTATOR scope_level: STORAGE, }; } + + // This comment is left unintentionally blank. rpc NamespaceExists(NamespaceExistsRequest) returns (NamespaceExistsResponse) { option (op_type) = { op: ACCESSOR scope_level: STORAGE, }; } + } message AddNamespaceRequest { diff --git a/proto/objectpool.proto b/proto/objectpool.proto index 8258e09db..a88117e0e 100644 --- a/proto/objectpool.proto +++ b/proto/objectpool.proto @@ -12,11 +12,15 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // satellite repositories in order to deduplicate common objects between them. // This is mostly used in the contexet of repository forks. service ObjectPoolService { + + // This comment is left unintentionally blank. rpc CreateObjectPool(CreateObjectPoolRequest) returns (CreateObjectPoolResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc DeleteObjectPool(DeleteObjectPoolRequest) returns (DeleteObjectPoolResponse) { option (op_type) = { op: MUTATOR @@ -30,26 +34,34 @@ service ObjectPoolService { }; } + // This comment is left unintentionally blank. rpc ReduplicateRepository(ReduplicateRepositoryRequest) returns (ReduplicateRepositoryResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc DisconnectGitAlternates(DisconnectGitAlternatesRequest) returns (DisconnectGitAlternatesResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc FetchIntoObjectPool(FetchIntoObjectPoolRequest) returns (FetchIntoObjectPoolResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc GetObjectPool(GetObjectPoolRequest) returns (GetObjectPoolResponse) { option (op_type) = { op: ACCESSOR }; } + } // Creates an object pool from the repository. The client is responsible for diff --git a/proto/operations.proto b/proto/operations.proto index 023ed3c8b..54f98745c 100644 --- a/proto/operations.proto +++ b/proto/operations.proto @@ -14,16 +14,22 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // treated as untrusted. Any reference update is thus checked against GitLab's // '/allowed' endpoint. service OperationService { + + // This comment is left unintentionally blank. rpc UserCreateBranch(UserCreateBranchRequest) returns (UserCreateBranchResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc UserUpdateBranch(UserUpdateBranchRequest) returns (UserUpdateBranchResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc UserDeleteBranch(UserDeleteBranchRequest) returns (UserDeleteBranchResponse) { option (op_type) = { op: MUTATOR @@ -36,6 +42,8 @@ service OperationService { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc UserDeleteTag(UserDeleteTagRequest) returns (UserDeleteTagResponse) { option (op_type) = { op: MUTATOR @@ -140,6 +148,7 @@ service OperationService { op: MUTATOR }; } + } message UserCreateBranchRequest { @@ -399,7 +408,7 @@ message UserCherryPickError { oneof error { // CherryPickConflict is returned if there is a conflict when applying the cherry // pick. - MergeConflictError cherry_pick_conflict = 1; + MergeConflictError cherry_pick_conflict = 1; // TargetBranchDiverged is returned whenever the tip commit of the branch we're // about to apply the new commit on is not a direct ancestor of the newly created // cherry-picked commit. This may happen either due to a race where the reference diff --git a/proto/praefect.proto b/proto/praefect.proto index 917be6ebb..bd46daf48 100644 --- a/proto/praefect.proto +++ b/proto/praefect.proto @@ -13,6 +13,7 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; service PraefectInfoService { option (intercepted) = true; + // This comment is left unintentionally blank. rpc RepositoryReplicas(RepositoryReplicasRequest) returns (RepositoryReplicasResponse); // DatalossCheck checks for unavailable repositories. @@ -36,8 +37,10 @@ service PraefectInfoService { // from a Praefect node that does not yet know about a new node. As assignments of unconfigured storages are ignored, replication // factor of repositories assigned to a storage node removed from the cluster is effectively decreased. rpc SetReplicationFactor(SetReplicationFactorRequest) returns (SetReplicationFactorResponse); + // GetRepositoryMetadata returns the cluster metadata for a repository. Returns NotFound if the repository does not exist. rpc GetRepositoryMetadata(GetRepositoryMetadataRequest) returns (GetRepositoryMetadataResponse); + } // MarkUnverifiedRequest specifies the replicas which to mark unverified. diff --git a/proto/ref.proto b/proto/ref.proto index 8980e6443..24721563b 100644 --- a/proto/ref.proto +++ b/proto/ref.proto @@ -10,49 +10,65 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // RefService is a service that provides RPCs to list and modify Git references. service RefService { + + // This comment is left unintentionally blank. rpc FindDefaultBranchName(FindDefaultBranchNameRequest) returns (FindDefaultBranchNameResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc FindAllBranchNames(FindAllBranchNamesRequest) returns (stream FindAllBranchNamesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc FindAllTagNames(FindAllTagNamesRequest) returns (stream FindAllTagNamesResponse) { option (op_type) = { op: ACCESSOR }; } + // Return a stream so we can divide the response in chunks of branches rpc FindLocalBranches(FindLocalBranchesRequest) returns (stream FindLocalBranchesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc FindAllBranches(FindAllBranchesRequest) returns (stream FindAllBranchesResponse) { option (op_type) = { op: ACCESSOR }; } + // Returns a stream of tags repository has. rpc FindAllTags(FindAllTagsRequest) returns (stream FindAllTagsResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc FindTag(FindTagRequest) returns (FindTagResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc FindAllRemoteBranches(FindAllRemoteBranchesRequest) returns (stream FindAllRemoteBranchesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc RefExists(RefExistsRequest) returns (RefExistsResponse) { option (op_type) = { op: ACCESSOR @@ -66,17 +82,22 @@ service RefService { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc DeleteRefs(DeleteRefsRequest) returns (DeleteRefsResponse) { option (op_type) = { op: MUTATOR }; } + // This comment is left unintentionally blank. rpc ListBranchNamesContainingCommit(ListBranchNamesContainingCommitRequest) returns (stream ListBranchNamesContainingCommitResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc ListTagNamesContainingCommit(ListTagNamesContainingCommitRequest) returns (stream ListTagNamesContainingCommitResponse) { option (op_type) = { op: ACCESSOR @@ -93,6 +114,7 @@ service RefService { }; } + // This comment is left unintentionally blank. rpc GetTagMessages(GetTagMessagesRequest) returns (stream GetTagMessagesResponse) { option (op_type) = { op: ACCESSOR @@ -124,6 +146,7 @@ service RefService { op: ACCESSOR }; } + } message FindDefaultBranchNameRequest { diff --git a/proto/remote.proto b/proto/remote.proto index 003c06105..8a5fa0f07 100644 --- a/proto/remote.proto +++ b/proto/remote.proto @@ -21,6 +21,8 @@ service RemoteService { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc FindRemoteRepository(FindRemoteRepositoryRequest) returns (FindRemoteRepositoryResponse) { option (op_type) = { op: ACCESSOR diff --git a/proto/repository.proto b/proto/repository.proto index c203ac2db..5d830088e 100644 --- a/proto/repository.proto +++ b/proto/repository.proto @@ -9,6 +9,8 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // RepositoryService is a service providing RPCs accessing repositories as a whole. service RepositoryService { + + // This comment is left unintentionally blank. rpc RepositoryExists(RepositoryExistsRequest) returns (RepositoryExistsResponse) { option (op_type) = { op: ACCESSOR @@ -55,11 +57,14 @@ service RepositoryService { }; } + // This comment is left unintentionally blank. rpc RepositorySize(RepositorySizeRequest) returns (RepositorySizeResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc ApplyGitattributes(ApplyGitattributesRequest) returns (ApplyGitattributesResponse) { option (op_type) = { op: MUTATOR @@ -73,16 +78,22 @@ service RepositoryService { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc CreateRepository(CreateRepositoryRequest) returns (CreateRepositoryResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc GetArchive(GetArchiveRequest) returns (stream GetArchiveResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc HasLocalBranches(HasLocalBranchesRequest) returns (HasLocalBranchesResponse) { option (op_type) = { op: ACCESSOR @@ -96,27 +107,36 @@ service RepositoryService { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc Fsck(FsckRequest) returns (FsckResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc WriteRef(WriteRefRequest) returns (WriteRefResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc FindMergeBase(FindMergeBaseRequest) returns (FindMergeBaseResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc CreateFork(CreateForkRequest) returns (CreateForkResponse) { option (op_type) = { op: MUTATOR }; } + // This comment is left unintentionally blank. rpc CreateRepositoryFromURL(CreateRepositoryFromURLRequest) returns (CreateRepositoryFromURLResponse) { option (op_type) = { op: MUTATOR @@ -147,6 +167,7 @@ service RepositoryService { }; } + // This comment is left unintentionally blank. rpc CreateRepositoryFromBundle(stream CreateRepositoryFromBundleRequest) returns (CreateRepositoryFromBundleResponse) { option (op_type) = { op: MUTATOR @@ -161,16 +182,21 @@ service RepositoryService { }; } + // This comment is left unintentionally blank. rpc FindLicense(FindLicenseRequest) returns (FindLicenseResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc GetInfoAttributes(GetInfoAttributesRequest) returns (stream GetInfoAttributesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc CalculateChecksum(CalculateChecksumRequest) returns (CalculateChecksumResponse) { option (op_type) = { op: ACCESSOR @@ -185,46 +211,62 @@ service RepositoryService { }; } + // This comment is left unintentionally blank. rpc GetSnapshot(GetSnapshotRequest) returns (stream GetSnapshotResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc CreateRepositoryFromSnapshot(CreateRepositoryFromSnapshotRequest) returns (CreateRepositoryFromSnapshotResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc GetRawChanges(GetRawChangesRequest) returns (stream GetRawChangesResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc SearchFilesByContent(SearchFilesByContentRequest) returns (stream SearchFilesByContentResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc SearchFilesByName(SearchFilesByNameRequest) returns (stream SearchFilesByNameResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc RestoreCustomHooks(stream RestoreCustomHooksRequest) returns (RestoreCustomHooksResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc BackupCustomHooks(BackupCustomHooksRequest) returns (stream BackupCustomHooksResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc GetObjectDirectorySize(GetObjectDirectorySizeRequest) returns (GetObjectDirectorySizeResponse) { option (op_type) = { op: ACCESSOR }; } + // RemoveRepository will move the repository to `+gitaly/tmp/<relative_path>_removed` and // eventually remove it. This ensures that even on networked filesystems the // data is actually removed even if there's someone still handling the data. @@ -233,11 +275,15 @@ service RepositoryService { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc RenameRepository(RenameRepositoryRequest) returns (RenameRepositoryResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc ReplicateRepository(ReplicateRepositoryRequest) returns (ReplicateRepositoryResponse) { option (op_type) = { op: MUTATOR diff --git a/proto/server.proto b/proto/server.proto index fc5901036..3fac8b6f9 100644 --- a/proto/server.proto +++ b/proto/server.proto @@ -10,11 +10,16 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; service ServerService { option (intercepted) = true; + // This comment is left unintentionally blank. rpc ServerInfo(ServerInfoRequest) returns (ServerInfoResponse); + + // This comment is left unintentionally blank. rpc DiskStatistics(DiskStatisticsRequest) returns (DiskStatisticsResponse); + // ClockSynced checks if machine clock is synced // (the offset is less that the one passed in the request). - rpc ClockSynced(ClockSyncedRequest) returns (ClockSyncedResponse) {} + rpc ClockSynced(ClockSyncedRequest) returns (ClockSyncedResponse); + } message ServerInfoRequest { diff --git a/proto/transaction.proto b/proto/transaction.proto index 7d074f898..aeca018ca 100644 --- a/proto/transaction.proto +++ b/proto/transaction.proto @@ -15,9 +15,31 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; service RefTransaction { option (intercepted) = true; + // VoteTransaction casts a vote on a transaction to establish whether the + // node is doing the same change as all the other nodes part of the + // transaction. This RPC blocks until quorum has been reached, which may be + // _before_ all nodes have cast a vote. + // + // This RPC may return one of the following error codes: + // + // - `NotFound` in case the transaction could not be found. + // - `Canceled` in case the transaction has been canceled before quorum was + // reached. rpc VoteTransaction (VoteTransactionRequest) returns (VoteTransactionResponse); + // StopTransaction gracefully stops a transaction. This RPC can be used if + // only a subset of nodes executes specific code which may cause the + // transaction to fail. One such example is Git hooks, which only execute on + // the primary Gitaly noded. Other nodes which vote on this transaction will + // get a response with the `STOP` state being set. + // + // This RPC may return one of the following error codes: + // + // - `NotFound` in case the transaction could not be found. + // - `Canceled` in case the transaction has been canceled before quorum was + // reached. rpc StopTransaction (StopTransactionRequest) returns (StopTransactionResponse); + } message VoteTransactionRequest { diff --git a/proto/wiki.proto b/proto/wiki.proto index bf5f62320..7bc9afe21 100644 --- a/proto/wiki.proto +++ b/proto/wiki.proto @@ -11,34 +11,42 @@ option go_package = "gitlab.com/gitlab-org/gitaly/v14/proto/go/gitalypb"; // service is deprecated and should not be used anymore. Instead, all // functionality to implement Wikis should use Git-based RPCS. service WikiService { + + // This comment is left unintentionally blank. rpc WikiWritePage(stream WikiWritePageRequest) returns (WikiWritePageResponse) { option (op_type) = { op: MUTATOR }; } + + // This comment is left unintentionally blank. rpc WikiUpdatePage(stream WikiUpdatePageRequest) returns (WikiUpdatePageResponse) { option (op_type) = { op: MUTATOR }; } + // WikiFindPage returns a stream because the page's raw_data field may be arbitrarily large. rpc WikiFindPage(WikiFindPageRequest) returns (stream WikiFindPageResponse) { option (op_type) = { op: ACCESSOR }; } + + // This comment is left unintentionally blank. rpc WikiGetAllPages(WikiGetAllPagesRequest) returns (stream WikiGetAllPagesResponse) { option (op_type) = { op: ACCESSOR }; - } + + // This comment is left unintentionally blank. rpc WikiListPages(WikiListPagesRequest) returns (stream WikiListPagesResponse) { option (op_type) = { op: ACCESSOR }; - } + } message WikiCommitDetails { diff --git a/ruby/proto/gitaly/blob_services_pb.rb b/ruby/proto/gitaly/blob_services_pb.rb index 1e726517b..aaea1d0ef 100644 --- a/ruby/proto/gitaly/blob_services_pb.rb +++ b/ruby/proto/gitaly/blob_services_pb.rb @@ -20,6 +20,7 @@ module Gitaly # ID. We use a stream to return a chunked arbitrarily large binary # response rpc :GetBlob, ::Gitaly::GetBlobRequest, stream(::Gitaly::GetBlobResponse) + # This comment is left unintentionally blank. rpc :GetBlobs, ::Gitaly::GetBlobsRequest, stream(::Gitaly::GetBlobsResponse) # ListBlobs will list all blobs reachable from a given set of revisions by # doing a graph walk. It is not valid to pass revisions which do not resolve diff --git a/ruby/proto/gitaly/cleanup_services_pb.rb b/ruby/proto/gitaly/cleanup_services_pb.rb index 6fdbd4304..54a0d9fa5 100644 --- a/ruby/proto/gitaly/cleanup_services_pb.rb +++ b/ruby/proto/gitaly/cleanup_services_pb.rb @@ -15,6 +15,7 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.CleanupService' + # This comment is left unintentionally blank. rpc :ApplyBfgObjectMapStream, stream(::Gitaly::ApplyBfgObjectMapStreamRequest), stream(::Gitaly::ApplyBfgObjectMapStreamResponse) end diff --git a/ruby/proto/gitaly/commit_services_pb.rb b/ruby/proto/gitaly/commit_services_pb.rb index 0551e05de..17df1b4b8 100644 --- a/ruby/proto/gitaly/commit_services_pb.rb +++ b/ruby/proto/gitaly/commit_services_pb.rb @@ -23,26 +23,45 @@ module Gitaly # ListAllCommits lists all commits present in the repository, including # those not reachable by any reference. rpc :ListAllCommits, ::Gitaly::ListAllCommitsRequest, stream(::Gitaly::ListAllCommitsResponse) + # This comment is left unintentionally blank. rpc :CommitIsAncestor, ::Gitaly::CommitIsAncestorRequest, ::Gitaly::CommitIsAncestorResponse + # This comment is left unintentionally blank. rpc :TreeEntry, ::Gitaly::TreeEntryRequest, stream(::Gitaly::TreeEntryResponse) + # This comment is left unintentionally blank. rpc :CountCommits, ::Gitaly::CountCommitsRequest, ::Gitaly::CountCommitsResponse + # This comment is left unintentionally blank. rpc :CountDivergingCommits, ::Gitaly::CountDivergingCommitsRequest, ::Gitaly::CountDivergingCommitsResponse + # This comment is left unintentionally blank. rpc :GetTreeEntries, ::Gitaly::GetTreeEntriesRequest, stream(::Gitaly::GetTreeEntriesResponse) + # This comment is left unintentionally blank. rpc :ListFiles, ::Gitaly::ListFilesRequest, stream(::Gitaly::ListFilesResponse) + # This comment is left unintentionally blank. rpc :FindCommit, ::Gitaly::FindCommitRequest, ::Gitaly::FindCommitResponse + # This comment is left unintentionally blank. rpc :CommitStats, ::Gitaly::CommitStatsRequest, ::Gitaly::CommitStatsResponse # Use a stream to paginate the result set rpc :FindAllCommits, ::Gitaly::FindAllCommitsRequest, stream(::Gitaly::FindAllCommitsResponse) + # This comment is left unintentionally blank. rpc :FindCommits, ::Gitaly::FindCommitsRequest, stream(::Gitaly::FindCommitsResponse) + # This comment is left unintentionally blank. rpc :CommitLanguages, ::Gitaly::CommitLanguagesRequest, ::Gitaly::CommitLanguagesResponse + # This comment is left unintentionally blank. rpc :RawBlame, ::Gitaly::RawBlameRequest, stream(::Gitaly::RawBlameResponse) + # This comment is left unintentionally blank. rpc :LastCommitForPath, ::Gitaly::LastCommitForPathRequest, ::Gitaly::LastCommitForPathResponse + # This comment is left unintentionally blank. rpc :ListLastCommitsForTree, ::Gitaly::ListLastCommitsForTreeRequest, stream(::Gitaly::ListLastCommitsForTreeResponse) + # This comment is left unintentionally blank. rpc :CommitsByMessage, ::Gitaly::CommitsByMessageRequest, stream(::Gitaly::CommitsByMessageResponse) + # This comment is left unintentionally blank. rpc :ListCommitsByOid, ::Gitaly::ListCommitsByOidRequest, stream(::Gitaly::ListCommitsByOidResponse) + # This comment is left unintentionally blank. rpc :ListCommitsByRefName, ::Gitaly::ListCommitsByRefNameRequest, stream(::Gitaly::ListCommitsByRefNameResponse) + # This comment is left unintentionally blank. rpc :FilterShasWithSignatures, stream(::Gitaly::FilterShasWithSignaturesRequest), stream(::Gitaly::FilterShasWithSignaturesResponse) + # This comment is left unintentionally blank. rpc :GetCommitSignatures, ::Gitaly::GetCommitSignaturesRequest, stream(::Gitaly::GetCommitSignaturesResponse) + # This comment is left unintentionally blank. rpc :GetCommitMessages, ::Gitaly::GetCommitMessagesRequest, stream(::Gitaly::GetCommitMessagesResponse) # CheckObjectsExist will check for the existence of revisions against a # repository. It returns two sets of data. An array containing the revisions diff --git a/ruby/proto/gitaly/conflicts_services_pb.rb b/ruby/proto/gitaly/conflicts_services_pb.rb index 344f5afa2..245cdd2eb 100644 --- a/ruby/proto/gitaly/conflicts_services_pb.rb +++ b/ruby/proto/gitaly/conflicts_services_pb.rb @@ -16,6 +16,8 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.ConflictsService' + # ListConflictFiles returns all conflicting files which result from a merge + # of two specified commit objects. rpc :ListConflictFiles, ::Gitaly::ListConflictFilesRequest, stream(::Gitaly::ListConflictFilesResponse) # ResolveConflicts tries to resolve a conflicting merge with a set of # user-provided merge resolutions. If resolving the conflict succeeds, the diff --git a/ruby/proto/gitaly/diff_services_pb.rb b/ruby/proto/gitaly/diff_services_pb.rb index 071c98c36..c325ed65e 100644 --- a/ruby/proto/gitaly/diff_services_pb.rb +++ b/ruby/proto/gitaly/diff_services_pb.rb @@ -20,8 +20,11 @@ module Gitaly rpc :CommitDiff, ::Gitaly::CommitDiffRequest, stream(::Gitaly::CommitDiffResponse) # Return a stream so we can divide the response in chunks of deltas rpc :CommitDelta, ::Gitaly::CommitDeltaRequest, stream(::Gitaly::CommitDeltaResponse) + # This comment is left unintentionally blank. rpc :RawDiff, ::Gitaly::RawDiffRequest, stream(::Gitaly::RawDiffResponse) + # This comment is left unintentionally blank. rpc :RawPatch, ::Gitaly::RawPatchRequest, stream(::Gitaly::RawPatchResponse) + # This comment is left unintentionally blank. rpc :DiffStats, ::Gitaly::DiffStatsRequest, stream(::Gitaly::DiffStatsResponse) # Return a list of files changed along with the status of each file rpc :FindChangedPaths, ::Gitaly::FindChangedPathsRequest, stream(::Gitaly::FindChangedPathsResponse) diff --git a/ruby/proto/gitaly/hook_services_pb.rb b/ruby/proto/gitaly/hook_services_pb.rb index 6ecf549e9..0854e819a 100644 --- a/ruby/proto/gitaly/hook_services_pb.rb +++ b/ruby/proto/gitaly/hook_services_pb.rb @@ -17,9 +17,13 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.HookService' + # This comment is left unintentionally blank. rpc :PreReceiveHook, stream(::Gitaly::PreReceiveHookRequest), stream(::Gitaly::PreReceiveHookResponse) + # This comment is left unintentionally blank. rpc :PostReceiveHook, stream(::Gitaly::PostReceiveHookRequest), stream(::Gitaly::PostReceiveHookResponse) + # This comment is left unintentionally blank. rpc :UpdateHook, ::Gitaly::UpdateHookRequest, stream(::Gitaly::UpdateHookResponse) + # This comment is left unintentionally blank. rpc :ReferenceTransactionHook, stream(::Gitaly::ReferenceTransactionHookRequest), stream(::Gitaly::ReferenceTransactionHookResponse) # PackObjectsHookWithSidechannel is an optimized version of PackObjectsHook that uses # a unix socket side channel. diff --git a/ruby/proto/gitaly/namespace_services_pb.rb b/ruby/proto/gitaly/namespace_services_pb.rb index 09174f063..ce0a0c2a8 100644 --- a/ruby/proto/gitaly/namespace_services_pb.rb +++ b/ruby/proto/gitaly/namespace_services_pb.rb @@ -17,9 +17,13 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.NamespaceService' + # This comment is left unintentionally blank. rpc :AddNamespace, ::Gitaly::AddNamespaceRequest, ::Gitaly::AddNamespaceResponse + # This comment is left unintentionally blank. rpc :RemoveNamespace, ::Gitaly::RemoveNamespaceRequest, ::Gitaly::RemoveNamespaceResponse + # This comment is left unintentionally blank. rpc :RenameNamespace, ::Gitaly::RenameNamespaceRequest, ::Gitaly::RenameNamespaceResponse + # This comment is left unintentionally blank. rpc :NamespaceExists, ::Gitaly::NamespaceExistsRequest, ::Gitaly::NamespaceExistsResponse end diff --git a/ruby/proto/gitaly/objectpool_services_pb.rb b/ruby/proto/gitaly/objectpool_services_pb.rb index 5984af019..d0529fa3d 100644 --- a/ruby/proto/gitaly/objectpool_services_pb.rb +++ b/ruby/proto/gitaly/objectpool_services_pb.rb @@ -18,13 +18,19 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.ObjectPoolService' + # This comment is left unintentionally blank. rpc :CreateObjectPool, ::Gitaly::CreateObjectPoolRequest, ::Gitaly::CreateObjectPoolResponse + # This comment is left unintentionally blank. rpc :DeleteObjectPool, ::Gitaly::DeleteObjectPoolRequest, ::Gitaly::DeleteObjectPoolResponse # Repositories are assumed to be stored on the same disk rpc :LinkRepositoryToObjectPool, ::Gitaly::LinkRepositoryToObjectPoolRequest, ::Gitaly::LinkRepositoryToObjectPoolResponse + # This comment is left unintentionally blank. rpc :ReduplicateRepository, ::Gitaly::ReduplicateRepositoryRequest, ::Gitaly::ReduplicateRepositoryResponse + # This comment is left unintentionally blank. rpc :DisconnectGitAlternates, ::Gitaly::DisconnectGitAlternatesRequest, ::Gitaly::DisconnectGitAlternatesResponse + # This comment is left unintentionally blank. rpc :FetchIntoObjectPool, ::Gitaly::FetchIntoObjectPoolRequest, ::Gitaly::FetchIntoObjectPoolResponse + # This comment is left unintentionally blank. rpc :GetObjectPool, ::Gitaly::GetObjectPoolRequest, ::Gitaly::GetObjectPoolResponse end diff --git a/ruby/proto/gitaly/operations_services_pb.rb b/ruby/proto/gitaly/operations_services_pb.rb index 13a98c011..05f1184f4 100644 --- a/ruby/proto/gitaly/operations_services_pb.rb +++ b/ruby/proto/gitaly/operations_services_pb.rb @@ -18,11 +18,15 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.OperationService' + # This comment is left unintentionally blank. rpc :UserCreateBranch, ::Gitaly::UserCreateBranchRequest, ::Gitaly::UserCreateBranchResponse + # This comment is left unintentionally blank. rpc :UserUpdateBranch, ::Gitaly::UserUpdateBranchRequest, ::Gitaly::UserUpdateBranchResponse + # This comment is left unintentionally blank. rpc :UserDeleteBranch, ::Gitaly::UserDeleteBranchRequest, ::Gitaly::UserDeleteBranchResponse # UserCreateTag creates a new tag. rpc :UserCreateTag, ::Gitaly::UserCreateTagRequest, ::Gitaly::UserCreateTagResponse + # This comment is left unintentionally blank. rpc :UserDeleteTag, ::Gitaly::UserDeleteTagRequest, ::Gitaly::UserDeleteTagResponse # UserMergeRef creates a merge commit and updates target_ref to point to that # new commit. The first parent of the merge commit (the main line) is taken diff --git a/ruby/proto/gitaly/praefect_services_pb.rb b/ruby/proto/gitaly/praefect_services_pb.rb index 752bef266..9ead16a48 100644 --- a/ruby/proto/gitaly/praefect_services_pb.rb +++ b/ruby/proto/gitaly/praefect_services_pb.rb @@ -16,6 +16,7 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.PraefectInfoService' + # This comment is left unintentionally blank. rpc :RepositoryReplicas, ::Gitaly::RepositoryReplicasRequest, ::Gitaly::RepositoryReplicasResponse # DatalossCheck checks for unavailable repositories. rpc :DatalossCheck, ::Gitaly::DatalossCheckRequest, ::Gitaly::DatalossCheckResponse diff --git a/ruby/proto/gitaly/ref_services_pb.rb b/ruby/proto/gitaly/ref_services_pb.rb index a508e3c7a..67f5e76a1 100644 --- a/ruby/proto/gitaly/ref_services_pb.rb +++ b/ruby/proto/gitaly/ref_services_pb.rb @@ -15,28 +15,39 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.RefService' + # This comment is left unintentionally blank. rpc :FindDefaultBranchName, ::Gitaly::FindDefaultBranchNameRequest, ::Gitaly::FindDefaultBranchNameResponse + # This comment is left unintentionally blank. rpc :FindAllBranchNames, ::Gitaly::FindAllBranchNamesRequest, stream(::Gitaly::FindAllBranchNamesResponse) + # This comment is left unintentionally blank. rpc :FindAllTagNames, ::Gitaly::FindAllTagNamesRequest, stream(::Gitaly::FindAllTagNamesResponse) # Return a stream so we can divide the response in chunks of branches rpc :FindLocalBranches, ::Gitaly::FindLocalBranchesRequest, stream(::Gitaly::FindLocalBranchesResponse) + # This comment is left unintentionally blank. rpc :FindAllBranches, ::Gitaly::FindAllBranchesRequest, stream(::Gitaly::FindAllBranchesResponse) # Returns a stream of tags repository has. rpc :FindAllTags, ::Gitaly::FindAllTagsRequest, stream(::Gitaly::FindAllTagsResponse) + # This comment is left unintentionally blank. rpc :FindTag, ::Gitaly::FindTagRequest, ::Gitaly::FindTagResponse + # This comment is left unintentionally blank. rpc :FindAllRemoteBranches, ::Gitaly::FindAllRemoteBranchesRequest, stream(::Gitaly::FindAllRemoteBranchesResponse) + # This comment is left unintentionally blank. rpc :RefExists, ::Gitaly::RefExistsRequest, ::Gitaly::RefExistsResponse # FindBranch finds a branch by its unqualified name (like "master") and # returns the commit it currently points to. rpc :FindBranch, ::Gitaly::FindBranchRequest, ::Gitaly::FindBranchResponse + # This comment is left unintentionally blank. rpc :DeleteRefs, ::Gitaly::DeleteRefsRequest, ::Gitaly::DeleteRefsResponse + # This comment is left unintentionally blank. rpc :ListBranchNamesContainingCommit, ::Gitaly::ListBranchNamesContainingCommitRequest, stream(::Gitaly::ListBranchNamesContainingCommitResponse) + # This comment is left unintentionally blank. rpc :ListTagNamesContainingCommit, ::Gitaly::ListTagNamesContainingCommitRequest, stream(::Gitaly::ListTagNamesContainingCommitResponse) # GetTagSignatures returns signatures for annotated tags resolved from a set of revisions. Revisions # which don't resolve to an annotated tag are silently discarded. Revisions which cannot be resolved # result in an error. Tags which are annotated but not signed will return a TagSignature response # which has no signature, but its unsigned contents will still be returned. rpc :GetTagSignatures, ::Gitaly::GetTagSignaturesRequest, stream(::Gitaly::GetTagSignaturesResponse) + # This comment is left unintentionally blank. rpc :GetTagMessages, ::Gitaly::GetTagMessagesRequest, stream(::Gitaly::GetTagMessagesResponse) # PackRefs is deprecated in favor of OptimizeRepository. rpc :PackRefs, ::Gitaly::PackRefsRequest, ::Gitaly::PackRefsResponse diff --git a/ruby/proto/gitaly/remote_services_pb.rb b/ruby/proto/gitaly/remote_services_pb.rb index c8fce6ae1..08f7ed80d 100644 --- a/ruby/proto/gitaly/remote_services_pb.rb +++ b/ruby/proto/gitaly/remote_services_pb.rb @@ -22,6 +22,7 @@ module Gitaly # deleted from the mirror. UpdateRemoteMirror updates all tags. Branches are updated if they match # the patterns specified in the requests. rpc :UpdateRemoteMirror, stream(::Gitaly::UpdateRemoteMirrorRequest), ::Gitaly::UpdateRemoteMirrorResponse + # This comment is left unintentionally blank. rpc :FindRemoteRepository, ::Gitaly::FindRemoteRepositoryRequest, ::Gitaly::FindRemoteRepositoryResponse # FindRemoteRootRef tries to find the root reference of a remote # repository. The root reference is the default branch as pointed to by diff --git a/ruby/proto/gitaly/repository_services_pb.rb b/ruby/proto/gitaly/repository_services_pb.rb index 25f339ac2..e7043c8aa 100644 --- a/ruby/proto/gitaly/repository_services_pb.rb +++ b/ruby/proto/gitaly/repository_services_pb.rb @@ -15,6 +15,7 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.RepositoryService' + # This comment is left unintentionally blank. rpc :RepositoryExists, ::Gitaly::RepositoryExistsRequest, ::Gitaly::RepositoryExistsResponse # RepackIncremental is deprecated in favor of OptimizeRepository. rpc :RepackIncremental, ::Gitaly::RepackIncrementalRequest, ::Gitaly::RepackIncrementalResponse @@ -26,21 +27,31 @@ module Gitaly rpc :GarbageCollect, ::Gitaly::GarbageCollectRequest, ::Gitaly::GarbageCollectResponse # WriteCommitGraph is deprecated in favor of OptimizeRepository. rpc :WriteCommitGraph, ::Gitaly::WriteCommitGraphRequest, ::Gitaly::WriteCommitGraphResponse + # This comment is left unintentionally blank. rpc :RepositorySize, ::Gitaly::RepositorySizeRequest, ::Gitaly::RepositorySizeResponse + # This comment is left unintentionally blank. rpc :ApplyGitattributes, ::Gitaly::ApplyGitattributesRequest, ::Gitaly::ApplyGitattributesResponse # FetchRemote fetches references from a remote repository into the local # repository. rpc :FetchRemote, ::Gitaly::FetchRemoteRequest, ::Gitaly::FetchRemoteResponse + # This comment is left unintentionally blank. rpc :CreateRepository, ::Gitaly::CreateRepositoryRequest, ::Gitaly::CreateRepositoryResponse + # This comment is left unintentionally blank. rpc :GetArchive, ::Gitaly::GetArchiveRequest, stream(::Gitaly::GetArchiveResponse) + # This comment is left unintentionally blank. rpc :HasLocalBranches, ::Gitaly::HasLocalBranchesRequest, ::Gitaly::HasLocalBranchesResponse # FetchSourceBranch fetches a branch from a second (potentially remote) # repository into the given repository. rpc :FetchSourceBranch, ::Gitaly::FetchSourceBranchRequest, ::Gitaly::FetchSourceBranchResponse + # This comment is left unintentionally blank. rpc :Fsck, ::Gitaly::FsckRequest, ::Gitaly::FsckResponse + # This comment is left unintentionally blank. rpc :WriteRef, ::Gitaly::WriteRefRequest, ::Gitaly::WriteRefResponse + # This comment is left unintentionally blank. rpc :FindMergeBase, ::Gitaly::FindMergeBaseRequest, ::Gitaly::FindMergeBaseResponse + # This comment is left unintentionally blank. rpc :CreateFork, ::Gitaly::CreateForkRequest, ::Gitaly::CreateForkResponse + # This comment is left unintentionally blank. rpc :CreateRepositoryFromURL, ::Gitaly::CreateRepositoryFromURLRequest, ::Gitaly::CreateRepositoryFromURLResponse # CreateBundle creates a bundle from all refs rpc :CreateBundle, ::Gitaly::CreateBundleRequest, stream(::Gitaly::CreateBundleResponse) @@ -51,28 +62,42 @@ module Gitaly # Refs will be mirrored to the target repository with the refspec # "+refs/*:refs/*" and refs that do not exist in the bundle will be removed. rpc :FetchBundle, stream(::Gitaly::FetchBundleRequest), ::Gitaly::FetchBundleResponse + # This comment is left unintentionally blank. rpc :CreateRepositoryFromBundle, stream(::Gitaly::CreateRepositoryFromBundleRequest), ::Gitaly::CreateRepositoryFromBundleResponse # GetConfig reads the target repository's gitconfig and streams its contents # back. Returns a NotFound error in case no gitconfig was found. rpc :GetConfig, ::Gitaly::GetConfigRequest, stream(::Gitaly::GetConfigResponse) + # This comment is left unintentionally blank. rpc :FindLicense, ::Gitaly::FindLicenseRequest, ::Gitaly::FindLicenseResponse + # This comment is left unintentionally blank. rpc :GetInfoAttributes, ::Gitaly::GetInfoAttributesRequest, stream(::Gitaly::GetInfoAttributesResponse) + # This comment is left unintentionally blank. rpc :CalculateChecksum, ::Gitaly::CalculateChecksumRequest, ::Gitaly::CalculateChecksumResponse # Cleanup is deprecated in favor of OptimizeRepository. rpc :Cleanup, ::Gitaly::CleanupRequest, ::Gitaly::CleanupResponse + # This comment is left unintentionally blank. rpc :GetSnapshot, ::Gitaly::GetSnapshotRequest, stream(::Gitaly::GetSnapshotResponse) + # This comment is left unintentionally blank. rpc :CreateRepositoryFromSnapshot, ::Gitaly::CreateRepositoryFromSnapshotRequest, ::Gitaly::CreateRepositoryFromSnapshotResponse + # This comment is left unintentionally blank. rpc :GetRawChanges, ::Gitaly::GetRawChangesRequest, stream(::Gitaly::GetRawChangesResponse) + # This comment is left unintentionally blank. rpc :SearchFilesByContent, ::Gitaly::SearchFilesByContentRequest, stream(::Gitaly::SearchFilesByContentResponse) + # This comment is left unintentionally blank. rpc :SearchFilesByName, ::Gitaly::SearchFilesByNameRequest, stream(::Gitaly::SearchFilesByNameResponse) + # This comment is left unintentionally blank. rpc :RestoreCustomHooks, stream(::Gitaly::RestoreCustomHooksRequest), ::Gitaly::RestoreCustomHooksResponse + # This comment is left unintentionally blank. rpc :BackupCustomHooks, ::Gitaly::BackupCustomHooksRequest, stream(::Gitaly::BackupCustomHooksResponse) + # This comment is left unintentionally blank. rpc :GetObjectDirectorySize, ::Gitaly::GetObjectDirectorySizeRequest, ::Gitaly::GetObjectDirectorySizeResponse # RemoveRepository will move the repository to `+gitaly/tmp/<relative_path>_removed` and # eventually remove it. This ensures that even on networked filesystems the # data is actually removed even if there's someone still handling the data. rpc :RemoveRepository, ::Gitaly::RemoveRepositoryRequest, ::Gitaly::RemoveRepositoryResponse + # This comment is left unintentionally blank. rpc :RenameRepository, ::Gitaly::RenameRepositoryRequest, ::Gitaly::RenameRepositoryResponse + # This comment is left unintentionally blank. rpc :ReplicateRepository, ::Gitaly::ReplicateRepositoryRequest, ::Gitaly::ReplicateRepositoryResponse # OptimizeRepository performs all maintenance tasks in a repository to keep # it in an efficient state. It cleans up stale data, repacks objects, diff --git a/ruby/proto/gitaly/server_services_pb.rb b/ruby/proto/gitaly/server_services_pb.rb index 1d76e8667..37d7825f7 100644 --- a/ruby/proto/gitaly/server_services_pb.rb +++ b/ruby/proto/gitaly/server_services_pb.rb @@ -15,7 +15,9 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.ServerService' + # This comment is left unintentionally blank. rpc :ServerInfo, ::Gitaly::ServerInfoRequest, ::Gitaly::ServerInfoResponse + # This comment is left unintentionally blank. rpc :DiskStatistics, ::Gitaly::DiskStatisticsRequest, ::Gitaly::DiskStatisticsResponse # ClockSynced checks if machine clock is synced # (the offset is less that the one passed in the request). diff --git a/ruby/proto/gitaly/transaction_services_pb.rb b/ruby/proto/gitaly/transaction_services_pb.rb index 58c8bfe40..639d465bc 100644 --- a/ruby/proto/gitaly/transaction_services_pb.rb +++ b/ruby/proto/gitaly/transaction_services_pb.rb @@ -19,7 +19,28 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.RefTransaction' + # VoteTransaction casts a vote on a transaction to establish whether the + # node is doing the same change as all the other nodes part of the + # transaction. This RPC blocks until quorum has been reached, which may be + # _before_ all nodes have cast a vote. + # + # This RPC may return one of the following error codes: + # + # - `NotFound` in case the transaction could not be found. + # - `Canceled` in case the transaction has been canceled before quorum was + # reached. rpc :VoteTransaction, ::Gitaly::VoteTransactionRequest, ::Gitaly::VoteTransactionResponse + # StopTransaction gracefully stops a transaction. This RPC can be used if + # only a subset of nodes executes specific code which may cause the + # transaction to fail. One such example is Git hooks, which only execute on + # the primary Gitaly noded. Other nodes which vote on this transaction will + # get a response with the `STOP` state being set. + # + # This RPC may return one of the following error codes: + # + # - `NotFound` in case the transaction could not be found. + # - `Canceled` in case the transaction has been canceled before quorum was + # reached. rpc :StopTransaction, ::Gitaly::StopTransactionRequest, ::Gitaly::StopTransactionResponse end diff --git a/ruby/proto/gitaly/wiki_services_pb.rb b/ruby/proto/gitaly/wiki_services_pb.rb index 2304ff3a7..16ccdd1cb 100644 --- a/ruby/proto/gitaly/wiki_services_pb.rb +++ b/ruby/proto/gitaly/wiki_services_pb.rb @@ -17,11 +17,15 @@ module Gitaly self.unmarshal_class_method = :decode self.service_name = 'gitaly.WikiService' + # This comment is left unintentionally blank. rpc :WikiWritePage, stream(::Gitaly::WikiWritePageRequest), ::Gitaly::WikiWritePageResponse + # This comment is left unintentionally blank. rpc :WikiUpdatePage, stream(::Gitaly::WikiUpdatePageRequest), ::Gitaly::WikiUpdatePageResponse # WikiFindPage returns a stream because the page's raw_data field may be arbitrarily large. rpc :WikiFindPage, ::Gitaly::WikiFindPageRequest, stream(::Gitaly::WikiFindPageResponse) + # This comment is left unintentionally blank. rpc :WikiGetAllPages, ::Gitaly::WikiGetAllPagesRequest, stream(::Gitaly::WikiGetAllPagesResponse) + # This comment is left unintentionally blank. rpc :WikiListPages, ::Gitaly::WikiListPagesRequest, stream(::Gitaly::WikiListPagesResponse) end |