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