1// Code generated by protoc-gen-go-grpc. DO NOT EDIT. 2 3package gitalypb 4 5import ( 6 context "context" 7 grpc "google.golang.org/grpc" 8 codes "google.golang.org/grpc/codes" 9 status "google.golang.org/grpc/status" 10) 11 12// This is a compile-time assertion to ensure that this generated file 13// is compatible with the grpc package it is being compiled against. 14// Requires gRPC-Go v1.32.0 or later. 15const _ = grpc.SupportPackageIsVersion7 16 17// SmartHTTPServiceClient is the client API for SmartHTTPService service. 18// 19// 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. 20type SmartHTTPServiceClient interface { 21 // The response body for GET /info/refs?service=git-upload-pack 22 // Will be invoked when the user executes a `git fetch`, meaning the server 23 // will upload the packs to that user. The user doesn't upload new objects. 24 InfoRefsUploadPack(ctx context.Context, in *InfoRefsRequest, opts ...grpc.CallOption) (SmartHTTPService_InfoRefsUploadPackClient, error) 25 // The response body for GET /info/refs?service=git-receive-pack 26 // Will be invoked when the user executes a `git push`, but only advertises 27 // references to the user. 28 InfoRefsReceivePack(ctx context.Context, in *InfoRefsRequest, opts ...grpc.CallOption) (SmartHTTPService_InfoRefsReceivePackClient, error) 29 // Request and response body for POST /upload-pack 30 PostUploadPack(ctx context.Context, opts ...grpc.CallOption) (SmartHTTPService_PostUploadPackClient, error) 31 // Request and response body for POST /upload-pack using sidechannel protocol 32 PostUploadPackWithSidechannel(ctx context.Context, in *PostUploadPackWithSidechannelRequest, opts ...grpc.CallOption) (*PostUploadPackWithSidechannelResponse, error) 33 // Request and response body for POST /receive-pack 34 PostReceivePack(ctx context.Context, opts ...grpc.CallOption) (SmartHTTPService_PostReceivePackClient, error) 35} 36 37type smartHTTPServiceClient struct { 38 cc grpc.ClientConnInterface 39} 40 41func NewSmartHTTPServiceClient(cc grpc.ClientConnInterface) SmartHTTPServiceClient { 42 return &smartHTTPServiceClient{cc} 43} 44 45func (c *smartHTTPServiceClient) InfoRefsUploadPack(ctx context.Context, in *InfoRefsRequest, opts ...grpc.CallOption) (SmartHTTPService_InfoRefsUploadPackClient, error) { 46 stream, err := c.cc.NewStream(ctx, &SmartHTTPService_ServiceDesc.Streams[0], "/gitaly.SmartHTTPService/InfoRefsUploadPack", opts...) 47 if err != nil { 48 return nil, err 49 } 50 x := &smartHTTPServiceInfoRefsUploadPackClient{stream} 51 if err := x.ClientStream.SendMsg(in); err != nil { 52 return nil, err 53 } 54 if err := x.ClientStream.CloseSend(); err != nil { 55 return nil, err 56 } 57 return x, nil 58} 59 60type SmartHTTPService_InfoRefsUploadPackClient interface { 61 Recv() (*InfoRefsResponse, error) 62 grpc.ClientStream 63} 64 65type smartHTTPServiceInfoRefsUploadPackClient struct { 66 grpc.ClientStream 67} 68 69func (x *smartHTTPServiceInfoRefsUploadPackClient) Recv() (*InfoRefsResponse, error) { 70 m := new(InfoRefsResponse) 71 if err := x.ClientStream.RecvMsg(m); err != nil { 72 return nil, err 73 } 74 return m, nil 75} 76 77func (c *smartHTTPServiceClient) InfoRefsReceivePack(ctx context.Context, in *InfoRefsRequest, opts ...grpc.CallOption) (SmartHTTPService_InfoRefsReceivePackClient, error) { 78 stream, err := c.cc.NewStream(ctx, &SmartHTTPService_ServiceDesc.Streams[1], "/gitaly.SmartHTTPService/InfoRefsReceivePack", opts...) 79 if err != nil { 80 return nil, err 81 } 82 x := &smartHTTPServiceInfoRefsReceivePackClient{stream} 83 if err := x.ClientStream.SendMsg(in); err != nil { 84 return nil, err 85 } 86 if err := x.ClientStream.CloseSend(); err != nil { 87 return nil, err 88 } 89 return x, nil 90} 91 92type SmartHTTPService_InfoRefsReceivePackClient interface { 93 Recv() (*InfoRefsResponse, error) 94 grpc.ClientStream 95} 96 97type smartHTTPServiceInfoRefsReceivePackClient struct { 98 grpc.ClientStream 99} 100 101func (x *smartHTTPServiceInfoRefsReceivePackClient) Recv() (*InfoRefsResponse, error) { 102 m := new(InfoRefsResponse) 103 if err := x.ClientStream.RecvMsg(m); err != nil { 104 return nil, err 105 } 106 return m, nil 107} 108 109func (c *smartHTTPServiceClient) PostUploadPack(ctx context.Context, opts ...grpc.CallOption) (SmartHTTPService_PostUploadPackClient, error) { 110 stream, err := c.cc.NewStream(ctx, &SmartHTTPService_ServiceDesc.Streams[2], "/gitaly.SmartHTTPService/PostUploadPack", opts...) 111 if err != nil { 112 return nil, err 113 } 114 x := &smartHTTPServicePostUploadPackClient{stream} 115 return x, nil 116} 117 118type SmartHTTPService_PostUploadPackClient interface { 119 Send(*PostUploadPackRequest) error 120 Recv() (*PostUploadPackResponse, error) 121 grpc.ClientStream 122} 123 124type smartHTTPServicePostUploadPackClient struct { 125 grpc.ClientStream 126} 127 128func (x *smartHTTPServicePostUploadPackClient) Send(m *PostUploadPackRequest) error { 129 return x.ClientStream.SendMsg(m) 130} 131 132func (x *smartHTTPServicePostUploadPackClient) Recv() (*PostUploadPackResponse, error) { 133 m := new(PostUploadPackResponse) 134 if err := x.ClientStream.RecvMsg(m); err != nil { 135 return nil, err 136 } 137 return m, nil 138} 139 140func (c *smartHTTPServiceClient) PostUploadPackWithSidechannel(ctx context.Context, in *PostUploadPackWithSidechannelRequest, opts ...grpc.CallOption) (*PostUploadPackWithSidechannelResponse, error) { 141 out := new(PostUploadPackWithSidechannelResponse) 142 err := c.cc.Invoke(ctx, "/gitaly.SmartHTTPService/PostUploadPackWithSidechannel", in, out, opts...) 143 if err != nil { 144 return nil, err 145 } 146 return out, nil 147} 148 149func (c *smartHTTPServiceClient) PostReceivePack(ctx context.Context, opts ...grpc.CallOption) (SmartHTTPService_PostReceivePackClient, error) { 150 stream, err := c.cc.NewStream(ctx, &SmartHTTPService_ServiceDesc.Streams[3], "/gitaly.SmartHTTPService/PostReceivePack", opts...) 151 if err != nil { 152 return nil, err 153 } 154 x := &smartHTTPServicePostReceivePackClient{stream} 155 return x, nil 156} 157 158type SmartHTTPService_PostReceivePackClient interface { 159 Send(*PostReceivePackRequest) error 160 Recv() (*PostReceivePackResponse, error) 161 grpc.ClientStream 162} 163 164type smartHTTPServicePostReceivePackClient struct { 165 grpc.ClientStream 166} 167 168func (x *smartHTTPServicePostReceivePackClient) Send(m *PostReceivePackRequest) error { 169 return x.ClientStream.SendMsg(m) 170} 171 172func (x *smartHTTPServicePostReceivePackClient) Recv() (*PostReceivePackResponse, error) { 173 m := new(PostReceivePackResponse) 174 if err := x.ClientStream.RecvMsg(m); err != nil { 175 return nil, err 176 } 177 return m, nil 178} 179 180// SmartHTTPServiceServer is the server API for SmartHTTPService service. 181// All implementations must embed UnimplementedSmartHTTPServiceServer 182// for forward compatibility 183type SmartHTTPServiceServer interface { 184 // The response body for GET /info/refs?service=git-upload-pack 185 // Will be invoked when the user executes a `git fetch`, meaning the server 186 // will upload the packs to that user. The user doesn't upload new objects. 187 InfoRefsUploadPack(*InfoRefsRequest, SmartHTTPService_InfoRefsUploadPackServer) error 188 // The response body for GET /info/refs?service=git-receive-pack 189 // Will be invoked when the user executes a `git push`, but only advertises 190 // references to the user. 191 InfoRefsReceivePack(*InfoRefsRequest, SmartHTTPService_InfoRefsReceivePackServer) error 192 // Request and response body for POST /upload-pack 193 PostUploadPack(SmartHTTPService_PostUploadPackServer) error 194 // Request and response body for POST /upload-pack using sidechannel protocol 195 PostUploadPackWithSidechannel(context.Context, *PostUploadPackWithSidechannelRequest) (*PostUploadPackWithSidechannelResponse, error) 196 // Request and response body for POST /receive-pack 197 PostReceivePack(SmartHTTPService_PostReceivePackServer) error 198 mustEmbedUnimplementedSmartHTTPServiceServer() 199} 200 201// UnimplementedSmartHTTPServiceServer must be embedded to have forward compatible implementations. 202type UnimplementedSmartHTTPServiceServer struct { 203} 204 205func (UnimplementedSmartHTTPServiceServer) InfoRefsUploadPack(*InfoRefsRequest, SmartHTTPService_InfoRefsUploadPackServer) error { 206 return status.Errorf(codes.Unimplemented, "method InfoRefsUploadPack not implemented") 207} 208func (UnimplementedSmartHTTPServiceServer) InfoRefsReceivePack(*InfoRefsRequest, SmartHTTPService_InfoRefsReceivePackServer) error { 209 return status.Errorf(codes.Unimplemented, "method InfoRefsReceivePack not implemented") 210} 211func (UnimplementedSmartHTTPServiceServer) PostUploadPack(SmartHTTPService_PostUploadPackServer) error { 212 return status.Errorf(codes.Unimplemented, "method PostUploadPack not implemented") 213} 214func (UnimplementedSmartHTTPServiceServer) PostUploadPackWithSidechannel(context.Context, *PostUploadPackWithSidechannelRequest) (*PostUploadPackWithSidechannelResponse, error) { 215 return nil, status.Errorf(codes.Unimplemented, "method PostUploadPackWithSidechannel not implemented") 216} 217func (UnimplementedSmartHTTPServiceServer) PostReceivePack(SmartHTTPService_PostReceivePackServer) error { 218 return status.Errorf(codes.Unimplemented, "method PostReceivePack not implemented") 219} 220func (UnimplementedSmartHTTPServiceServer) mustEmbedUnimplementedSmartHTTPServiceServer() {} 221 222// UnsafeSmartHTTPServiceServer may be embedded to opt out of forward compatibility for this service. 223// Use of this interface is not recommended, as added methods to SmartHTTPServiceServer will 224// result in compilation errors. 225type UnsafeSmartHTTPServiceServer interface { 226 mustEmbedUnimplementedSmartHTTPServiceServer() 227} 228 229func RegisterSmartHTTPServiceServer(s grpc.ServiceRegistrar, srv SmartHTTPServiceServer) { 230 s.RegisterService(&SmartHTTPService_ServiceDesc, srv) 231} 232 233func _SmartHTTPService_InfoRefsUploadPack_Handler(srv interface{}, stream grpc.ServerStream) error { 234 m := new(InfoRefsRequest) 235 if err := stream.RecvMsg(m); err != nil { 236 return err 237 } 238 return srv.(SmartHTTPServiceServer).InfoRefsUploadPack(m, &smartHTTPServiceInfoRefsUploadPackServer{stream}) 239} 240 241type SmartHTTPService_InfoRefsUploadPackServer interface { 242 Send(*InfoRefsResponse) error 243 grpc.ServerStream 244} 245 246type smartHTTPServiceInfoRefsUploadPackServer struct { 247 grpc.ServerStream 248} 249 250func (x *smartHTTPServiceInfoRefsUploadPackServer) Send(m *InfoRefsResponse) error { 251 return x.ServerStream.SendMsg(m) 252} 253 254func _SmartHTTPService_InfoRefsReceivePack_Handler(srv interface{}, stream grpc.ServerStream) error { 255 m := new(InfoRefsRequest) 256 if err := stream.RecvMsg(m); err != nil { 257 return err 258 } 259 return srv.(SmartHTTPServiceServer).InfoRefsReceivePack(m, &smartHTTPServiceInfoRefsReceivePackServer{stream}) 260} 261 262type SmartHTTPService_InfoRefsReceivePackServer interface { 263 Send(*InfoRefsResponse) error 264 grpc.ServerStream 265} 266 267type smartHTTPServiceInfoRefsReceivePackServer struct { 268 grpc.ServerStream 269} 270 271func (x *smartHTTPServiceInfoRefsReceivePackServer) Send(m *InfoRefsResponse) error { 272 return x.ServerStream.SendMsg(m) 273} 274 275func _SmartHTTPService_PostUploadPack_Handler(srv interface{}, stream grpc.ServerStream) error { 276 return srv.(SmartHTTPServiceServer).PostUploadPack(&smartHTTPServicePostUploadPackServer{stream}) 277} 278 279type SmartHTTPService_PostUploadPackServer interface { 280 Send(*PostUploadPackResponse) error 281 Recv() (*PostUploadPackRequest, error) 282 grpc.ServerStream 283} 284 285type smartHTTPServicePostUploadPackServer struct { 286 grpc.ServerStream 287} 288 289func (x *smartHTTPServicePostUploadPackServer) Send(m *PostUploadPackResponse) error { 290 return x.ServerStream.SendMsg(m) 291} 292 293func (x *smartHTTPServicePostUploadPackServer) Recv() (*PostUploadPackRequest, error) { 294 m := new(PostUploadPackRequest) 295 if err := x.ServerStream.RecvMsg(m); err != nil { 296 return nil, err 297 } 298 return m, nil 299} 300 301func _SmartHTTPService_PostUploadPackWithSidechannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 302 in := new(PostUploadPackWithSidechannelRequest) 303 if err := dec(in); err != nil { 304 return nil, err 305 } 306 if interceptor == nil { 307 return srv.(SmartHTTPServiceServer).PostUploadPackWithSidechannel(ctx, in) 308 } 309 info := &grpc.UnaryServerInfo{ 310 Server: srv, 311 FullMethod: "/gitaly.SmartHTTPService/PostUploadPackWithSidechannel", 312 } 313 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 314 return srv.(SmartHTTPServiceServer).PostUploadPackWithSidechannel(ctx, req.(*PostUploadPackWithSidechannelRequest)) 315 } 316 return interceptor(ctx, in, info, handler) 317} 318 319func _SmartHTTPService_PostReceivePack_Handler(srv interface{}, stream grpc.ServerStream) error { 320 return srv.(SmartHTTPServiceServer).PostReceivePack(&smartHTTPServicePostReceivePackServer{stream}) 321} 322 323type SmartHTTPService_PostReceivePackServer interface { 324 Send(*PostReceivePackResponse) error 325 Recv() (*PostReceivePackRequest, error) 326 grpc.ServerStream 327} 328 329type smartHTTPServicePostReceivePackServer struct { 330 grpc.ServerStream 331} 332 333func (x *smartHTTPServicePostReceivePackServer) Send(m *PostReceivePackResponse) error { 334 return x.ServerStream.SendMsg(m) 335} 336 337func (x *smartHTTPServicePostReceivePackServer) Recv() (*PostReceivePackRequest, error) { 338 m := new(PostReceivePackRequest) 339 if err := x.ServerStream.RecvMsg(m); err != nil { 340 return nil, err 341 } 342 return m, nil 343} 344 345// SmartHTTPService_ServiceDesc is the grpc.ServiceDesc for SmartHTTPService service. 346// It's only intended for direct use with grpc.RegisterService, 347// and not to be introspected or modified (even as a copy) 348var SmartHTTPService_ServiceDesc = grpc.ServiceDesc{ 349 ServiceName: "gitaly.SmartHTTPService", 350 HandlerType: (*SmartHTTPServiceServer)(nil), 351 Methods: []grpc.MethodDesc{ 352 { 353 MethodName: "PostUploadPackWithSidechannel", 354 Handler: _SmartHTTPService_PostUploadPackWithSidechannel_Handler, 355 }, 356 }, 357 Streams: []grpc.StreamDesc{ 358 { 359 StreamName: "InfoRefsUploadPack", 360 Handler: _SmartHTTPService_InfoRefsUploadPack_Handler, 361 ServerStreams: true, 362 }, 363 { 364 StreamName: "InfoRefsReceivePack", 365 Handler: _SmartHTTPService_InfoRefsReceivePack_Handler, 366 ServerStreams: true, 367 }, 368 { 369 StreamName: "PostUploadPack", 370 Handler: _SmartHTTPService_PostUploadPack_Handler, 371 ServerStreams: true, 372 ClientStreams: true, 373 }, 374 { 375 StreamName: "PostReceivePack", 376 Handler: _SmartHTTPService_PostReceivePack_Handler, 377 ServerStreams: true, 378 ClientStreams: true, 379 }, 380 }, 381 Metadata: "smarthttp.proto", 382} 383