• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

lightningnetwork / lnd / 13412100018

19 Feb 2025 12:05PM UTC coverage: 44.914% (-13.9%) from 58.794%
13412100018

Pull #9521

github

web-flow
Merge 861d6970e into 0e8786348
Pull Request #9521: unit: remove GOACC, use Go 1.20 native coverage functionality

101023 of 224923 relevant lines covered (44.91%)

19479.4 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0
/lnrpc/routerrpc/router_grpc.pb.go
1
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
2

3
package routerrpc
4

5
import (
6
        context "context"
7
        lnrpc "github.com/lightningnetwork/lnd/lnrpc"
8
        grpc "google.golang.org/grpc"
9
        codes "google.golang.org/grpc/codes"
10
        status "google.golang.org/grpc/status"
11
)
12

13
// This is a compile-time assertion to ensure that this generated file
14
// is compatible with the grpc package it is being compiled against.
15
// Requires gRPC-Go v1.32.0 or later.
16
const _ = grpc.SupportPackageIsVersion7
17

18
// RouterClient is the client API for Router service.
19
//
20
// 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.
21
type RouterClient interface {
22
        // SendPaymentV2 attempts to route a payment described by the passed
23
        // PaymentRequest to the final destination. The call returns a stream of
24
        // payment updates. When using this RPC, make sure to set a fee limit, as the
25
        // default routing fee limit is 0 sats. Without a non-zero fee limit only
26
        // routes without fees will be attempted which often fails with
27
        // FAILURE_REASON_NO_ROUTE.
28
        SendPaymentV2(ctx context.Context, in *SendPaymentRequest, opts ...grpc.CallOption) (Router_SendPaymentV2Client, error)
29
        // lncli: `trackpayment`
30
        // TrackPaymentV2 returns an update stream for the payment identified by the
31
        // payment hash.
32
        TrackPaymentV2(ctx context.Context, in *TrackPaymentRequest, opts ...grpc.CallOption) (Router_TrackPaymentV2Client, error)
33
        // TrackPayments returns an update stream for every payment that is not in a
34
        // terminal state. Note that if payments are in-flight while starting a new
35
        // subscription, the start of the payment stream could produce out-of-order
36
        // and/or duplicate events. In order to get updates for every in-flight
37
        // payment attempt make sure to subscribe to this method before initiating any
38
        // payments.
39
        TrackPayments(ctx context.Context, in *TrackPaymentsRequest, opts ...grpc.CallOption) (Router_TrackPaymentsClient, error)
40
        // EstimateRouteFee allows callers to obtain a lower bound w.r.t how much it
41
        // may cost to send an HTLC to the target end destination.
42
        EstimateRouteFee(ctx context.Context, in *RouteFeeRequest, opts ...grpc.CallOption) (*RouteFeeResponse, error)
43
        // Deprecated: Do not use.
44
        //
45
        // Deprecated, use SendToRouteV2. SendToRoute attempts to make a payment via
46
        // the specified route. This method differs from SendPayment in that it
47
        // allows users to specify a full route manually. This can be used for
48
        // things like rebalancing, and atomic swaps. It differs from the newer
49
        // SendToRouteV2 in that it doesn't return the full HTLC information.
50
        SendToRoute(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*SendToRouteResponse, error)
51
        // SendToRouteV2 attempts to make a payment via the specified route. This
52
        // method differs from SendPayment in that it allows users to specify a full
53
        // route manually. This can be used for things like rebalancing, and atomic
54
        // swaps.
55
        SendToRouteV2(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*lnrpc.HTLCAttempt, error)
56
        // lncli: `resetmc`
57
        // ResetMissionControl clears all mission control state and starts with a clean
58
        // slate.
59
        ResetMissionControl(ctx context.Context, in *ResetMissionControlRequest, opts ...grpc.CallOption) (*ResetMissionControlResponse, error)
60
        // lncli: `querymc`
61
        // QueryMissionControl exposes the internal mission control state to callers.
62
        // It is a development feature.
63
        QueryMissionControl(ctx context.Context, in *QueryMissionControlRequest, opts ...grpc.CallOption) (*QueryMissionControlResponse, error)
64
        // lncli: `importmc`
65
        // XImportMissionControl is an experimental API that imports the state provided
66
        // to the internal mission control's state, using all results which are more
67
        // recent than our existing values. These values will only be imported
68
        // in-memory, and will not be persisted across restarts.
69
        XImportMissionControl(ctx context.Context, in *XImportMissionControlRequest, opts ...grpc.CallOption) (*XImportMissionControlResponse, error)
70
        // lncli: `getmccfg`
71
        // GetMissionControlConfig returns mission control's current config.
72
        GetMissionControlConfig(ctx context.Context, in *GetMissionControlConfigRequest, opts ...grpc.CallOption) (*GetMissionControlConfigResponse, error)
73
        // lncli: `setmccfg`
74
        // SetMissionControlConfig will set mission control's config, if the config
75
        // provided is valid.
76
        SetMissionControlConfig(ctx context.Context, in *SetMissionControlConfigRequest, opts ...grpc.CallOption) (*SetMissionControlConfigResponse, error)
77
        // lncli: `queryprob`
78
        // Deprecated. QueryProbability returns the current success probability
79
        // estimate for a given node pair and amount. The call returns a zero success
80
        // probability if no channel is available or if the amount violates min/max
81
        // HTLC constraints.
82
        QueryProbability(ctx context.Context, in *QueryProbabilityRequest, opts ...grpc.CallOption) (*QueryProbabilityResponse, error)
83
        // lncli: `buildroute`
84
        // BuildRoute builds a fully specified route based on a list of hop public
85
        // keys. It retrieves the relevant channel policies from the graph in order to
86
        // calculate the correct fees and time locks.
87
        // Note that LND will use its default final_cltv_delta if no value is supplied.
88
        // Make sure to add the correct final_cltv_delta depending on the invoice
89
        // restriction. Moreover the caller has to make sure to provide the
90
        // payment_addr if the route is paying an invoice which signaled it.
91
        BuildRoute(ctx context.Context, in *BuildRouteRequest, opts ...grpc.CallOption) (*BuildRouteResponse, error)
92
        // SubscribeHtlcEvents creates a uni-directional stream from the server to
93
        // the client which delivers a stream of htlc events.
94
        SubscribeHtlcEvents(ctx context.Context, in *SubscribeHtlcEventsRequest, opts ...grpc.CallOption) (Router_SubscribeHtlcEventsClient, error)
95
        // Deprecated: Do not use.
96
        //
97
        // Deprecated, use SendPaymentV2. SendPayment attempts to route a payment
98
        // described by the passed PaymentRequest to the final destination. The call
99
        // returns a stream of payment status updates.
100
        SendPayment(ctx context.Context, in *SendPaymentRequest, opts ...grpc.CallOption) (Router_SendPaymentClient, error)
101
        // Deprecated: Do not use.
102
        //
103
        // Deprecated, use TrackPaymentV2. TrackPayment returns an update stream for
104
        // the payment identified by the payment hash.
105
        TrackPayment(ctx context.Context, in *TrackPaymentRequest, opts ...grpc.CallOption) (Router_TrackPaymentClient, error)
106
        // *
107
        // HtlcInterceptor dispatches a bi-directional streaming RPC in which
108
        // Forwarded HTLC requests are sent to the client and the client responds with
109
        // a boolean that tells LND if this htlc should be intercepted.
110
        // In case of interception, the htlc can be either settled, cancelled or
111
        // resumed later by using the ResolveHoldForward endpoint.
112
        HtlcInterceptor(ctx context.Context, opts ...grpc.CallOption) (Router_HtlcInterceptorClient, error)
113
        // lncli: `updatechanstatus`
114
        // UpdateChanStatus attempts to manually set the state of a channel
115
        // (enabled, disabled, or auto). A manual "disable" request will cause the
116
        // channel to stay disabled until a subsequent manual request of either
117
        // "enable" or "auto".
118
        UpdateChanStatus(ctx context.Context, in *UpdateChanStatusRequest, opts ...grpc.CallOption) (*UpdateChanStatusResponse, error)
119
        // XAddLocalChanAliases is an experimental API that creates a set of new
120
        // channel SCID alias mappings. The final total set of aliases in the manager
121
        // after the add operation is returned. This is only a locally stored alias,
122
        // and will not be communicated to the channel peer via any message. Therefore,
123
        // routing over such an alias will only work if the peer also calls this same
124
        // RPC on their end. If an alias already exists, an error is returned
125
        XAddLocalChanAliases(ctx context.Context, in *AddAliasesRequest, opts ...grpc.CallOption) (*AddAliasesResponse, error)
126
        // XDeleteLocalChanAliases is an experimental API that deletes a set of alias
127
        // mappings. The final total set of aliases in the manager after the delete
128
        // operation is returned. The deletion will not be communicated to the channel
129
        // peer via any message.
130
        XDeleteLocalChanAliases(ctx context.Context, in *DeleteAliasesRequest, opts ...grpc.CallOption) (*DeleteAliasesResponse, error)
131
}
132

133
type routerClient struct {
134
        cc grpc.ClientConnInterface
135
}
136

137
func NewRouterClient(cc grpc.ClientConnInterface) RouterClient {
×
138
        return &routerClient{cc}
×
139
}
×
140

141
func (c *routerClient) SendPaymentV2(ctx context.Context, in *SendPaymentRequest, opts ...grpc.CallOption) (Router_SendPaymentV2Client, error) {
×
142
        stream, err := c.cc.NewStream(ctx, &Router_ServiceDesc.Streams[0], "/routerrpc.Router/SendPaymentV2", opts...)
×
143
        if err != nil {
×
144
                return nil, err
×
145
        }
×
146
        x := &routerSendPaymentV2Client{stream}
×
147
        if err := x.ClientStream.SendMsg(in); err != nil {
×
148
                return nil, err
×
149
        }
×
150
        if err := x.ClientStream.CloseSend(); err != nil {
×
151
                return nil, err
×
152
        }
×
153
        return x, nil
×
154
}
155

156
type Router_SendPaymentV2Client interface {
157
        Recv() (*lnrpc.Payment, error)
158
        grpc.ClientStream
159
}
160

161
type routerSendPaymentV2Client struct {
162
        grpc.ClientStream
163
}
164

165
func (x *routerSendPaymentV2Client) Recv() (*lnrpc.Payment, error) {
×
166
        m := new(lnrpc.Payment)
×
167
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
168
                return nil, err
×
169
        }
×
170
        return m, nil
×
171
}
172

173
func (c *routerClient) TrackPaymentV2(ctx context.Context, in *TrackPaymentRequest, opts ...grpc.CallOption) (Router_TrackPaymentV2Client, error) {
×
174
        stream, err := c.cc.NewStream(ctx, &Router_ServiceDesc.Streams[1], "/routerrpc.Router/TrackPaymentV2", opts...)
×
175
        if err != nil {
×
176
                return nil, err
×
177
        }
×
178
        x := &routerTrackPaymentV2Client{stream}
×
179
        if err := x.ClientStream.SendMsg(in); err != nil {
×
180
                return nil, err
×
181
        }
×
182
        if err := x.ClientStream.CloseSend(); err != nil {
×
183
                return nil, err
×
184
        }
×
185
        return x, nil
×
186
}
187

188
type Router_TrackPaymentV2Client interface {
189
        Recv() (*lnrpc.Payment, error)
190
        grpc.ClientStream
191
}
192

193
type routerTrackPaymentV2Client struct {
194
        grpc.ClientStream
195
}
196

197
func (x *routerTrackPaymentV2Client) Recv() (*lnrpc.Payment, error) {
×
198
        m := new(lnrpc.Payment)
×
199
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
200
                return nil, err
×
201
        }
×
202
        return m, nil
×
203
}
204

205
func (c *routerClient) TrackPayments(ctx context.Context, in *TrackPaymentsRequest, opts ...grpc.CallOption) (Router_TrackPaymentsClient, error) {
×
206
        stream, err := c.cc.NewStream(ctx, &Router_ServiceDesc.Streams[2], "/routerrpc.Router/TrackPayments", opts...)
×
207
        if err != nil {
×
208
                return nil, err
×
209
        }
×
210
        x := &routerTrackPaymentsClient{stream}
×
211
        if err := x.ClientStream.SendMsg(in); err != nil {
×
212
                return nil, err
×
213
        }
×
214
        if err := x.ClientStream.CloseSend(); err != nil {
×
215
                return nil, err
×
216
        }
×
217
        return x, nil
×
218
}
219

220
type Router_TrackPaymentsClient interface {
221
        Recv() (*lnrpc.Payment, error)
222
        grpc.ClientStream
223
}
224

225
type routerTrackPaymentsClient struct {
226
        grpc.ClientStream
227
}
228

229
func (x *routerTrackPaymentsClient) Recv() (*lnrpc.Payment, error) {
×
230
        m := new(lnrpc.Payment)
×
231
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
232
                return nil, err
×
233
        }
×
234
        return m, nil
×
235
}
236

237
func (c *routerClient) EstimateRouteFee(ctx context.Context, in *RouteFeeRequest, opts ...grpc.CallOption) (*RouteFeeResponse, error) {
×
238
        out := new(RouteFeeResponse)
×
239
        err := c.cc.Invoke(ctx, "/routerrpc.Router/EstimateRouteFee", in, out, opts...)
×
240
        if err != nil {
×
241
                return nil, err
×
242
        }
×
243
        return out, nil
×
244
}
245

246
// Deprecated: Do not use.
247
func (c *routerClient) SendToRoute(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*SendToRouteResponse, error) {
×
248
        out := new(SendToRouteResponse)
×
249
        err := c.cc.Invoke(ctx, "/routerrpc.Router/SendToRoute", in, out, opts...)
×
250
        if err != nil {
×
251
                return nil, err
×
252
        }
×
253
        return out, nil
×
254
}
255

256
func (c *routerClient) SendToRouteV2(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*lnrpc.HTLCAttempt, error) {
×
257
        out := new(lnrpc.HTLCAttempt)
×
258
        err := c.cc.Invoke(ctx, "/routerrpc.Router/SendToRouteV2", in, out, opts...)
×
259
        if err != nil {
×
260
                return nil, err
×
261
        }
×
262
        return out, nil
×
263
}
264

265
func (c *routerClient) ResetMissionControl(ctx context.Context, in *ResetMissionControlRequest, opts ...grpc.CallOption) (*ResetMissionControlResponse, error) {
×
266
        out := new(ResetMissionControlResponse)
×
267
        err := c.cc.Invoke(ctx, "/routerrpc.Router/ResetMissionControl", in, out, opts...)
×
268
        if err != nil {
×
269
                return nil, err
×
270
        }
×
271
        return out, nil
×
272
}
273

274
func (c *routerClient) QueryMissionControl(ctx context.Context, in *QueryMissionControlRequest, opts ...grpc.CallOption) (*QueryMissionControlResponse, error) {
×
275
        out := new(QueryMissionControlResponse)
×
276
        err := c.cc.Invoke(ctx, "/routerrpc.Router/QueryMissionControl", in, out, opts...)
×
277
        if err != nil {
×
278
                return nil, err
×
279
        }
×
280
        return out, nil
×
281
}
282

283
func (c *routerClient) XImportMissionControl(ctx context.Context, in *XImportMissionControlRequest, opts ...grpc.CallOption) (*XImportMissionControlResponse, error) {
×
284
        out := new(XImportMissionControlResponse)
×
285
        err := c.cc.Invoke(ctx, "/routerrpc.Router/XImportMissionControl", in, out, opts...)
×
286
        if err != nil {
×
287
                return nil, err
×
288
        }
×
289
        return out, nil
×
290
}
291

292
func (c *routerClient) GetMissionControlConfig(ctx context.Context, in *GetMissionControlConfigRequest, opts ...grpc.CallOption) (*GetMissionControlConfigResponse, error) {
×
293
        out := new(GetMissionControlConfigResponse)
×
294
        err := c.cc.Invoke(ctx, "/routerrpc.Router/GetMissionControlConfig", in, out, opts...)
×
295
        if err != nil {
×
296
                return nil, err
×
297
        }
×
298
        return out, nil
×
299
}
300

301
func (c *routerClient) SetMissionControlConfig(ctx context.Context, in *SetMissionControlConfigRequest, opts ...grpc.CallOption) (*SetMissionControlConfigResponse, error) {
×
302
        out := new(SetMissionControlConfigResponse)
×
303
        err := c.cc.Invoke(ctx, "/routerrpc.Router/SetMissionControlConfig", in, out, opts...)
×
304
        if err != nil {
×
305
                return nil, err
×
306
        }
×
307
        return out, nil
×
308
}
309

310
func (c *routerClient) QueryProbability(ctx context.Context, in *QueryProbabilityRequest, opts ...grpc.CallOption) (*QueryProbabilityResponse, error) {
×
311
        out := new(QueryProbabilityResponse)
×
312
        err := c.cc.Invoke(ctx, "/routerrpc.Router/QueryProbability", in, out, opts...)
×
313
        if err != nil {
×
314
                return nil, err
×
315
        }
×
316
        return out, nil
×
317
}
318

319
func (c *routerClient) BuildRoute(ctx context.Context, in *BuildRouteRequest, opts ...grpc.CallOption) (*BuildRouteResponse, error) {
×
320
        out := new(BuildRouteResponse)
×
321
        err := c.cc.Invoke(ctx, "/routerrpc.Router/BuildRoute", in, out, opts...)
×
322
        if err != nil {
×
323
                return nil, err
×
324
        }
×
325
        return out, nil
×
326
}
327

328
func (c *routerClient) SubscribeHtlcEvents(ctx context.Context, in *SubscribeHtlcEventsRequest, opts ...grpc.CallOption) (Router_SubscribeHtlcEventsClient, error) {
×
329
        stream, err := c.cc.NewStream(ctx, &Router_ServiceDesc.Streams[3], "/routerrpc.Router/SubscribeHtlcEvents", opts...)
×
330
        if err != nil {
×
331
                return nil, err
×
332
        }
×
333
        x := &routerSubscribeHtlcEventsClient{stream}
×
334
        if err := x.ClientStream.SendMsg(in); err != nil {
×
335
                return nil, err
×
336
        }
×
337
        if err := x.ClientStream.CloseSend(); err != nil {
×
338
                return nil, err
×
339
        }
×
340
        return x, nil
×
341
}
342

343
type Router_SubscribeHtlcEventsClient interface {
344
        Recv() (*HtlcEvent, error)
345
        grpc.ClientStream
346
}
347

348
type routerSubscribeHtlcEventsClient struct {
349
        grpc.ClientStream
350
}
351

352
func (x *routerSubscribeHtlcEventsClient) Recv() (*HtlcEvent, error) {
×
353
        m := new(HtlcEvent)
×
354
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
355
                return nil, err
×
356
        }
×
357
        return m, nil
×
358
}
359

360
// Deprecated: Do not use.
361
func (c *routerClient) SendPayment(ctx context.Context, in *SendPaymentRequest, opts ...grpc.CallOption) (Router_SendPaymentClient, error) {
×
362
        stream, err := c.cc.NewStream(ctx, &Router_ServiceDesc.Streams[4], "/routerrpc.Router/SendPayment", opts...)
×
363
        if err != nil {
×
364
                return nil, err
×
365
        }
×
366
        x := &routerSendPaymentClient{stream}
×
367
        if err := x.ClientStream.SendMsg(in); err != nil {
×
368
                return nil, err
×
369
        }
×
370
        if err := x.ClientStream.CloseSend(); err != nil {
×
371
                return nil, err
×
372
        }
×
373
        return x, nil
×
374
}
375

376
type Router_SendPaymentClient interface {
377
        Recv() (*PaymentStatus, error)
378
        grpc.ClientStream
379
}
380

381
type routerSendPaymentClient struct {
382
        grpc.ClientStream
383
}
384

385
func (x *routerSendPaymentClient) Recv() (*PaymentStatus, error) {
×
386
        m := new(PaymentStatus)
×
387
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
388
                return nil, err
×
389
        }
×
390
        return m, nil
×
391
}
392

393
// Deprecated: Do not use.
394
func (c *routerClient) TrackPayment(ctx context.Context, in *TrackPaymentRequest, opts ...grpc.CallOption) (Router_TrackPaymentClient, error) {
×
395
        stream, err := c.cc.NewStream(ctx, &Router_ServiceDesc.Streams[5], "/routerrpc.Router/TrackPayment", opts...)
×
396
        if err != nil {
×
397
                return nil, err
×
398
        }
×
399
        x := &routerTrackPaymentClient{stream}
×
400
        if err := x.ClientStream.SendMsg(in); err != nil {
×
401
                return nil, err
×
402
        }
×
403
        if err := x.ClientStream.CloseSend(); err != nil {
×
404
                return nil, err
×
405
        }
×
406
        return x, nil
×
407
}
408

409
type Router_TrackPaymentClient interface {
410
        Recv() (*PaymentStatus, error)
411
        grpc.ClientStream
412
}
413

414
type routerTrackPaymentClient struct {
415
        grpc.ClientStream
416
}
417

418
func (x *routerTrackPaymentClient) Recv() (*PaymentStatus, error) {
×
419
        m := new(PaymentStatus)
×
420
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
421
                return nil, err
×
422
        }
×
423
        return m, nil
×
424
}
425

426
func (c *routerClient) HtlcInterceptor(ctx context.Context, opts ...grpc.CallOption) (Router_HtlcInterceptorClient, error) {
×
427
        stream, err := c.cc.NewStream(ctx, &Router_ServiceDesc.Streams[6], "/routerrpc.Router/HtlcInterceptor", opts...)
×
428
        if err != nil {
×
429
                return nil, err
×
430
        }
×
431
        x := &routerHtlcInterceptorClient{stream}
×
432
        return x, nil
×
433
}
434

435
type Router_HtlcInterceptorClient interface {
436
        Send(*ForwardHtlcInterceptResponse) error
437
        Recv() (*ForwardHtlcInterceptRequest, error)
438
        grpc.ClientStream
439
}
440

441
type routerHtlcInterceptorClient struct {
442
        grpc.ClientStream
443
}
444

445
func (x *routerHtlcInterceptorClient) Send(m *ForwardHtlcInterceptResponse) error {
×
446
        return x.ClientStream.SendMsg(m)
×
447
}
×
448

449
func (x *routerHtlcInterceptorClient) Recv() (*ForwardHtlcInterceptRequest, error) {
×
450
        m := new(ForwardHtlcInterceptRequest)
×
451
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
452
                return nil, err
×
453
        }
×
454
        return m, nil
×
455
}
456

457
func (c *routerClient) UpdateChanStatus(ctx context.Context, in *UpdateChanStatusRequest, opts ...grpc.CallOption) (*UpdateChanStatusResponse, error) {
×
458
        out := new(UpdateChanStatusResponse)
×
459
        err := c.cc.Invoke(ctx, "/routerrpc.Router/UpdateChanStatus", in, out, opts...)
×
460
        if err != nil {
×
461
                return nil, err
×
462
        }
×
463
        return out, nil
×
464
}
465

466
func (c *routerClient) XAddLocalChanAliases(ctx context.Context, in *AddAliasesRequest, opts ...grpc.CallOption) (*AddAliasesResponse, error) {
×
467
        out := new(AddAliasesResponse)
×
468
        err := c.cc.Invoke(ctx, "/routerrpc.Router/XAddLocalChanAliases", in, out, opts...)
×
469
        if err != nil {
×
470
                return nil, err
×
471
        }
×
472
        return out, nil
×
473
}
474

475
func (c *routerClient) XDeleteLocalChanAliases(ctx context.Context, in *DeleteAliasesRequest, opts ...grpc.CallOption) (*DeleteAliasesResponse, error) {
×
476
        out := new(DeleteAliasesResponse)
×
477
        err := c.cc.Invoke(ctx, "/routerrpc.Router/XDeleteLocalChanAliases", in, out, opts...)
×
478
        if err != nil {
×
479
                return nil, err
×
480
        }
×
481
        return out, nil
×
482
}
483

484
// RouterServer is the server API for Router service.
485
// All implementations must embed UnimplementedRouterServer
486
// for forward compatibility
487
type RouterServer interface {
488
        // SendPaymentV2 attempts to route a payment described by the passed
489
        // PaymentRequest to the final destination. The call returns a stream of
490
        // payment updates. When using this RPC, make sure to set a fee limit, as the
491
        // default routing fee limit is 0 sats. Without a non-zero fee limit only
492
        // routes without fees will be attempted which often fails with
493
        // FAILURE_REASON_NO_ROUTE.
494
        SendPaymentV2(*SendPaymentRequest, Router_SendPaymentV2Server) error
495
        // lncli: `trackpayment`
496
        // TrackPaymentV2 returns an update stream for the payment identified by the
497
        // payment hash.
498
        TrackPaymentV2(*TrackPaymentRequest, Router_TrackPaymentV2Server) error
499
        // TrackPayments returns an update stream for every payment that is not in a
500
        // terminal state. Note that if payments are in-flight while starting a new
501
        // subscription, the start of the payment stream could produce out-of-order
502
        // and/or duplicate events. In order to get updates for every in-flight
503
        // payment attempt make sure to subscribe to this method before initiating any
504
        // payments.
505
        TrackPayments(*TrackPaymentsRequest, Router_TrackPaymentsServer) error
506
        // EstimateRouteFee allows callers to obtain a lower bound w.r.t how much it
507
        // may cost to send an HTLC to the target end destination.
508
        EstimateRouteFee(context.Context, *RouteFeeRequest) (*RouteFeeResponse, error)
509
        // Deprecated: Do not use.
510
        //
511
        // Deprecated, use SendToRouteV2. SendToRoute attempts to make a payment via
512
        // the specified route. This method differs from SendPayment in that it
513
        // allows users to specify a full route manually. This can be used for
514
        // things like rebalancing, and atomic swaps. It differs from the newer
515
        // SendToRouteV2 in that it doesn't return the full HTLC information.
516
        SendToRoute(context.Context, *SendToRouteRequest) (*SendToRouteResponse, error)
517
        // SendToRouteV2 attempts to make a payment via the specified route. This
518
        // method differs from SendPayment in that it allows users to specify a full
519
        // route manually. This can be used for things like rebalancing, and atomic
520
        // swaps.
521
        SendToRouteV2(context.Context, *SendToRouteRequest) (*lnrpc.HTLCAttempt, error)
522
        // lncli: `resetmc`
523
        // ResetMissionControl clears all mission control state and starts with a clean
524
        // slate.
525
        ResetMissionControl(context.Context, *ResetMissionControlRequest) (*ResetMissionControlResponse, error)
526
        // lncli: `querymc`
527
        // QueryMissionControl exposes the internal mission control state to callers.
528
        // It is a development feature.
529
        QueryMissionControl(context.Context, *QueryMissionControlRequest) (*QueryMissionControlResponse, error)
530
        // lncli: `importmc`
531
        // XImportMissionControl is an experimental API that imports the state provided
532
        // to the internal mission control's state, using all results which are more
533
        // recent than our existing values. These values will only be imported
534
        // in-memory, and will not be persisted across restarts.
535
        XImportMissionControl(context.Context, *XImportMissionControlRequest) (*XImportMissionControlResponse, error)
536
        // lncli: `getmccfg`
537
        // GetMissionControlConfig returns mission control's current config.
538
        GetMissionControlConfig(context.Context, *GetMissionControlConfigRequest) (*GetMissionControlConfigResponse, error)
539
        // lncli: `setmccfg`
540
        // SetMissionControlConfig will set mission control's config, if the config
541
        // provided is valid.
542
        SetMissionControlConfig(context.Context, *SetMissionControlConfigRequest) (*SetMissionControlConfigResponse, error)
543
        // lncli: `queryprob`
544
        // Deprecated. QueryProbability returns the current success probability
545
        // estimate for a given node pair and amount. The call returns a zero success
546
        // probability if no channel is available or if the amount violates min/max
547
        // HTLC constraints.
548
        QueryProbability(context.Context, *QueryProbabilityRequest) (*QueryProbabilityResponse, error)
549
        // lncli: `buildroute`
550
        // BuildRoute builds a fully specified route based on a list of hop public
551
        // keys. It retrieves the relevant channel policies from the graph in order to
552
        // calculate the correct fees and time locks.
553
        // Note that LND will use its default final_cltv_delta if no value is supplied.
554
        // Make sure to add the correct final_cltv_delta depending on the invoice
555
        // restriction. Moreover the caller has to make sure to provide the
556
        // payment_addr if the route is paying an invoice which signaled it.
557
        BuildRoute(context.Context, *BuildRouteRequest) (*BuildRouteResponse, error)
558
        // SubscribeHtlcEvents creates a uni-directional stream from the server to
559
        // the client which delivers a stream of htlc events.
560
        SubscribeHtlcEvents(*SubscribeHtlcEventsRequest, Router_SubscribeHtlcEventsServer) error
561
        // Deprecated: Do not use.
562
        //
563
        // Deprecated, use SendPaymentV2. SendPayment attempts to route a payment
564
        // described by the passed PaymentRequest to the final destination. The call
565
        // returns a stream of payment status updates.
566
        SendPayment(*SendPaymentRequest, Router_SendPaymentServer) error
567
        // Deprecated: Do not use.
568
        //
569
        // Deprecated, use TrackPaymentV2. TrackPayment returns an update stream for
570
        // the payment identified by the payment hash.
571
        TrackPayment(*TrackPaymentRequest, Router_TrackPaymentServer) error
572
        // *
573
        // HtlcInterceptor dispatches a bi-directional streaming RPC in which
574
        // Forwarded HTLC requests are sent to the client and the client responds with
575
        // a boolean that tells LND if this htlc should be intercepted.
576
        // In case of interception, the htlc can be either settled, cancelled or
577
        // resumed later by using the ResolveHoldForward endpoint.
578
        HtlcInterceptor(Router_HtlcInterceptorServer) error
579
        // lncli: `updatechanstatus`
580
        // UpdateChanStatus attempts to manually set the state of a channel
581
        // (enabled, disabled, or auto). A manual "disable" request will cause the
582
        // channel to stay disabled until a subsequent manual request of either
583
        // "enable" or "auto".
584
        UpdateChanStatus(context.Context, *UpdateChanStatusRequest) (*UpdateChanStatusResponse, error)
585
        // XAddLocalChanAliases is an experimental API that creates a set of new
586
        // channel SCID alias mappings. The final total set of aliases in the manager
587
        // after the add operation is returned. This is only a locally stored alias,
588
        // and will not be communicated to the channel peer via any message. Therefore,
589
        // routing over such an alias will only work if the peer also calls this same
590
        // RPC on their end. If an alias already exists, an error is returned
591
        XAddLocalChanAliases(context.Context, *AddAliasesRequest) (*AddAliasesResponse, error)
592
        // XDeleteLocalChanAliases is an experimental API that deletes a set of alias
593
        // mappings. The final total set of aliases in the manager after the delete
594
        // operation is returned. The deletion will not be communicated to the channel
595
        // peer via any message.
596
        XDeleteLocalChanAliases(context.Context, *DeleteAliasesRequest) (*DeleteAliasesResponse, error)
597
        mustEmbedUnimplementedRouterServer()
598
}
599

600
// UnimplementedRouterServer must be embedded to have forward compatible implementations.
601
type UnimplementedRouterServer struct {
602
}
603

604
func (UnimplementedRouterServer) SendPaymentV2(*SendPaymentRequest, Router_SendPaymentV2Server) error {
×
605
        return status.Errorf(codes.Unimplemented, "method SendPaymentV2 not implemented")
×
606
}
×
607
func (UnimplementedRouterServer) TrackPaymentV2(*TrackPaymentRequest, Router_TrackPaymentV2Server) error {
×
608
        return status.Errorf(codes.Unimplemented, "method TrackPaymentV2 not implemented")
×
609
}
×
610
func (UnimplementedRouterServer) TrackPayments(*TrackPaymentsRequest, Router_TrackPaymentsServer) error {
×
611
        return status.Errorf(codes.Unimplemented, "method TrackPayments not implemented")
×
612
}
×
613
func (UnimplementedRouterServer) EstimateRouteFee(context.Context, *RouteFeeRequest) (*RouteFeeResponse, error) {
×
614
        return nil, status.Errorf(codes.Unimplemented, "method EstimateRouteFee not implemented")
×
615
}
×
616
func (UnimplementedRouterServer) SendToRoute(context.Context, *SendToRouteRequest) (*SendToRouteResponse, error) {
×
617
        return nil, status.Errorf(codes.Unimplemented, "method SendToRoute not implemented")
×
618
}
×
619
func (UnimplementedRouterServer) SendToRouteV2(context.Context, *SendToRouteRequest) (*lnrpc.HTLCAttempt, error) {
×
620
        return nil, status.Errorf(codes.Unimplemented, "method SendToRouteV2 not implemented")
×
621
}
×
622
func (UnimplementedRouterServer) ResetMissionControl(context.Context, *ResetMissionControlRequest) (*ResetMissionControlResponse, error) {
×
623
        return nil, status.Errorf(codes.Unimplemented, "method ResetMissionControl not implemented")
×
624
}
×
625
func (UnimplementedRouterServer) QueryMissionControl(context.Context, *QueryMissionControlRequest) (*QueryMissionControlResponse, error) {
×
626
        return nil, status.Errorf(codes.Unimplemented, "method QueryMissionControl not implemented")
×
627
}
×
628
func (UnimplementedRouterServer) XImportMissionControl(context.Context, *XImportMissionControlRequest) (*XImportMissionControlResponse, error) {
×
629
        return nil, status.Errorf(codes.Unimplemented, "method XImportMissionControl not implemented")
×
630
}
×
631
func (UnimplementedRouterServer) GetMissionControlConfig(context.Context, *GetMissionControlConfigRequest) (*GetMissionControlConfigResponse, error) {
×
632
        return nil, status.Errorf(codes.Unimplemented, "method GetMissionControlConfig not implemented")
×
633
}
×
634
func (UnimplementedRouterServer) SetMissionControlConfig(context.Context, *SetMissionControlConfigRequest) (*SetMissionControlConfigResponse, error) {
×
635
        return nil, status.Errorf(codes.Unimplemented, "method SetMissionControlConfig not implemented")
×
636
}
×
637
func (UnimplementedRouterServer) QueryProbability(context.Context, *QueryProbabilityRequest) (*QueryProbabilityResponse, error) {
×
638
        return nil, status.Errorf(codes.Unimplemented, "method QueryProbability not implemented")
×
639
}
×
640
func (UnimplementedRouterServer) BuildRoute(context.Context, *BuildRouteRequest) (*BuildRouteResponse, error) {
×
641
        return nil, status.Errorf(codes.Unimplemented, "method BuildRoute not implemented")
×
642
}
×
643
func (UnimplementedRouterServer) SubscribeHtlcEvents(*SubscribeHtlcEventsRequest, Router_SubscribeHtlcEventsServer) error {
×
644
        return status.Errorf(codes.Unimplemented, "method SubscribeHtlcEvents not implemented")
×
645
}
×
646
func (UnimplementedRouterServer) SendPayment(*SendPaymentRequest, Router_SendPaymentServer) error {
×
647
        return status.Errorf(codes.Unimplemented, "method SendPayment not implemented")
×
648
}
×
649
func (UnimplementedRouterServer) TrackPayment(*TrackPaymentRequest, Router_TrackPaymentServer) error {
×
650
        return status.Errorf(codes.Unimplemented, "method TrackPayment not implemented")
×
651
}
×
652
func (UnimplementedRouterServer) HtlcInterceptor(Router_HtlcInterceptorServer) error {
×
653
        return status.Errorf(codes.Unimplemented, "method HtlcInterceptor not implemented")
×
654
}
×
655
func (UnimplementedRouterServer) UpdateChanStatus(context.Context, *UpdateChanStatusRequest) (*UpdateChanStatusResponse, error) {
×
656
        return nil, status.Errorf(codes.Unimplemented, "method UpdateChanStatus not implemented")
×
657
}
×
658
func (UnimplementedRouterServer) XAddLocalChanAliases(context.Context, *AddAliasesRequest) (*AddAliasesResponse, error) {
×
659
        return nil, status.Errorf(codes.Unimplemented, "method XAddLocalChanAliases not implemented")
×
660
}
×
661
func (UnimplementedRouterServer) XDeleteLocalChanAliases(context.Context, *DeleteAliasesRequest) (*DeleteAliasesResponse, error) {
×
662
        return nil, status.Errorf(codes.Unimplemented, "method XDeleteLocalChanAliases not implemented")
×
663
}
×
664
func (UnimplementedRouterServer) mustEmbedUnimplementedRouterServer() {}
×
665

666
// UnsafeRouterServer may be embedded to opt out of forward compatibility for this service.
667
// Use of this interface is not recommended, as added methods to RouterServer will
668
// result in compilation errors.
669
type UnsafeRouterServer interface {
670
        mustEmbedUnimplementedRouterServer()
671
}
672

673
func RegisterRouterServer(s grpc.ServiceRegistrar, srv RouterServer) {
×
674
        s.RegisterService(&Router_ServiceDesc, srv)
×
675
}
×
676

677
func _Router_SendPaymentV2_Handler(srv interface{}, stream grpc.ServerStream) error {
×
678
        m := new(SendPaymentRequest)
×
679
        if err := stream.RecvMsg(m); err != nil {
×
680
                return err
×
681
        }
×
682
        return srv.(RouterServer).SendPaymentV2(m, &routerSendPaymentV2Server{stream})
×
683
}
684

685
type Router_SendPaymentV2Server interface {
686
        Send(*lnrpc.Payment) error
687
        grpc.ServerStream
688
}
689

690
type routerSendPaymentV2Server struct {
691
        grpc.ServerStream
692
}
693

694
func (x *routerSendPaymentV2Server) Send(m *lnrpc.Payment) error {
×
695
        return x.ServerStream.SendMsg(m)
×
696
}
×
697

698
func _Router_TrackPaymentV2_Handler(srv interface{}, stream grpc.ServerStream) error {
×
699
        m := new(TrackPaymentRequest)
×
700
        if err := stream.RecvMsg(m); err != nil {
×
701
                return err
×
702
        }
×
703
        return srv.(RouterServer).TrackPaymentV2(m, &routerTrackPaymentV2Server{stream})
×
704
}
705

706
type Router_TrackPaymentV2Server interface {
707
        Send(*lnrpc.Payment) error
708
        grpc.ServerStream
709
}
710

711
type routerTrackPaymentV2Server struct {
712
        grpc.ServerStream
713
}
714

715
func (x *routerTrackPaymentV2Server) Send(m *lnrpc.Payment) error {
×
716
        return x.ServerStream.SendMsg(m)
×
717
}
×
718

719
func _Router_TrackPayments_Handler(srv interface{}, stream grpc.ServerStream) error {
×
720
        m := new(TrackPaymentsRequest)
×
721
        if err := stream.RecvMsg(m); err != nil {
×
722
                return err
×
723
        }
×
724
        return srv.(RouterServer).TrackPayments(m, &routerTrackPaymentsServer{stream})
×
725
}
726

727
type Router_TrackPaymentsServer interface {
728
        Send(*lnrpc.Payment) error
729
        grpc.ServerStream
730
}
731

732
type routerTrackPaymentsServer struct {
733
        grpc.ServerStream
734
}
735

736
func (x *routerTrackPaymentsServer) Send(m *lnrpc.Payment) error {
×
737
        return x.ServerStream.SendMsg(m)
×
738
}
×
739

740
func _Router_EstimateRouteFee_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
741
        in := new(RouteFeeRequest)
×
742
        if err := dec(in); err != nil {
×
743
                return nil, err
×
744
        }
×
745
        if interceptor == nil {
×
746
                return srv.(RouterServer).EstimateRouteFee(ctx, in)
×
747
        }
×
748
        info := &grpc.UnaryServerInfo{
×
749
                Server:     srv,
×
750
                FullMethod: "/routerrpc.Router/EstimateRouteFee",
×
751
        }
×
752
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
753
                return srv.(RouterServer).EstimateRouteFee(ctx, req.(*RouteFeeRequest))
×
754
        }
×
755
        return interceptor(ctx, in, info, handler)
×
756
}
757

758
func _Router_SendToRoute_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
759
        in := new(SendToRouteRequest)
×
760
        if err := dec(in); err != nil {
×
761
                return nil, err
×
762
        }
×
763
        if interceptor == nil {
×
764
                return srv.(RouterServer).SendToRoute(ctx, in)
×
765
        }
×
766
        info := &grpc.UnaryServerInfo{
×
767
                Server:     srv,
×
768
                FullMethod: "/routerrpc.Router/SendToRoute",
×
769
        }
×
770
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
771
                return srv.(RouterServer).SendToRoute(ctx, req.(*SendToRouteRequest))
×
772
        }
×
773
        return interceptor(ctx, in, info, handler)
×
774
}
775

776
func _Router_SendToRouteV2_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
777
        in := new(SendToRouteRequest)
×
778
        if err := dec(in); err != nil {
×
779
                return nil, err
×
780
        }
×
781
        if interceptor == nil {
×
782
                return srv.(RouterServer).SendToRouteV2(ctx, in)
×
783
        }
×
784
        info := &grpc.UnaryServerInfo{
×
785
                Server:     srv,
×
786
                FullMethod: "/routerrpc.Router/SendToRouteV2",
×
787
        }
×
788
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
789
                return srv.(RouterServer).SendToRouteV2(ctx, req.(*SendToRouteRequest))
×
790
        }
×
791
        return interceptor(ctx, in, info, handler)
×
792
}
793

794
func _Router_ResetMissionControl_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
795
        in := new(ResetMissionControlRequest)
×
796
        if err := dec(in); err != nil {
×
797
                return nil, err
×
798
        }
×
799
        if interceptor == nil {
×
800
                return srv.(RouterServer).ResetMissionControl(ctx, in)
×
801
        }
×
802
        info := &grpc.UnaryServerInfo{
×
803
                Server:     srv,
×
804
                FullMethod: "/routerrpc.Router/ResetMissionControl",
×
805
        }
×
806
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
807
                return srv.(RouterServer).ResetMissionControl(ctx, req.(*ResetMissionControlRequest))
×
808
        }
×
809
        return interceptor(ctx, in, info, handler)
×
810
}
811

812
func _Router_QueryMissionControl_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
813
        in := new(QueryMissionControlRequest)
×
814
        if err := dec(in); err != nil {
×
815
                return nil, err
×
816
        }
×
817
        if interceptor == nil {
×
818
                return srv.(RouterServer).QueryMissionControl(ctx, in)
×
819
        }
×
820
        info := &grpc.UnaryServerInfo{
×
821
                Server:     srv,
×
822
                FullMethod: "/routerrpc.Router/QueryMissionControl",
×
823
        }
×
824
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
825
                return srv.(RouterServer).QueryMissionControl(ctx, req.(*QueryMissionControlRequest))
×
826
        }
×
827
        return interceptor(ctx, in, info, handler)
×
828
}
829

830
func _Router_XImportMissionControl_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
831
        in := new(XImportMissionControlRequest)
×
832
        if err := dec(in); err != nil {
×
833
                return nil, err
×
834
        }
×
835
        if interceptor == nil {
×
836
                return srv.(RouterServer).XImportMissionControl(ctx, in)
×
837
        }
×
838
        info := &grpc.UnaryServerInfo{
×
839
                Server:     srv,
×
840
                FullMethod: "/routerrpc.Router/XImportMissionControl",
×
841
        }
×
842
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
843
                return srv.(RouterServer).XImportMissionControl(ctx, req.(*XImportMissionControlRequest))
×
844
        }
×
845
        return interceptor(ctx, in, info, handler)
×
846
}
847

848
func _Router_GetMissionControlConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
849
        in := new(GetMissionControlConfigRequest)
×
850
        if err := dec(in); err != nil {
×
851
                return nil, err
×
852
        }
×
853
        if interceptor == nil {
×
854
                return srv.(RouterServer).GetMissionControlConfig(ctx, in)
×
855
        }
×
856
        info := &grpc.UnaryServerInfo{
×
857
                Server:     srv,
×
858
                FullMethod: "/routerrpc.Router/GetMissionControlConfig",
×
859
        }
×
860
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
861
                return srv.(RouterServer).GetMissionControlConfig(ctx, req.(*GetMissionControlConfigRequest))
×
862
        }
×
863
        return interceptor(ctx, in, info, handler)
×
864
}
865

866
func _Router_SetMissionControlConfig_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
867
        in := new(SetMissionControlConfigRequest)
×
868
        if err := dec(in); err != nil {
×
869
                return nil, err
×
870
        }
×
871
        if interceptor == nil {
×
872
                return srv.(RouterServer).SetMissionControlConfig(ctx, in)
×
873
        }
×
874
        info := &grpc.UnaryServerInfo{
×
875
                Server:     srv,
×
876
                FullMethod: "/routerrpc.Router/SetMissionControlConfig",
×
877
        }
×
878
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
879
                return srv.(RouterServer).SetMissionControlConfig(ctx, req.(*SetMissionControlConfigRequest))
×
880
        }
×
881
        return interceptor(ctx, in, info, handler)
×
882
}
883

884
func _Router_QueryProbability_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
885
        in := new(QueryProbabilityRequest)
×
886
        if err := dec(in); err != nil {
×
887
                return nil, err
×
888
        }
×
889
        if interceptor == nil {
×
890
                return srv.(RouterServer).QueryProbability(ctx, in)
×
891
        }
×
892
        info := &grpc.UnaryServerInfo{
×
893
                Server:     srv,
×
894
                FullMethod: "/routerrpc.Router/QueryProbability",
×
895
        }
×
896
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
897
                return srv.(RouterServer).QueryProbability(ctx, req.(*QueryProbabilityRequest))
×
898
        }
×
899
        return interceptor(ctx, in, info, handler)
×
900
}
901

902
func _Router_BuildRoute_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
903
        in := new(BuildRouteRequest)
×
904
        if err := dec(in); err != nil {
×
905
                return nil, err
×
906
        }
×
907
        if interceptor == nil {
×
908
                return srv.(RouterServer).BuildRoute(ctx, in)
×
909
        }
×
910
        info := &grpc.UnaryServerInfo{
×
911
                Server:     srv,
×
912
                FullMethod: "/routerrpc.Router/BuildRoute",
×
913
        }
×
914
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
915
                return srv.(RouterServer).BuildRoute(ctx, req.(*BuildRouteRequest))
×
916
        }
×
917
        return interceptor(ctx, in, info, handler)
×
918
}
919

920
func _Router_SubscribeHtlcEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
×
921
        m := new(SubscribeHtlcEventsRequest)
×
922
        if err := stream.RecvMsg(m); err != nil {
×
923
                return err
×
924
        }
×
925
        return srv.(RouterServer).SubscribeHtlcEvents(m, &routerSubscribeHtlcEventsServer{stream})
×
926
}
927

928
type Router_SubscribeHtlcEventsServer interface {
929
        Send(*HtlcEvent) error
930
        grpc.ServerStream
931
}
932

933
type routerSubscribeHtlcEventsServer struct {
934
        grpc.ServerStream
935
}
936

937
func (x *routerSubscribeHtlcEventsServer) Send(m *HtlcEvent) error {
×
938
        return x.ServerStream.SendMsg(m)
×
939
}
×
940

941
func _Router_SendPayment_Handler(srv interface{}, stream grpc.ServerStream) error {
×
942
        m := new(SendPaymentRequest)
×
943
        if err := stream.RecvMsg(m); err != nil {
×
944
                return err
×
945
        }
×
946
        return srv.(RouterServer).SendPayment(m, &routerSendPaymentServer{stream})
×
947
}
948

949
type Router_SendPaymentServer interface {
950
        Send(*PaymentStatus) error
951
        grpc.ServerStream
952
}
953

954
type routerSendPaymentServer struct {
955
        grpc.ServerStream
956
}
957

958
func (x *routerSendPaymentServer) Send(m *PaymentStatus) error {
×
959
        return x.ServerStream.SendMsg(m)
×
960
}
×
961

962
func _Router_TrackPayment_Handler(srv interface{}, stream grpc.ServerStream) error {
×
963
        m := new(TrackPaymentRequest)
×
964
        if err := stream.RecvMsg(m); err != nil {
×
965
                return err
×
966
        }
×
967
        return srv.(RouterServer).TrackPayment(m, &routerTrackPaymentServer{stream})
×
968
}
969

970
type Router_TrackPaymentServer interface {
971
        Send(*PaymentStatus) error
972
        grpc.ServerStream
973
}
974

975
type routerTrackPaymentServer struct {
976
        grpc.ServerStream
977
}
978

979
func (x *routerTrackPaymentServer) Send(m *PaymentStatus) error {
×
980
        return x.ServerStream.SendMsg(m)
×
981
}
×
982

983
func _Router_HtlcInterceptor_Handler(srv interface{}, stream grpc.ServerStream) error {
×
984
        return srv.(RouterServer).HtlcInterceptor(&routerHtlcInterceptorServer{stream})
×
985
}
×
986

987
type Router_HtlcInterceptorServer interface {
988
        Send(*ForwardHtlcInterceptRequest) error
989
        Recv() (*ForwardHtlcInterceptResponse, error)
990
        grpc.ServerStream
991
}
992

993
type routerHtlcInterceptorServer struct {
994
        grpc.ServerStream
995
}
996

997
func (x *routerHtlcInterceptorServer) Send(m *ForwardHtlcInterceptRequest) error {
×
998
        return x.ServerStream.SendMsg(m)
×
999
}
×
1000

1001
func (x *routerHtlcInterceptorServer) Recv() (*ForwardHtlcInterceptResponse, error) {
×
1002
        m := new(ForwardHtlcInterceptResponse)
×
1003
        if err := x.ServerStream.RecvMsg(m); err != nil {
×
1004
                return nil, err
×
1005
        }
×
1006
        return m, nil
×
1007
}
1008

1009
func _Router_UpdateChanStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
1010
        in := new(UpdateChanStatusRequest)
×
1011
        if err := dec(in); err != nil {
×
1012
                return nil, err
×
1013
        }
×
1014
        if interceptor == nil {
×
1015
                return srv.(RouterServer).UpdateChanStatus(ctx, in)
×
1016
        }
×
1017
        info := &grpc.UnaryServerInfo{
×
1018
                Server:     srv,
×
1019
                FullMethod: "/routerrpc.Router/UpdateChanStatus",
×
1020
        }
×
1021
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
1022
                return srv.(RouterServer).UpdateChanStatus(ctx, req.(*UpdateChanStatusRequest))
×
1023
        }
×
1024
        return interceptor(ctx, in, info, handler)
×
1025
}
1026

1027
func _Router_XAddLocalChanAliases_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
1028
        in := new(AddAliasesRequest)
×
1029
        if err := dec(in); err != nil {
×
1030
                return nil, err
×
1031
        }
×
1032
        if interceptor == nil {
×
1033
                return srv.(RouterServer).XAddLocalChanAliases(ctx, in)
×
1034
        }
×
1035
        info := &grpc.UnaryServerInfo{
×
1036
                Server:     srv,
×
1037
                FullMethod: "/routerrpc.Router/XAddLocalChanAliases",
×
1038
        }
×
1039
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
1040
                return srv.(RouterServer).XAddLocalChanAliases(ctx, req.(*AddAliasesRequest))
×
1041
        }
×
1042
        return interceptor(ctx, in, info, handler)
×
1043
}
1044

1045
func _Router_XDeleteLocalChanAliases_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
1046
        in := new(DeleteAliasesRequest)
×
1047
        if err := dec(in); err != nil {
×
1048
                return nil, err
×
1049
        }
×
1050
        if interceptor == nil {
×
1051
                return srv.(RouterServer).XDeleteLocalChanAliases(ctx, in)
×
1052
        }
×
1053
        info := &grpc.UnaryServerInfo{
×
1054
                Server:     srv,
×
1055
                FullMethod: "/routerrpc.Router/XDeleteLocalChanAliases",
×
1056
        }
×
1057
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
1058
                return srv.(RouterServer).XDeleteLocalChanAliases(ctx, req.(*DeleteAliasesRequest))
×
1059
        }
×
1060
        return interceptor(ctx, in, info, handler)
×
1061
}
1062

1063
// Router_ServiceDesc is the grpc.ServiceDesc for Router service.
1064
// It's only intended for direct use with grpc.RegisterService,
1065
// and not to be introspected or modified (even as a copy)
1066
var Router_ServiceDesc = grpc.ServiceDesc{
1067
        ServiceName: "routerrpc.Router",
1068
        HandlerType: (*RouterServer)(nil),
1069
        Methods: []grpc.MethodDesc{
1070
                {
1071
                        MethodName: "EstimateRouteFee",
1072
                        Handler:    _Router_EstimateRouteFee_Handler,
1073
                },
1074
                {
1075
                        MethodName: "SendToRoute",
1076
                        Handler:    _Router_SendToRoute_Handler,
1077
                },
1078
                {
1079
                        MethodName: "SendToRouteV2",
1080
                        Handler:    _Router_SendToRouteV2_Handler,
1081
                },
1082
                {
1083
                        MethodName: "ResetMissionControl",
1084
                        Handler:    _Router_ResetMissionControl_Handler,
1085
                },
1086
                {
1087
                        MethodName: "QueryMissionControl",
1088
                        Handler:    _Router_QueryMissionControl_Handler,
1089
                },
1090
                {
1091
                        MethodName: "XImportMissionControl",
1092
                        Handler:    _Router_XImportMissionControl_Handler,
1093
                },
1094
                {
1095
                        MethodName: "GetMissionControlConfig",
1096
                        Handler:    _Router_GetMissionControlConfig_Handler,
1097
                },
1098
                {
1099
                        MethodName: "SetMissionControlConfig",
1100
                        Handler:    _Router_SetMissionControlConfig_Handler,
1101
                },
1102
                {
1103
                        MethodName: "QueryProbability",
1104
                        Handler:    _Router_QueryProbability_Handler,
1105
                },
1106
                {
1107
                        MethodName: "BuildRoute",
1108
                        Handler:    _Router_BuildRoute_Handler,
1109
                },
1110
                {
1111
                        MethodName: "UpdateChanStatus",
1112
                        Handler:    _Router_UpdateChanStatus_Handler,
1113
                },
1114
                {
1115
                        MethodName: "XAddLocalChanAliases",
1116
                        Handler:    _Router_XAddLocalChanAliases_Handler,
1117
                },
1118
                {
1119
                        MethodName: "XDeleteLocalChanAliases",
1120
                        Handler:    _Router_XDeleteLocalChanAliases_Handler,
1121
                },
1122
        },
1123
        Streams: []grpc.StreamDesc{
1124
                {
1125
                        StreamName:    "SendPaymentV2",
1126
                        Handler:       _Router_SendPaymentV2_Handler,
1127
                        ServerStreams: true,
1128
                },
1129
                {
1130
                        StreamName:    "TrackPaymentV2",
1131
                        Handler:       _Router_TrackPaymentV2_Handler,
1132
                        ServerStreams: true,
1133
                },
1134
                {
1135
                        StreamName:    "TrackPayments",
1136
                        Handler:       _Router_TrackPayments_Handler,
1137
                        ServerStreams: true,
1138
                },
1139
                {
1140
                        StreamName:    "SubscribeHtlcEvents",
1141
                        Handler:       _Router_SubscribeHtlcEvents_Handler,
1142
                        ServerStreams: true,
1143
                },
1144
                {
1145
                        StreamName:    "SendPayment",
1146
                        Handler:       _Router_SendPayment_Handler,
1147
                        ServerStreams: true,
1148
                },
1149
                {
1150
                        StreamName:    "TrackPayment",
1151
                        Handler:       _Router_TrackPayment_Handler,
1152
                        ServerStreams: true,
1153
                },
1154
                {
1155
                        StreamName:    "HtlcInterceptor",
1156
                        Handler:       _Router_HtlcInterceptor_Handler,
1157
                        ServerStreams: true,
1158
                        ClientStreams: true,
1159
                },
1160
        },
1161
        Metadata: "routerrpc/router.proto",
1162
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2025 Coveralls, Inc