hold_grpc.pb.go raw
1 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
2 // versions:
3 // - protoc-gen-go-grpc v1.6.0
4 // - protoc v3.21.12
5 // source: hold.proto
6
7 package clngrpc_hold
8
9 import (
10 context "context"
11 grpc "google.golang.org/grpc"
12 codes "google.golang.org/grpc/codes"
13 status "google.golang.org/grpc/status"
14 )
15
16 // This is a compile-time assertion to ensure that this generated file
17 // is compatible with the grpc package it is being compiled against.
18 // Requires gRPC-Go v1.64.0 or later.
19 const _ = grpc.SupportPackageIsVersion9
20
21 const (
22 Hold_GetInfo_FullMethodName = "/hold.Hold/GetInfo"
23 Hold_Invoice_FullMethodName = "/hold.Hold/Invoice"
24 Hold_Inject_FullMethodName = "/hold.Hold/Inject"
25 Hold_List_FullMethodName = "/hold.Hold/List"
26 Hold_Settle_FullMethodName = "/hold.Hold/Settle"
27 Hold_Cancel_FullMethodName = "/hold.Hold/Cancel"
28 Hold_Clean_FullMethodName = "/hold.Hold/Clean"
29 Hold_Track_FullMethodName = "/hold.Hold/Track"
30 Hold_TrackAll_FullMethodName = "/hold.Hold/TrackAll"
31 Hold_OnionMessages_FullMethodName = "/hold.Hold/OnionMessages"
32 )
33
34 // HoldClient is the client API for Hold service.
35 //
36 // 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.
37 type HoldClient interface {
38 GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error)
39 Invoice(ctx context.Context, in *InvoiceRequest, opts ...grpc.CallOption) (*InvoiceResponse, error)
40 Inject(ctx context.Context, in *InjectRequest, opts ...grpc.CallOption) (*InjectResponse, error)
41 List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
42 Settle(ctx context.Context, in *SettleRequest, opts ...grpc.CallOption) (*SettleResponse, error)
43 Cancel(ctx context.Context, in *CancelRequest, opts ...grpc.CallOption) (*CancelResponse, error)
44 // Cleans cancelled invoices
45 Clean(ctx context.Context, in *CleanRequest, opts ...grpc.CallOption) (*CleanResponse, error)
46 Track(ctx context.Context, in *TrackRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TrackResponse], error)
47 TrackAll(ctx context.Context, in *TrackAllRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TrackAllResponse], error)
48 OnionMessages(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[OnionMessageResponse, OnionMessage], error)
49 }
50
51 type holdClient struct {
52 cc grpc.ClientConnInterface
53 }
54
55 func NewHoldClient(cc grpc.ClientConnInterface) HoldClient {
56 return &holdClient{cc}
57 }
58
59 func (c *holdClient) GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error) {
60 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
61 out := new(GetInfoResponse)
62 err := c.cc.Invoke(ctx, Hold_GetInfo_FullMethodName, in, out, cOpts...)
63 if err != nil {
64 return nil, err
65 }
66 return out, nil
67 }
68
69 func (c *holdClient) Invoice(ctx context.Context, in *InvoiceRequest, opts ...grpc.CallOption) (*InvoiceResponse, error) {
70 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
71 out := new(InvoiceResponse)
72 err := c.cc.Invoke(ctx, Hold_Invoice_FullMethodName, in, out, cOpts...)
73 if err != nil {
74 return nil, err
75 }
76 return out, nil
77 }
78
79 func (c *holdClient) Inject(ctx context.Context, in *InjectRequest, opts ...grpc.CallOption) (*InjectResponse, error) {
80 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
81 out := new(InjectResponse)
82 err := c.cc.Invoke(ctx, Hold_Inject_FullMethodName, in, out, cOpts...)
83 if err != nil {
84 return nil, err
85 }
86 return out, nil
87 }
88
89 func (c *holdClient) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) {
90 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
91 out := new(ListResponse)
92 err := c.cc.Invoke(ctx, Hold_List_FullMethodName, in, out, cOpts...)
93 if err != nil {
94 return nil, err
95 }
96 return out, nil
97 }
98
99 func (c *holdClient) Settle(ctx context.Context, in *SettleRequest, opts ...grpc.CallOption) (*SettleResponse, error) {
100 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
101 out := new(SettleResponse)
102 err := c.cc.Invoke(ctx, Hold_Settle_FullMethodName, in, out, cOpts...)
103 if err != nil {
104 return nil, err
105 }
106 return out, nil
107 }
108
109 func (c *holdClient) Cancel(ctx context.Context, in *CancelRequest, opts ...grpc.CallOption) (*CancelResponse, error) {
110 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
111 out := new(CancelResponse)
112 err := c.cc.Invoke(ctx, Hold_Cancel_FullMethodName, in, out, cOpts...)
113 if err != nil {
114 return nil, err
115 }
116 return out, nil
117 }
118
119 func (c *holdClient) Clean(ctx context.Context, in *CleanRequest, opts ...grpc.CallOption) (*CleanResponse, error) {
120 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
121 out := new(CleanResponse)
122 err := c.cc.Invoke(ctx, Hold_Clean_FullMethodName, in, out, cOpts...)
123 if err != nil {
124 return nil, err
125 }
126 return out, nil
127 }
128
129 func (c *holdClient) Track(ctx context.Context, in *TrackRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TrackResponse], error) {
130 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
131 stream, err := c.cc.NewStream(ctx, &Hold_ServiceDesc.Streams[0], Hold_Track_FullMethodName, cOpts...)
132 if err != nil {
133 return nil, err
134 }
135 x := &grpc.GenericClientStream[TrackRequest, TrackResponse]{ClientStream: stream}
136 if err := x.ClientStream.SendMsg(in); err != nil {
137 return nil, err
138 }
139 if err := x.ClientStream.CloseSend(); err != nil {
140 return nil, err
141 }
142 return x, nil
143 }
144
145 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
146 type Hold_TrackClient = grpc.ServerStreamingClient[TrackResponse]
147
148 func (c *holdClient) TrackAll(ctx context.Context, in *TrackAllRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[TrackAllResponse], error) {
149 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
150 stream, err := c.cc.NewStream(ctx, &Hold_ServiceDesc.Streams[1], Hold_TrackAll_FullMethodName, cOpts...)
151 if err != nil {
152 return nil, err
153 }
154 x := &grpc.GenericClientStream[TrackAllRequest, TrackAllResponse]{ClientStream: stream}
155 if err := x.ClientStream.SendMsg(in); err != nil {
156 return nil, err
157 }
158 if err := x.ClientStream.CloseSend(); err != nil {
159 return nil, err
160 }
161 return x, nil
162 }
163
164 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
165 type Hold_TrackAllClient = grpc.ServerStreamingClient[TrackAllResponse]
166
167 func (c *holdClient) OnionMessages(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[OnionMessageResponse, OnionMessage], error) {
168 cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
169 stream, err := c.cc.NewStream(ctx, &Hold_ServiceDesc.Streams[2], Hold_OnionMessages_FullMethodName, cOpts...)
170 if err != nil {
171 return nil, err
172 }
173 x := &grpc.GenericClientStream[OnionMessageResponse, OnionMessage]{ClientStream: stream}
174 return x, nil
175 }
176
177 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
178 type Hold_OnionMessagesClient = grpc.BidiStreamingClient[OnionMessageResponse, OnionMessage]
179
180 // HoldServer is the server API for Hold service.
181 // All implementations must embed UnimplementedHoldServer
182 // for forward compatibility.
183 type HoldServer interface {
184 GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error)
185 Invoice(context.Context, *InvoiceRequest) (*InvoiceResponse, error)
186 Inject(context.Context, *InjectRequest) (*InjectResponse, error)
187 List(context.Context, *ListRequest) (*ListResponse, error)
188 Settle(context.Context, *SettleRequest) (*SettleResponse, error)
189 Cancel(context.Context, *CancelRequest) (*CancelResponse, error)
190 // Cleans cancelled invoices
191 Clean(context.Context, *CleanRequest) (*CleanResponse, error)
192 Track(*TrackRequest, grpc.ServerStreamingServer[TrackResponse]) error
193 TrackAll(*TrackAllRequest, grpc.ServerStreamingServer[TrackAllResponse]) error
194 OnionMessages(grpc.BidiStreamingServer[OnionMessageResponse, OnionMessage]) error
195 mustEmbedUnimplementedHoldServer()
196 }
197
198 // UnimplementedHoldServer must be embedded to have
199 // forward compatible implementations.
200 //
201 // NOTE: this should be embedded by value instead of pointer to avoid a nil
202 // pointer dereference when methods are called.
203 type UnimplementedHoldServer struct{}
204
205 func (UnimplementedHoldServer) GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error) {
206 return nil, status.Error(codes.Unimplemented, "method GetInfo not implemented")
207 }
208 func (UnimplementedHoldServer) Invoice(context.Context, *InvoiceRequest) (*InvoiceResponse, error) {
209 return nil, status.Error(codes.Unimplemented, "method Invoice not implemented")
210 }
211 func (UnimplementedHoldServer) Inject(context.Context, *InjectRequest) (*InjectResponse, error) {
212 return nil, status.Error(codes.Unimplemented, "method Inject not implemented")
213 }
214 func (UnimplementedHoldServer) List(context.Context, *ListRequest) (*ListResponse, error) {
215 return nil, status.Error(codes.Unimplemented, "method List not implemented")
216 }
217 func (UnimplementedHoldServer) Settle(context.Context, *SettleRequest) (*SettleResponse, error) {
218 return nil, status.Error(codes.Unimplemented, "method Settle not implemented")
219 }
220 func (UnimplementedHoldServer) Cancel(context.Context, *CancelRequest) (*CancelResponse, error) {
221 return nil, status.Error(codes.Unimplemented, "method Cancel not implemented")
222 }
223 func (UnimplementedHoldServer) Clean(context.Context, *CleanRequest) (*CleanResponse, error) {
224 return nil, status.Error(codes.Unimplemented, "method Clean not implemented")
225 }
226 func (UnimplementedHoldServer) Track(*TrackRequest, grpc.ServerStreamingServer[TrackResponse]) error {
227 return status.Error(codes.Unimplemented, "method Track not implemented")
228 }
229 func (UnimplementedHoldServer) TrackAll(*TrackAllRequest, grpc.ServerStreamingServer[TrackAllResponse]) error {
230 return status.Error(codes.Unimplemented, "method TrackAll not implemented")
231 }
232 func (UnimplementedHoldServer) OnionMessages(grpc.BidiStreamingServer[OnionMessageResponse, OnionMessage]) error {
233 return status.Error(codes.Unimplemented, "method OnionMessages not implemented")
234 }
235 func (UnimplementedHoldServer) mustEmbedUnimplementedHoldServer() {}
236 func (UnimplementedHoldServer) testEmbeddedByValue() {}
237
238 // UnsafeHoldServer may be embedded to opt out of forward compatibility for this service.
239 // Use of this interface is not recommended, as added methods to HoldServer will
240 // result in compilation errors.
241 type UnsafeHoldServer interface {
242 mustEmbedUnimplementedHoldServer()
243 }
244
245 func RegisterHoldServer(s grpc.ServiceRegistrar, srv HoldServer) {
246 // If the following call panics, it indicates UnimplementedHoldServer was
247 // embedded by pointer and is nil. This will cause panics if an
248 // unimplemented method is ever invoked, so we test this at initialization
249 // time to prevent it from happening at runtime later due to I/O.
250 if t, ok := srv.(interface{ testEmbeddedByValue() }); ok {
251 t.testEmbeddedByValue()
252 }
253 s.RegisterService(&Hold_ServiceDesc, srv)
254 }
255
256 func _Hold_GetInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
257 in := new(GetInfoRequest)
258 if err := dec(in); err != nil {
259 return nil, err
260 }
261 if interceptor == nil {
262 return srv.(HoldServer).GetInfo(ctx, in)
263 }
264 info := &grpc.UnaryServerInfo{
265 Server: srv,
266 FullMethod: Hold_GetInfo_FullMethodName,
267 }
268 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
269 return srv.(HoldServer).GetInfo(ctx, req.(*GetInfoRequest))
270 }
271 return interceptor(ctx, in, info, handler)
272 }
273
274 func _Hold_Invoice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
275 in := new(InvoiceRequest)
276 if err := dec(in); err != nil {
277 return nil, err
278 }
279 if interceptor == nil {
280 return srv.(HoldServer).Invoice(ctx, in)
281 }
282 info := &grpc.UnaryServerInfo{
283 Server: srv,
284 FullMethod: Hold_Invoice_FullMethodName,
285 }
286 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
287 return srv.(HoldServer).Invoice(ctx, req.(*InvoiceRequest))
288 }
289 return interceptor(ctx, in, info, handler)
290 }
291
292 func _Hold_Inject_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
293 in := new(InjectRequest)
294 if err := dec(in); err != nil {
295 return nil, err
296 }
297 if interceptor == nil {
298 return srv.(HoldServer).Inject(ctx, in)
299 }
300 info := &grpc.UnaryServerInfo{
301 Server: srv,
302 FullMethod: Hold_Inject_FullMethodName,
303 }
304 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
305 return srv.(HoldServer).Inject(ctx, req.(*InjectRequest))
306 }
307 return interceptor(ctx, in, info, handler)
308 }
309
310 func _Hold_List_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
311 in := new(ListRequest)
312 if err := dec(in); err != nil {
313 return nil, err
314 }
315 if interceptor == nil {
316 return srv.(HoldServer).List(ctx, in)
317 }
318 info := &grpc.UnaryServerInfo{
319 Server: srv,
320 FullMethod: Hold_List_FullMethodName,
321 }
322 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
323 return srv.(HoldServer).List(ctx, req.(*ListRequest))
324 }
325 return interceptor(ctx, in, info, handler)
326 }
327
328 func _Hold_Settle_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
329 in := new(SettleRequest)
330 if err := dec(in); err != nil {
331 return nil, err
332 }
333 if interceptor == nil {
334 return srv.(HoldServer).Settle(ctx, in)
335 }
336 info := &grpc.UnaryServerInfo{
337 Server: srv,
338 FullMethod: Hold_Settle_FullMethodName,
339 }
340 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
341 return srv.(HoldServer).Settle(ctx, req.(*SettleRequest))
342 }
343 return interceptor(ctx, in, info, handler)
344 }
345
346 func _Hold_Cancel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
347 in := new(CancelRequest)
348 if err := dec(in); err != nil {
349 return nil, err
350 }
351 if interceptor == nil {
352 return srv.(HoldServer).Cancel(ctx, in)
353 }
354 info := &grpc.UnaryServerInfo{
355 Server: srv,
356 FullMethod: Hold_Cancel_FullMethodName,
357 }
358 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
359 return srv.(HoldServer).Cancel(ctx, req.(*CancelRequest))
360 }
361 return interceptor(ctx, in, info, handler)
362 }
363
364 func _Hold_Clean_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
365 in := new(CleanRequest)
366 if err := dec(in); err != nil {
367 return nil, err
368 }
369 if interceptor == nil {
370 return srv.(HoldServer).Clean(ctx, in)
371 }
372 info := &grpc.UnaryServerInfo{
373 Server: srv,
374 FullMethod: Hold_Clean_FullMethodName,
375 }
376 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
377 return srv.(HoldServer).Clean(ctx, req.(*CleanRequest))
378 }
379 return interceptor(ctx, in, info, handler)
380 }
381
382 func _Hold_Track_Handler(srv interface{}, stream grpc.ServerStream) error {
383 m := new(TrackRequest)
384 if err := stream.RecvMsg(m); err != nil {
385 return err
386 }
387 return srv.(HoldServer).Track(m, &grpc.GenericServerStream[TrackRequest, TrackResponse]{ServerStream: stream})
388 }
389
390 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
391 type Hold_TrackServer = grpc.ServerStreamingServer[TrackResponse]
392
393 func _Hold_TrackAll_Handler(srv interface{}, stream grpc.ServerStream) error {
394 m := new(TrackAllRequest)
395 if err := stream.RecvMsg(m); err != nil {
396 return err
397 }
398 return srv.(HoldServer).TrackAll(m, &grpc.GenericServerStream[TrackAllRequest, TrackAllResponse]{ServerStream: stream})
399 }
400
401 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
402 type Hold_TrackAllServer = grpc.ServerStreamingServer[TrackAllResponse]
403
404 func _Hold_OnionMessages_Handler(srv interface{}, stream grpc.ServerStream) error {
405 return srv.(HoldServer).OnionMessages(&grpc.GenericServerStream[OnionMessageResponse, OnionMessage]{ServerStream: stream})
406 }
407
408 // This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
409 type Hold_OnionMessagesServer = grpc.BidiStreamingServer[OnionMessageResponse, OnionMessage]
410
411 // Hold_ServiceDesc is the grpc.ServiceDesc for Hold service.
412 // It's only intended for direct use with grpc.RegisterService,
413 // and not to be introspected or modified (even as a copy)
414 var Hold_ServiceDesc = grpc.ServiceDesc{
415 ServiceName: "hold.Hold",
416 HandlerType: (*HoldServer)(nil),
417 Methods: []grpc.MethodDesc{
418 {
419 MethodName: "GetInfo",
420 Handler: _Hold_GetInfo_Handler,
421 },
422 {
423 MethodName: "Invoice",
424 Handler: _Hold_Invoice_Handler,
425 },
426 {
427 MethodName: "Inject",
428 Handler: _Hold_Inject_Handler,
429 },
430 {
431 MethodName: "List",
432 Handler: _Hold_List_Handler,
433 },
434 {
435 MethodName: "Settle",
436 Handler: _Hold_Settle_Handler,
437 },
438 {
439 MethodName: "Cancel",
440 Handler: _Hold_Cancel_Handler,
441 },
442 {
443 MethodName: "Clean",
444 Handler: _Hold_Clean_Handler,
445 },
446 },
447 Streams: []grpc.StreamDesc{
448 {
449 StreamName: "Track",
450 Handler: _Hold_Track_Handler,
451 ServerStreams: true,
452 },
453 {
454 StreamName: "TrackAll",
455 Handler: _Hold_TrackAll_Handler,
456 ServerStreams: true,
457 },
458 {
459 StreamName: "OnionMessages",
460 Handler: _Hold_OnionMessages_Handler,
461 ServerStreams: true,
462 ClientStreams: true,
463 },
464 },
465 Metadata: "hold.proto",
466 }
467