diff options
Diffstat (limited to 'proto/go/gitalypb/repository-service_grpc.pb.go')
| -rw-r--r-- | proto/go/gitalypb/repository-service_grpc.pb.go | 90 |
1 files changed, 81 insertions, 9 deletions
diff --git a/proto/go/gitalypb/repository-service_grpc.pb.go b/proto/go/gitalypb/repository-service_grpc.pb.go index 340c1b347..42c338872 100644 --- a/proto/go/gitalypb/repository-service_grpc.pb.go +++ b/proto/go/gitalypb/repository-service_grpc.pb.go @@ -42,7 +42,10 @@ type RepositoryServiceClient interface { IsRebaseInProgress(ctx context.Context, in *IsRebaseInProgressRequest, opts ...grpc.CallOption) (*IsRebaseInProgressResponse, error) IsSquashInProgress(ctx context.Context, in *IsSquashInProgressRequest, opts ...grpc.CallOption) (*IsSquashInProgressResponse, error) 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) + // CreateBundleFromRefList creates a bundle from a stream of ref patterns + CreateBundleFromRefList(ctx context.Context, opts ...grpc.CallOption) (RepositoryService_CreateBundleFromRefListClient, error) 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. @@ -320,8 +323,39 @@ func (x *repositoryServiceCreateBundleClient) Recv() (*CreateBundleResponse, err return m, nil } +func (c *repositoryServiceClient) CreateBundleFromRefList(ctx context.Context, opts ...grpc.CallOption) (RepositoryService_CreateBundleFromRefListClient, error) { + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[2], "/gitaly.RepositoryService/CreateBundleFromRefList", opts...) + if err != nil { + return nil, err + } + x := &repositoryServiceCreateBundleFromRefListClient{stream} + return x, nil +} + +type RepositoryService_CreateBundleFromRefListClient interface { + Send(*CreateBundleFromRefListRequest) error + Recv() (*CreateBundleFromRefListResponse, error) + grpc.ClientStream +} + +type repositoryServiceCreateBundleFromRefListClient struct { + grpc.ClientStream +} + +func (x *repositoryServiceCreateBundleFromRefListClient) Send(m *CreateBundleFromRefListRequest) error { + return x.ClientStream.SendMsg(m) +} + +func (x *repositoryServiceCreateBundleFromRefListClient) Recv() (*CreateBundleFromRefListResponse, error) { + m := new(CreateBundleFromRefListResponse) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + func (c *repositoryServiceClient) CreateRepositoryFromBundle(ctx context.Context, opts ...grpc.CallOption) (RepositoryService_CreateRepositoryFromBundleClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[2], "/gitaly.RepositoryService/CreateRepositoryFromBundle", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[3], "/gitaly.RepositoryService/CreateRepositoryFromBundle", opts...) if err != nil { return nil, err } @@ -355,7 +389,7 @@ func (x *repositoryServiceCreateRepositoryFromBundleClient) CloseAndRecv() (*Cre } func (c *repositoryServiceClient) GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (RepositoryService_GetConfigClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[3], "/gitaly.RepositoryService/GetConfig", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[4], "/gitaly.RepositoryService/GetConfig", opts...) if err != nil { return nil, err } @@ -414,7 +448,7 @@ func (c *repositoryServiceClient) FindLicense(ctx context.Context, in *FindLicen } func (c *repositoryServiceClient) GetInfoAttributes(ctx context.Context, in *GetInfoAttributesRequest, opts ...grpc.CallOption) (RepositoryService_GetInfoAttributesClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[4], "/gitaly.RepositoryService/GetInfoAttributes", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[5], "/gitaly.RepositoryService/GetInfoAttributes", opts...) if err != nil { return nil, err } @@ -464,7 +498,7 @@ func (c *repositoryServiceClient) Cleanup(ctx context.Context, in *CleanupReques } func (c *repositoryServiceClient) GetSnapshot(ctx context.Context, in *GetSnapshotRequest, opts ...grpc.CallOption) (RepositoryService_GetSnapshotClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[5], "/gitaly.RepositoryService/GetSnapshot", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[6], "/gitaly.RepositoryService/GetSnapshot", opts...) if err != nil { return nil, err } @@ -505,7 +539,7 @@ func (c *repositoryServiceClient) CreateRepositoryFromSnapshot(ctx context.Conte } func (c *repositoryServiceClient) GetRawChanges(ctx context.Context, in *GetRawChangesRequest, opts ...grpc.CallOption) (RepositoryService_GetRawChangesClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[6], "/gitaly.RepositoryService/GetRawChanges", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[7], "/gitaly.RepositoryService/GetRawChanges", opts...) if err != nil { return nil, err } @@ -537,7 +571,7 @@ func (x *repositoryServiceGetRawChangesClient) Recv() (*GetRawChangesResponse, e } func (c *repositoryServiceClient) SearchFilesByContent(ctx context.Context, in *SearchFilesByContentRequest, opts ...grpc.CallOption) (RepositoryService_SearchFilesByContentClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[7], "/gitaly.RepositoryService/SearchFilesByContent", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[8], "/gitaly.RepositoryService/SearchFilesByContent", opts...) if err != nil { return nil, err } @@ -569,7 +603,7 @@ func (x *repositoryServiceSearchFilesByContentClient) Recv() (*SearchFilesByCont } func (c *repositoryServiceClient) SearchFilesByName(ctx context.Context, in *SearchFilesByNameRequest, opts ...grpc.CallOption) (RepositoryService_SearchFilesByNameClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[8], "/gitaly.RepositoryService/SearchFilesByName", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[9], "/gitaly.RepositoryService/SearchFilesByName", opts...) if err != nil { return nil, err } @@ -601,7 +635,7 @@ func (x *repositoryServiceSearchFilesByNameClient) Recv() (*SearchFilesByNameRes } func (c *repositoryServiceClient) RestoreCustomHooks(ctx context.Context, opts ...grpc.CallOption) (RepositoryService_RestoreCustomHooksClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[9], "/gitaly.RepositoryService/RestoreCustomHooks", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[10], "/gitaly.RepositoryService/RestoreCustomHooks", opts...) if err != nil { return nil, err } @@ -635,7 +669,7 @@ func (x *repositoryServiceRestoreCustomHooksClient) CloseAndRecv() (*RestoreCust } func (c *repositoryServiceClient) BackupCustomHooks(ctx context.Context, in *BackupCustomHooksRequest, opts ...grpc.CallOption) (RepositoryService_BackupCustomHooksClient, error) { - stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[10], "/gitaly.RepositoryService/BackupCustomHooks", opts...) + stream, err := c.cc.NewStream(ctx, &RepositoryService_ServiceDesc.Streams[11], "/gitaly.RepositoryService/BackupCustomHooks", opts...) if err != nil { return nil, err } @@ -766,7 +800,10 @@ type RepositoryServiceServer interface { IsRebaseInProgress(context.Context, *IsRebaseInProgressRequest) (*IsRebaseInProgressResponse, error) IsSquashInProgress(context.Context, *IsSquashInProgressRequest) (*IsSquashInProgressResponse, error) CreateRepositoryFromURL(context.Context, *CreateRepositoryFromURLRequest) (*CreateRepositoryFromURLResponse, error) + // CreateBundle creates a bundle from all refs CreateBundle(*CreateBundleRequest, RepositoryService_CreateBundleServer) error + // CreateBundleFromRefList creates a bundle from a stream of ref patterns + CreateBundleFromRefList(RepositoryService_CreateBundleFromRefListServer) error 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. @@ -869,6 +906,9 @@ func (UnimplementedRepositoryServiceServer) CreateRepositoryFromURL(context.Cont func (UnimplementedRepositoryServiceServer) CreateBundle(*CreateBundleRequest, RepositoryService_CreateBundleServer) error { return status.Errorf(codes.Unimplemented, "method CreateBundle not implemented") } +func (UnimplementedRepositoryServiceServer) CreateBundleFromRefList(RepositoryService_CreateBundleFromRefListServer) error { + return status.Errorf(codes.Unimplemented, "method CreateBundleFromRefList not implemented") +} func (UnimplementedRepositoryServiceServer) CreateRepositoryFromBundle(RepositoryService_CreateRepositoryFromBundleServer) error { return status.Errorf(codes.Unimplemented, "method CreateRepositoryFromBundle not implemented") } @@ -1335,6 +1375,32 @@ func (x *repositoryServiceCreateBundleServer) Send(m *CreateBundleResponse) erro return x.ServerStream.SendMsg(m) } +func _RepositoryService_CreateBundleFromRefList_Handler(srv interface{}, stream grpc.ServerStream) error { + return srv.(RepositoryServiceServer).CreateBundleFromRefList(&repositoryServiceCreateBundleFromRefListServer{stream}) +} + +type RepositoryService_CreateBundleFromRefListServer interface { + Send(*CreateBundleFromRefListResponse) error + Recv() (*CreateBundleFromRefListRequest, error) + grpc.ServerStream +} + +type repositoryServiceCreateBundleFromRefListServer struct { + grpc.ServerStream +} + +func (x *repositoryServiceCreateBundleFromRefListServer) Send(m *CreateBundleFromRefListResponse) error { + return x.ServerStream.SendMsg(m) +} + +func (x *repositoryServiceCreateBundleFromRefListServer) Recv() (*CreateBundleFromRefListRequest, error) { + m := new(CreateBundleFromRefListRequest) + if err := x.ServerStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + func _RepositoryService_CreateRepositoryFromBundle_Handler(srv interface{}, stream grpc.ServerStream) error { return srv.(RepositoryServiceServer).CreateRepositoryFromBundle(&repositoryServiceCreateRepositoryFromBundleServer{stream}) } @@ -1938,6 +2004,12 @@ var RepositoryService_ServiceDesc = grpc.ServiceDesc{ ServerStreams: true, }, { + StreamName: "CreateBundleFromRefList", + Handler: _RepositoryService_CreateBundleFromRefList_Handler, + ServerStreams: true, + ClientStreams: true, + }, + { StreamName: "CreateRepositoryFromBundle", Handler: _RepositoryService_CreateRepositoryFromBundle_Handler, ClientStreams: true, |