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

lightningnetwork / lnd / 13583650550

28 Feb 2025 07:47AM UTC coverage: 58.867% (+0.009%) from 58.858%
13583650550

Pull #9555

github

ellemouton
graph/db: populate the graph cache in Start instead of during construction

In this commit, we move the graph cache population logic out of the
ChannelGraph constructor and into its Start method instead.
Pull Request #9555: graph: extract cache from CRUD [6]

42 of 56 new or added lines in 4 files covered. (75.0%)

38 existing lines in 12 files now uncovered.

136653 of 232137 relevant lines covered (58.87%)

19232.93 hits per line

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

36.58
/lnrpc/lightning_grpc.pb.go
1
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
2

3
package lnrpc
4

5
import (
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.
15
const _ = grpc.SupportPackageIsVersion7
16

17
// LightningClient is the client API for Lightning 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.
20
type LightningClient interface {
21
        // lncli: `walletbalance`
22
        // WalletBalance returns total unspent outputs(confirmed and unconfirmed), all
23
        // confirmed unspent outputs and all unconfirmed unspent outputs under control
24
        // of the wallet.
25
        WalletBalance(ctx context.Context, in *WalletBalanceRequest, opts ...grpc.CallOption) (*WalletBalanceResponse, error)
26
        // lncli: `channelbalance`
27
        // ChannelBalance returns a report on the total funds across all open channels,
28
        // categorized in local/remote, pending local/remote and unsettled local/remote
29
        // balances.
30
        ChannelBalance(ctx context.Context, in *ChannelBalanceRequest, opts ...grpc.CallOption) (*ChannelBalanceResponse, error)
31
        // lncli: `listchaintxns`
32
        // GetTransactions returns a list describing all the known transactions
33
        // relevant to the wallet.
34
        GetTransactions(ctx context.Context, in *GetTransactionsRequest, opts ...grpc.CallOption) (*TransactionDetails, error)
35
        // lncli: `estimatefee`
36
        // EstimateFee asks the chain backend to estimate the fee rate and total fees
37
        // for a transaction that pays to multiple specified outputs.
38
        //
39
        // When using REST, the `AddrToAmount` map type can be set by appending
40
        // `&AddrToAmount[<address>]=<amount_to_send>` to the URL. Unfortunately this
41
        // map type doesn't appear in the REST API documentation because of a bug in
42
        // the grpc-gateway library.
43
        EstimateFee(ctx context.Context, in *EstimateFeeRequest, opts ...grpc.CallOption) (*EstimateFeeResponse, error)
44
        // lncli: `sendcoins`
45
        // SendCoins executes a request to send coins to a particular address. Unlike
46
        // SendMany, this RPC call only allows creating a single output at a time. If
47
        // neither target_conf, or sat_per_vbyte are set, then the internal wallet will
48
        // consult its fee model to determine a fee for the default confirmation
49
        // target.
50
        SendCoins(ctx context.Context, in *SendCoinsRequest, opts ...grpc.CallOption) (*SendCoinsResponse, error)
51
        // lncli: `listunspent`
52
        // Deprecated, use walletrpc.ListUnspent instead.
53
        //
54
        // ListUnspent returns a list of all utxos spendable by the wallet with a
55
        // number of confirmations between the specified minimum and maximum.
56
        ListUnspent(ctx context.Context, in *ListUnspentRequest, opts ...grpc.CallOption) (*ListUnspentResponse, error)
57
        // SubscribeTransactions creates a uni-directional stream from the server to
58
        // the client in which any newly discovered transactions relevant to the
59
        // wallet are sent over.
60
        SubscribeTransactions(ctx context.Context, in *GetTransactionsRequest, opts ...grpc.CallOption) (Lightning_SubscribeTransactionsClient, error)
61
        // lncli: `sendmany`
62
        // SendMany handles a request for a transaction that creates multiple specified
63
        // outputs in parallel. If neither target_conf, or sat_per_vbyte are set, then
64
        // the internal wallet will consult its fee model to determine a fee for the
65
        // default confirmation target.
66
        SendMany(ctx context.Context, in *SendManyRequest, opts ...grpc.CallOption) (*SendManyResponse, error)
67
        // lncli: `newaddress`
68
        // NewAddress creates a new address under control of the local wallet.
69
        NewAddress(ctx context.Context, in *NewAddressRequest, opts ...grpc.CallOption) (*NewAddressResponse, error)
70
        // lncli: `signmessage`
71
        // SignMessage signs a message with this node's private key. The returned
72
        // signature string is `zbase32` encoded and pubkey recoverable, meaning that
73
        // only the message digest and signature are needed for verification.
74
        SignMessage(ctx context.Context, in *SignMessageRequest, opts ...grpc.CallOption) (*SignMessageResponse, error)
75
        // lncli: `verifymessage`
76
        // VerifyMessage verifies a signature over a message and recovers the signer's
77
        // public key. The signature is only deemed valid if the recovered public key
78
        // corresponds to a node key in the public Lightning network. The signature
79
        // must be zbase32 encoded and signed by an active node in the resident node's
80
        // channel database. In addition to returning the validity of the signature,
81
        // VerifyMessage also returns the recovered pubkey from the signature.
82
        VerifyMessage(ctx context.Context, in *VerifyMessageRequest, opts ...grpc.CallOption) (*VerifyMessageResponse, error)
83
        // lncli: `connect`
84
        // ConnectPeer attempts to establish a connection to a remote peer. This is at
85
        // the networking level, and is used for communication between nodes. This is
86
        // distinct from establishing a channel with a peer.
87
        ConnectPeer(ctx context.Context, in *ConnectPeerRequest, opts ...grpc.CallOption) (*ConnectPeerResponse, error)
88
        // lncli: `disconnect`
89
        // DisconnectPeer attempts to disconnect one peer from another identified by a
90
        // given pubKey. In the case that we currently have a pending or active channel
91
        // with the target peer, then this action will be not be allowed.
92
        DisconnectPeer(ctx context.Context, in *DisconnectPeerRequest, opts ...grpc.CallOption) (*DisconnectPeerResponse, error)
93
        // lncli: `listpeers`
94
        // ListPeers returns a verbose listing of all currently active peers.
95
        ListPeers(ctx context.Context, in *ListPeersRequest, opts ...grpc.CallOption) (*ListPeersResponse, error)
96
        // SubscribePeerEvents creates a uni-directional stream from the server to
97
        // the client in which any events relevant to the state of peers are sent
98
        // over. Events include peers going online and offline.
99
        SubscribePeerEvents(ctx context.Context, in *PeerEventSubscription, opts ...grpc.CallOption) (Lightning_SubscribePeerEventsClient, error)
100
        // lncli: `getinfo`
101
        // GetInfo returns general information concerning the lightning node including
102
        // it's identity pubkey, alias, the chains it is connected to, and information
103
        // concerning the number of open+pending channels.
104
        GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error)
105
        // lncli: 'getdebuginfo'
106
        // GetDebugInfo returns debug information concerning the state of the daemon
107
        // and its subsystems. This includes the full configuration and the latest log
108
        // entries from the log file.
109
        GetDebugInfo(ctx context.Context, in *GetDebugInfoRequest, opts ...grpc.CallOption) (*GetDebugInfoResponse, error)
110
        // * lncli: `getrecoveryinfo`
111
        // GetRecoveryInfo returns information concerning the recovery mode including
112
        // whether it's in a recovery mode, whether the recovery is finished, and the
113
        // progress made so far.
114
        GetRecoveryInfo(ctx context.Context, in *GetRecoveryInfoRequest, opts ...grpc.CallOption) (*GetRecoveryInfoResponse, error)
115
        // lncli: `pendingchannels`
116
        // PendingChannels returns a list of all the channels that are currently
117
        // considered "pending". A channel is pending if it has finished the funding
118
        // workflow and is waiting for confirmations for the funding txn, or is in the
119
        // process of closure, either initiated cooperatively or non-cooperatively.
120
        PendingChannels(ctx context.Context, in *PendingChannelsRequest, opts ...grpc.CallOption) (*PendingChannelsResponse, error)
121
        // lncli: `listchannels`
122
        // ListChannels returns a description of all the open channels that this node
123
        // is a participant in.
124
        ListChannels(ctx context.Context, in *ListChannelsRequest, opts ...grpc.CallOption) (*ListChannelsResponse, error)
125
        // SubscribeChannelEvents creates a uni-directional stream from the server to
126
        // the client in which any updates relevant to the state of the channels are
127
        // sent over. Events include new active channels, inactive channels, and closed
128
        // channels.
129
        SubscribeChannelEvents(ctx context.Context, in *ChannelEventSubscription, opts ...grpc.CallOption) (Lightning_SubscribeChannelEventsClient, error)
130
        // lncli: `closedchannels`
131
        // ClosedChannels returns a description of all the closed channels that
132
        // this node was a participant in.
133
        ClosedChannels(ctx context.Context, in *ClosedChannelsRequest, opts ...grpc.CallOption) (*ClosedChannelsResponse, error)
134
        // OpenChannelSync is a synchronous version of the OpenChannel RPC call. This
135
        // call is meant to be consumed by clients to the REST proxy. As with all
136
        // other sync calls, all byte slices are intended to be populated as hex
137
        // encoded strings.
138
        OpenChannelSync(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*ChannelPoint, error)
139
        // lncli: `openchannel`
140
        // OpenChannel attempts to open a singly funded channel specified in the
141
        // request to a remote peer. Users are able to specify a target number of
142
        // blocks that the funding transaction should be confirmed in, or a manual fee
143
        // rate to us for the funding transaction. If neither are specified, then a
144
        // lax block confirmation target is used. Each OpenStatusUpdate will return
145
        // the pending channel ID of the in-progress channel. Depending on the
146
        // arguments specified in the OpenChannelRequest, this pending channel ID can
147
        // then be used to manually progress the channel funding flow.
148
        OpenChannel(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (Lightning_OpenChannelClient, error)
149
        // lncli: `batchopenchannel`
150
        // BatchOpenChannel attempts to open multiple single-funded channels in a
151
        // single transaction in an atomic way. This means either all channel open
152
        // requests succeed at once or all attempts are aborted if any of them fail.
153
        // This is the safer variant of using PSBTs to manually fund a batch of
154
        // channels through the OpenChannel RPC.
155
        BatchOpenChannel(ctx context.Context, in *BatchOpenChannelRequest, opts ...grpc.CallOption) (*BatchOpenChannelResponse, error)
156
        // FundingStateStep is an advanced funding related call that allows the caller
157
        // to either execute some preparatory steps for a funding workflow, or
158
        // manually progress a funding workflow. The primary way a funding flow is
159
        // identified is via its pending channel ID. As an example, this method can be
160
        // used to specify that we're expecting a funding flow for a particular
161
        // pending channel ID, for which we need to use specific parameters.
162
        // Alternatively, this can be used to interactively drive PSBT signing for
163
        // funding for partially complete funding transactions.
164
        FundingStateStep(ctx context.Context, in *FundingTransitionMsg, opts ...grpc.CallOption) (*FundingStateStepResp, error)
165
        // ChannelAcceptor dispatches a bi-directional streaming RPC in which
166
        // OpenChannel requests are sent to the client and the client responds with
167
        // a boolean that tells LND whether or not to accept the channel. This allows
168
        // node operators to specify their own criteria for accepting inbound channels
169
        // through a single persistent connection.
170
        ChannelAcceptor(ctx context.Context, opts ...grpc.CallOption) (Lightning_ChannelAcceptorClient, error)
171
        // lncli: `closechannel`
172
        // CloseChannel attempts to close an active channel identified by its channel
173
        // outpoint (ChannelPoint). The actions of this method can additionally be
174
        // augmented to attempt a force close after a timeout period in the case of an
175
        // inactive peer. If a non-force close (cooperative closure) is requested,
176
        // then the user can specify either a target number of blocks until the
177
        // closure transaction is confirmed, or a manual fee rate. If neither are
178
        // specified, then a default lax, block confirmation target is used.
179
        CloseChannel(ctx context.Context, in *CloseChannelRequest, opts ...grpc.CallOption) (Lightning_CloseChannelClient, error)
180
        // lncli: `abandonchannel`
181
        // AbandonChannel removes all channel state from the database except for a
182
        // close summary. This method can be used to get rid of permanently unusable
183
        // channels due to bugs fixed in newer versions of lnd. This method can also be
184
        // used to remove externally funded channels where the funding transaction was
185
        // never broadcast. Only available for non-externally funded channels in dev
186
        // build.
187
        AbandonChannel(ctx context.Context, in *AbandonChannelRequest, opts ...grpc.CallOption) (*AbandonChannelResponse, error)
188
        // Deprecated: Do not use.
189
        // lncli: `sendpayment`
190
        // Deprecated, use routerrpc.SendPaymentV2. SendPayment dispatches a
191
        // bi-directional streaming RPC for sending payments through the Lightning
192
        // Network. A single RPC invocation creates a persistent bi-directional
193
        // stream allowing clients to rapidly send payments through the Lightning
194
        // Network with a single persistent connection.
195
        SendPayment(ctx context.Context, opts ...grpc.CallOption) (Lightning_SendPaymentClient, error)
196
        // Deprecated: Do not use.
197
        //
198
        // Deprecated, use routerrpc.SendPaymentV2. SendPaymentSync is the synchronous
199
        // non-streaming version of SendPayment. This RPC is intended to be consumed by
200
        // clients of the REST proxy. Additionally, this RPC expects the destination's
201
        // public key and the payment hash (if any) to be encoded as hex strings.
202
        SendPaymentSync(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)
203
        // Deprecated: Do not use.
204
        // lncli: `sendtoroute`
205
        // Deprecated, use routerrpc.SendToRouteV2. SendToRoute is a bi-directional
206
        // streaming RPC for sending payment through the Lightning Network. This
207
        // method differs from SendPayment in that it allows users to specify a full
208
        // route manually. This can be used for things like rebalancing, and atomic
209
        // swaps.
210
        SendToRoute(ctx context.Context, opts ...grpc.CallOption) (Lightning_SendToRouteClient, error)
211
        // Deprecated: Do not use.
212
        //
213
        // Deprecated, use routerrpc.SendToRouteV2. SendToRouteSync is a synchronous
214
        // version of SendToRoute. It Will block until the payment either fails or
215
        // succeeds.
216
        SendToRouteSync(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*SendResponse, error)
217
        // lncli: `addinvoice`
218
        // AddInvoice attempts to add a new invoice to the invoice database. Any
219
        // duplicated invoices are rejected, therefore all invoices *must* have a
220
        // unique payment preimage.
221
        AddInvoice(ctx context.Context, in *Invoice, opts ...grpc.CallOption) (*AddInvoiceResponse, error)
222
        // lncli: `listinvoices`
223
        // ListInvoices returns a list of all the invoices currently stored within the
224
        // database. Any active debug invoices are ignored. It has full support for
225
        // paginated responses, allowing users to query for specific invoices through
226
        // their add_index. This can be done by using either the first_index_offset or
227
        // last_index_offset fields included in the response as the index_offset of the
228
        // next request. By default, the first 100 invoices created will be returned.
229
        // Backwards pagination is also supported through the Reversed flag.
230
        ListInvoices(ctx context.Context, in *ListInvoiceRequest, opts ...grpc.CallOption) (*ListInvoiceResponse, error)
231
        // lncli: `lookupinvoice`
232
        // LookupInvoice attempts to look up an invoice according to its payment hash.
233
        // The passed payment hash *must* be exactly 32 bytes, if not, an error is
234
        // returned.
235
        LookupInvoice(ctx context.Context, in *PaymentHash, opts ...grpc.CallOption) (*Invoice, error)
236
        // SubscribeInvoices returns a uni-directional stream (server -> client) for
237
        // notifying the client of newly added/settled invoices. The caller can
238
        // optionally specify the add_index and/or the settle_index. If the add_index
239
        // is specified, then we'll first start by sending add invoice events for all
240
        // invoices with an add_index greater than the specified value. If the
241
        // settle_index is specified, then next, we'll send out all settle events for
242
        // invoices with a settle_index greater than the specified value. One or both
243
        // of these fields can be set. If no fields are set, then we'll only send out
244
        // the latest add/settle events.
245
        SubscribeInvoices(ctx context.Context, in *InvoiceSubscription, opts ...grpc.CallOption) (Lightning_SubscribeInvoicesClient, error)
246
        // lncli: `decodepayreq`
247
        // DecodePayReq takes an encoded payment request string and attempts to decode
248
        // it, returning a full description of the conditions encoded within the
249
        // payment request.
250
        DecodePayReq(ctx context.Context, in *PayReqString, opts ...grpc.CallOption) (*PayReq, error)
251
        // lncli: `listpayments`
252
        // ListPayments returns a list of all outgoing payments.
253
        ListPayments(ctx context.Context, in *ListPaymentsRequest, opts ...grpc.CallOption) (*ListPaymentsResponse, error)
254
        // lncli: `deletepayments`
255
        // DeletePayment deletes an outgoing payment from DB. Note that it will not
256
        // attempt to delete an In-Flight payment, since that would be unsafe.
257
        DeletePayment(ctx context.Context, in *DeletePaymentRequest, opts ...grpc.CallOption) (*DeletePaymentResponse, error)
258
        // lncli: `deletepayments --all`
259
        // DeleteAllPayments deletes all outgoing payments from DB. Note that it will
260
        // not attempt to delete In-Flight payments, since that would be unsafe.
261
        DeleteAllPayments(ctx context.Context, in *DeleteAllPaymentsRequest, opts ...grpc.CallOption) (*DeleteAllPaymentsResponse, error)
262
        // lncli: `describegraph`
263
        // DescribeGraph returns a description of the latest graph state from the
264
        // point of view of the node. The graph information is partitioned into two
265
        // components: all the nodes/vertexes, and all the edges that connect the
266
        // vertexes themselves. As this is a directed graph, the edges also contain
267
        // the node directional specific routing policy which includes: the time lock
268
        // delta, fee information, etc.
269
        DescribeGraph(ctx context.Context, in *ChannelGraphRequest, opts ...grpc.CallOption) (*ChannelGraph, error)
270
        // lncli: `getnodemetrics`
271
        // GetNodeMetrics returns node metrics calculated from the graph. Currently
272
        // the only supported metric is betweenness centrality of individual nodes.
273
        GetNodeMetrics(ctx context.Context, in *NodeMetricsRequest, opts ...grpc.CallOption) (*NodeMetricsResponse, error)
274
        // lncli: `getchaninfo`
275
        // GetChanInfo returns the latest authenticated network announcement for the
276
        // given channel identified by its channel ID: an 8-byte integer which
277
        // uniquely identifies the location of transaction's funding output within the
278
        // blockchain.
279
        GetChanInfo(ctx context.Context, in *ChanInfoRequest, opts ...grpc.CallOption) (*ChannelEdge, error)
280
        // lncli: `getnodeinfo`
281
        // GetNodeInfo returns the latest advertised, aggregated, and authenticated
282
        // channel information for the specified node identified by its public key.
283
        GetNodeInfo(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfo, error)
284
        // lncli: `queryroutes`
285
        // QueryRoutes attempts to query the daemon's Channel Router for a possible
286
        // route to a target destination capable of carrying a specific amount of
287
        // satoshis. The returned route contains the full details required to craft and
288
        // send an HTLC, also including the necessary information that should be
289
        // present within the Sphinx packet encapsulated within the HTLC.
290
        //
291
        // When using REST, the `dest_custom_records` map type can be set by appending
292
        // `&dest_custom_records[<record_number>]=<record_data_base64_url_encoded>`
293
        // to the URL. Unfortunately this map type doesn't appear in the REST API
294
        // documentation because of a bug in the grpc-gateway library.
295
        QueryRoutes(ctx context.Context, in *QueryRoutesRequest, opts ...grpc.CallOption) (*QueryRoutesResponse, error)
296
        // lncli: `getnetworkinfo`
297
        // GetNetworkInfo returns some basic stats about the known channel graph from
298
        // the point of view of the node.
299
        GetNetworkInfo(ctx context.Context, in *NetworkInfoRequest, opts ...grpc.CallOption) (*NetworkInfo, error)
300
        // lncli: `stop`
301
        // StopDaemon will send a shutdown request to the interrupt handler, triggering
302
        // a graceful shutdown of the daemon.
303
        StopDaemon(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
304
        // SubscribeChannelGraph launches a streaming RPC that allows the caller to
305
        // receive notifications upon any changes to the channel graph topology from
306
        // the point of view of the responding node. Events notified include: new
307
        // nodes coming online, nodes updating their authenticated attributes, new
308
        // channels being advertised, updates in the routing policy for a directional
309
        // channel edge, and when channels are closed on-chain.
310
        SubscribeChannelGraph(ctx context.Context, in *GraphTopologySubscription, opts ...grpc.CallOption) (Lightning_SubscribeChannelGraphClient, error)
311
        // lncli: `debuglevel`
312
        // DebugLevel allows a caller to programmatically set the logging verbosity of
313
        // lnd. The logging can be targeted according to a coarse daemon-wide logging
314
        // level, or in a granular fashion to specify the logging for a target
315
        // sub-system.
316
        DebugLevel(ctx context.Context, in *DebugLevelRequest, opts ...grpc.CallOption) (*DebugLevelResponse, error)
317
        // lncli: `feereport`
318
        // FeeReport allows the caller to obtain a report detailing the current fee
319
        // schedule enforced by the node globally for each channel.
320
        FeeReport(ctx context.Context, in *FeeReportRequest, opts ...grpc.CallOption) (*FeeReportResponse, error)
321
        // lncli: `updatechanpolicy`
322
        // UpdateChannelPolicy allows the caller to update the fee schedule and
323
        // channel policies for all channels globally, or a particular channel.
324
        UpdateChannelPolicy(ctx context.Context, in *PolicyUpdateRequest, opts ...grpc.CallOption) (*PolicyUpdateResponse, error)
325
        // lncli: `fwdinghistory`
326
        // ForwardingHistory allows the caller to query the htlcswitch for a record of
327
        // all HTLCs forwarded within the target time range, and integer offset
328
        // within that time range, for a maximum number of events. If no maximum number
329
        // of events is specified, up to 100 events will be returned. If no time-range
330
        // is specified, then events will be returned in the order that they occured.
331
        //
332
        // A list of forwarding events are returned. The size of each forwarding event
333
        // is 40 bytes, and the max message size able to be returned in gRPC is 4 MiB.
334
        // As a result each message can only contain 50k entries. Each response has
335
        // the index offset of the last entry. The index offset can be provided to the
336
        // request to allow the caller to skip a series of records.
337
        ForwardingHistory(ctx context.Context, in *ForwardingHistoryRequest, opts ...grpc.CallOption) (*ForwardingHistoryResponse, error)
338
        // lncli: `exportchanbackup`
339
        // ExportChannelBackup attempts to return an encrypted static channel backup
340
        // for the target channel identified by it channel point. The backup is
341
        // encrypted with a key generated from the aezeed seed of the user. The
342
        // returned backup can either be restored using the RestoreChannelBackup
343
        // method once lnd is running, or via the InitWallet and UnlockWallet methods
344
        // from the WalletUnlocker service.
345
        ExportChannelBackup(ctx context.Context, in *ExportChannelBackupRequest, opts ...grpc.CallOption) (*ChannelBackup, error)
346
        // ExportAllChannelBackups returns static channel backups for all existing
347
        // channels known to lnd. A set of regular singular static channel backups for
348
        // each channel are returned. Additionally, a multi-channel backup is returned
349
        // as well, which contains a single encrypted blob containing the backups of
350
        // each channel.
351
        ExportAllChannelBackups(ctx context.Context, in *ChanBackupExportRequest, opts ...grpc.CallOption) (*ChanBackupSnapshot, error)
352
        // lncli: `verifychanbackup`
353
        // VerifyChanBackup allows a caller to verify the integrity of a channel backup
354
        // snapshot. This method will accept either a packed Single or a packed Multi.
355
        // Specifying both will result in an error.
356
        VerifyChanBackup(ctx context.Context, in *ChanBackupSnapshot, opts ...grpc.CallOption) (*VerifyChanBackupResponse, error)
357
        // lncli: `restorechanbackup`
358
        // RestoreChannelBackups accepts a set of singular channel backups, or a
359
        // single encrypted multi-chan backup and attempts to recover any funds
360
        // remaining within the channel. If we are able to unpack the backup, then the
361
        // new channel will be shown under listchannels, as well as pending channels.
362
        RestoreChannelBackups(ctx context.Context, in *RestoreChanBackupRequest, opts ...grpc.CallOption) (*RestoreBackupResponse, error)
363
        // SubscribeChannelBackups allows a client to sub-subscribe to the most up to
364
        // date information concerning the state of all channel backups. Each time a
365
        // new channel is added, we return the new set of channels, along with a
366
        // multi-chan backup containing the backup info for all channels. Each time a
367
        // channel is closed, we send a new update, which contains new new chan back
368
        // ups, but the updated set of encrypted multi-chan backups with the closed
369
        // channel(s) removed.
370
        SubscribeChannelBackups(ctx context.Context, in *ChannelBackupSubscription, opts ...grpc.CallOption) (Lightning_SubscribeChannelBackupsClient, error)
371
        // lncli: `bakemacaroon`
372
        // BakeMacaroon allows the creation of a new macaroon with custom read and
373
        // write permissions. No first-party caveats are added since this can be done
374
        // offline.
375
        BakeMacaroon(ctx context.Context, in *BakeMacaroonRequest, opts ...grpc.CallOption) (*BakeMacaroonResponse, error)
376
        // lncli: `listmacaroonids`
377
        // ListMacaroonIDs returns all root key IDs that are in use.
378
        ListMacaroonIDs(ctx context.Context, in *ListMacaroonIDsRequest, opts ...grpc.CallOption) (*ListMacaroonIDsResponse, error)
379
        // lncli: `deletemacaroonid`
380
        // DeleteMacaroonID deletes the specified macaroon ID and invalidates all
381
        // macaroons derived from that ID.
382
        DeleteMacaroonID(ctx context.Context, in *DeleteMacaroonIDRequest, opts ...grpc.CallOption) (*DeleteMacaroonIDResponse, error)
383
        // lncli: `listpermissions`
384
        // ListPermissions lists all RPC method URIs and their required macaroon
385
        // permissions to access them.
386
        ListPermissions(ctx context.Context, in *ListPermissionsRequest, opts ...grpc.CallOption) (*ListPermissionsResponse, error)
387
        // CheckMacaroonPermissions checks whether a request follows the constraints
388
        // imposed on the macaroon and that the macaroon is authorized to follow the
389
        // provided permissions.
390
        CheckMacaroonPermissions(ctx context.Context, in *CheckMacPermRequest, opts ...grpc.CallOption) (*CheckMacPermResponse, error)
391
        // RegisterRPCMiddleware adds a new gRPC middleware to the interceptor chain. A
392
        // gRPC middleware is software component external to lnd that aims to add
393
        // additional business logic to lnd by observing/intercepting/validating
394
        // incoming gRPC client requests and (if needed) replacing/overwriting outgoing
395
        // messages before they're sent to the client. When registering the middleware
396
        // must identify itself and indicate what custom macaroon caveats it wants to
397
        // be responsible for. Only requests that contain a macaroon with that specific
398
        // custom caveat are then sent to the middleware for inspection. The other
399
        // option is to register for the read-only mode in which all requests/responses
400
        // are forwarded for interception to the middleware but the middleware is not
401
        // allowed to modify any responses. As a security measure, _no_ middleware can
402
        // modify responses for requests made with _unencumbered_ macaroons!
403
        RegisterRPCMiddleware(ctx context.Context, opts ...grpc.CallOption) (Lightning_RegisterRPCMiddlewareClient, error)
404
        // lncli: `sendcustom`
405
        // SendCustomMessage sends a custom peer message.
406
        SendCustomMessage(ctx context.Context, in *SendCustomMessageRequest, opts ...grpc.CallOption) (*SendCustomMessageResponse, error)
407
        // lncli: `subscribecustom`
408
        // SubscribeCustomMessages subscribes to a stream of incoming custom peer
409
        // messages.
410
        //
411
        // To include messages with type outside of the custom range (>= 32768) lnd
412
        // needs to be compiled with  the `dev` build tag, and the message type to
413
        // override should be specified in lnd's experimental protocol configuration.
414
        SubscribeCustomMessages(ctx context.Context, in *SubscribeCustomMessagesRequest, opts ...grpc.CallOption) (Lightning_SubscribeCustomMessagesClient, error)
415
        // lncli: `listaliases`
416
        // ListAliases returns the set of all aliases that have ever existed with
417
        // their confirmed SCID (if it exists) and/or the base SCID (in the case of
418
        // zero conf).
419
        ListAliases(ctx context.Context, in *ListAliasesRequest, opts ...grpc.CallOption) (*ListAliasesResponse, error)
420
        // LookupHtlcResolution retrieves a final htlc resolution from the database.
421
        // If the htlc has no final resolution yet, a NotFound grpc status code is
422
        // returned.
423
        LookupHtlcResolution(ctx context.Context, in *LookupHtlcResolutionRequest, opts ...grpc.CallOption) (*LookupHtlcResolutionResponse, error)
424
}
425

426
type lightningClient struct {
427
        cc grpc.ClientConnInterface
428
}
429

430
func NewLightningClient(cc grpc.ClientConnInterface) LightningClient {
3✔
431
        return &lightningClient{cc}
3✔
432
}
3✔
433

434
func (c *lightningClient) WalletBalance(ctx context.Context, in *WalletBalanceRequest, opts ...grpc.CallOption) (*WalletBalanceResponse, error) {
×
435
        out := new(WalletBalanceResponse)
×
436
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/WalletBalance", in, out, opts...)
×
437
        if err != nil {
×
438
                return nil, err
×
439
        }
×
440
        return out, nil
×
441
}
442

443
func (c *lightningClient) ChannelBalance(ctx context.Context, in *ChannelBalanceRequest, opts ...grpc.CallOption) (*ChannelBalanceResponse, error) {
×
444
        out := new(ChannelBalanceResponse)
×
445
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ChannelBalance", in, out, opts...)
×
446
        if err != nil {
×
447
                return nil, err
×
448
        }
×
449
        return out, nil
×
450
}
451

452
func (c *lightningClient) GetTransactions(ctx context.Context, in *GetTransactionsRequest, opts ...grpc.CallOption) (*TransactionDetails, error) {
×
453
        out := new(TransactionDetails)
×
454
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetTransactions", in, out, opts...)
×
455
        if err != nil {
×
456
                return nil, err
×
457
        }
×
458
        return out, nil
×
459
}
460

461
func (c *lightningClient) EstimateFee(ctx context.Context, in *EstimateFeeRequest, opts ...grpc.CallOption) (*EstimateFeeResponse, error) {
3✔
462
        out := new(EstimateFeeResponse)
3✔
463
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/EstimateFee", in, out, opts...)
3✔
464
        if err != nil {
3✔
465
                return nil, err
×
466
        }
×
467
        return out, nil
3✔
468
}
469

470
func (c *lightningClient) SendCoins(ctx context.Context, in *SendCoinsRequest, opts ...grpc.CallOption) (*SendCoinsResponse, error) {
×
471
        out := new(SendCoinsResponse)
×
472
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SendCoins", in, out, opts...)
×
473
        if err != nil {
×
474
                return nil, err
×
475
        }
×
476
        return out, nil
×
477
}
478

479
func (c *lightningClient) ListUnspent(ctx context.Context, in *ListUnspentRequest, opts ...grpc.CallOption) (*ListUnspentResponse, error) {
×
480
        out := new(ListUnspentResponse)
×
481
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListUnspent", in, out, opts...)
×
482
        if err != nil {
×
483
                return nil, err
×
484
        }
×
485
        return out, nil
×
486
}
487

488
func (c *lightningClient) SubscribeTransactions(ctx context.Context, in *GetTransactionsRequest, opts ...grpc.CallOption) (Lightning_SubscribeTransactionsClient, error) {
×
489
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[0], "/lnrpc.Lightning/SubscribeTransactions", opts...)
×
490
        if err != nil {
×
491
                return nil, err
×
492
        }
×
493
        x := &lightningSubscribeTransactionsClient{stream}
×
494
        if err := x.ClientStream.SendMsg(in); err != nil {
×
495
                return nil, err
×
496
        }
×
497
        if err := x.ClientStream.CloseSend(); err != nil {
×
498
                return nil, err
×
499
        }
×
500
        return x, nil
×
501
}
502

503
type Lightning_SubscribeTransactionsClient interface {
504
        Recv() (*Transaction, error)
505
        grpc.ClientStream
506
}
507

508
type lightningSubscribeTransactionsClient struct {
509
        grpc.ClientStream
510
}
511

512
func (x *lightningSubscribeTransactionsClient) Recv() (*Transaction, error) {
×
513
        m := new(Transaction)
×
514
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
515
                return nil, err
×
516
        }
×
517
        return m, nil
×
518
}
519

520
func (c *lightningClient) SendMany(ctx context.Context, in *SendManyRequest, opts ...grpc.CallOption) (*SendManyResponse, error) {
×
521
        out := new(SendManyResponse)
×
522
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SendMany", in, out, opts...)
×
523
        if err != nil {
×
524
                return nil, err
×
525
        }
×
526
        return out, nil
×
527
}
528

529
func (c *lightningClient) NewAddress(ctx context.Context, in *NewAddressRequest, opts ...grpc.CallOption) (*NewAddressResponse, error) {
×
530
        out := new(NewAddressResponse)
×
531
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/NewAddress", in, out, opts...)
×
532
        if err != nil {
×
533
                return nil, err
×
534
        }
×
535
        return out, nil
×
536
}
537

538
func (c *lightningClient) SignMessage(ctx context.Context, in *SignMessageRequest, opts ...grpc.CallOption) (*SignMessageResponse, error) {
×
539
        out := new(SignMessageResponse)
×
540
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SignMessage", in, out, opts...)
×
541
        if err != nil {
×
542
                return nil, err
×
543
        }
×
544
        return out, nil
×
545
}
546

547
func (c *lightningClient) VerifyMessage(ctx context.Context, in *VerifyMessageRequest, opts ...grpc.CallOption) (*VerifyMessageResponse, error) {
×
548
        out := new(VerifyMessageResponse)
×
549
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/VerifyMessage", in, out, opts...)
×
550
        if err != nil {
×
551
                return nil, err
×
552
        }
×
553
        return out, nil
×
554
}
555

556
func (c *lightningClient) ConnectPeer(ctx context.Context, in *ConnectPeerRequest, opts ...grpc.CallOption) (*ConnectPeerResponse, error) {
×
557
        out := new(ConnectPeerResponse)
×
558
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ConnectPeer", in, out, opts...)
×
559
        if err != nil {
×
560
                return nil, err
×
561
        }
×
562
        return out, nil
×
563
}
564

565
func (c *lightningClient) DisconnectPeer(ctx context.Context, in *DisconnectPeerRequest, opts ...grpc.CallOption) (*DisconnectPeerResponse, error) {
×
566
        out := new(DisconnectPeerResponse)
×
567
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DisconnectPeer", in, out, opts...)
×
568
        if err != nil {
×
569
                return nil, err
×
570
        }
×
571
        return out, nil
×
572
}
573

574
func (c *lightningClient) ListPeers(ctx context.Context, in *ListPeersRequest, opts ...grpc.CallOption) (*ListPeersResponse, error) {
×
575
        out := new(ListPeersResponse)
×
576
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListPeers", in, out, opts...)
×
577
        if err != nil {
×
578
                return nil, err
×
579
        }
×
580
        return out, nil
×
581
}
582

583
func (c *lightningClient) SubscribePeerEvents(ctx context.Context, in *PeerEventSubscription, opts ...grpc.CallOption) (Lightning_SubscribePeerEventsClient, error) {
×
584
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[1], "/lnrpc.Lightning/SubscribePeerEvents", opts...)
×
585
        if err != nil {
×
586
                return nil, err
×
587
        }
×
588
        x := &lightningSubscribePeerEventsClient{stream}
×
589
        if err := x.ClientStream.SendMsg(in); err != nil {
×
590
                return nil, err
×
591
        }
×
592
        if err := x.ClientStream.CloseSend(); err != nil {
×
593
                return nil, err
×
594
        }
×
595
        return x, nil
×
596
}
597

598
type Lightning_SubscribePeerEventsClient interface {
599
        Recv() (*PeerEvent, error)
600
        grpc.ClientStream
601
}
602

603
type lightningSubscribePeerEventsClient struct {
604
        grpc.ClientStream
605
}
606

607
func (x *lightningSubscribePeerEventsClient) Recv() (*PeerEvent, error) {
×
608
        m := new(PeerEvent)
×
609
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
610
                return nil, err
×
611
        }
×
612
        return m, nil
×
613
}
614

615
func (c *lightningClient) GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error) {
3✔
616
        out := new(GetInfoResponse)
3✔
617
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetInfo", in, out, opts...)
3✔
618
        if err != nil {
3✔
619
                return nil, err
×
620
        }
×
621
        return out, nil
3✔
622
}
623

624
func (c *lightningClient) GetDebugInfo(ctx context.Context, in *GetDebugInfoRequest, opts ...grpc.CallOption) (*GetDebugInfoResponse, error) {
×
625
        out := new(GetDebugInfoResponse)
×
626
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetDebugInfo", in, out, opts...)
×
627
        if err != nil {
×
628
                return nil, err
×
629
        }
×
630
        return out, nil
×
631
}
632

633
func (c *lightningClient) GetRecoveryInfo(ctx context.Context, in *GetRecoveryInfoRequest, opts ...grpc.CallOption) (*GetRecoveryInfoResponse, error) {
×
634
        out := new(GetRecoveryInfoResponse)
×
635
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetRecoveryInfo", in, out, opts...)
×
636
        if err != nil {
×
637
                return nil, err
×
638
        }
×
639
        return out, nil
×
640
}
641

642
func (c *lightningClient) PendingChannels(ctx context.Context, in *PendingChannelsRequest, opts ...grpc.CallOption) (*PendingChannelsResponse, error) {
×
643
        out := new(PendingChannelsResponse)
×
644
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/PendingChannels", in, out, opts...)
×
645
        if err != nil {
×
646
                return nil, err
×
647
        }
×
648
        return out, nil
×
649
}
650

651
func (c *lightningClient) ListChannels(ctx context.Context, in *ListChannelsRequest, opts ...grpc.CallOption) (*ListChannelsResponse, error) {
×
652
        out := new(ListChannelsResponse)
×
653
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListChannels", in, out, opts...)
×
654
        if err != nil {
×
655
                return nil, err
×
656
        }
×
657
        return out, nil
×
658
}
659

660
func (c *lightningClient) SubscribeChannelEvents(ctx context.Context, in *ChannelEventSubscription, opts ...grpc.CallOption) (Lightning_SubscribeChannelEventsClient, error) {
×
661
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[2], "/lnrpc.Lightning/SubscribeChannelEvents", opts...)
×
662
        if err != nil {
×
663
                return nil, err
×
664
        }
×
665
        x := &lightningSubscribeChannelEventsClient{stream}
×
666
        if err := x.ClientStream.SendMsg(in); err != nil {
×
667
                return nil, err
×
668
        }
×
669
        if err := x.ClientStream.CloseSend(); err != nil {
×
670
                return nil, err
×
671
        }
×
672
        return x, nil
×
673
}
674

675
type Lightning_SubscribeChannelEventsClient interface {
676
        Recv() (*ChannelEventUpdate, error)
677
        grpc.ClientStream
678
}
679

680
type lightningSubscribeChannelEventsClient struct {
681
        grpc.ClientStream
682
}
683

684
func (x *lightningSubscribeChannelEventsClient) Recv() (*ChannelEventUpdate, error) {
×
685
        m := new(ChannelEventUpdate)
×
686
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
687
                return nil, err
×
688
        }
×
689
        return m, nil
×
690
}
691

692
func (c *lightningClient) ClosedChannels(ctx context.Context, in *ClosedChannelsRequest, opts ...grpc.CallOption) (*ClosedChannelsResponse, error) {
×
693
        out := new(ClosedChannelsResponse)
×
694
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ClosedChannels", in, out, opts...)
×
695
        if err != nil {
×
696
                return nil, err
×
697
        }
×
698
        return out, nil
×
699
}
700

701
func (c *lightningClient) OpenChannelSync(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*ChannelPoint, error) {
×
702
        out := new(ChannelPoint)
×
703
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/OpenChannelSync", in, out, opts...)
×
704
        if err != nil {
×
705
                return nil, err
×
706
        }
×
707
        return out, nil
×
708
}
709

710
func (c *lightningClient) OpenChannel(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (Lightning_OpenChannelClient, error) {
×
711
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[3], "/lnrpc.Lightning/OpenChannel", opts...)
×
712
        if err != nil {
×
713
                return nil, err
×
714
        }
×
715
        x := &lightningOpenChannelClient{stream}
×
716
        if err := x.ClientStream.SendMsg(in); err != nil {
×
717
                return nil, err
×
718
        }
×
719
        if err := x.ClientStream.CloseSend(); err != nil {
×
720
                return nil, err
×
721
        }
×
722
        return x, nil
×
723
}
724

725
type Lightning_OpenChannelClient interface {
726
        Recv() (*OpenStatusUpdate, error)
727
        grpc.ClientStream
728
}
729

730
type lightningOpenChannelClient struct {
731
        grpc.ClientStream
732
}
733

734
func (x *lightningOpenChannelClient) Recv() (*OpenStatusUpdate, error) {
×
735
        m := new(OpenStatusUpdate)
×
736
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
737
                return nil, err
×
738
        }
×
739
        return m, nil
×
740
}
741

742
func (c *lightningClient) BatchOpenChannel(ctx context.Context, in *BatchOpenChannelRequest, opts ...grpc.CallOption) (*BatchOpenChannelResponse, error) {
×
743
        out := new(BatchOpenChannelResponse)
×
744
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/BatchOpenChannel", in, out, opts...)
×
745
        if err != nil {
×
746
                return nil, err
×
747
        }
×
748
        return out, nil
×
749
}
750

751
func (c *lightningClient) FundingStateStep(ctx context.Context, in *FundingTransitionMsg, opts ...grpc.CallOption) (*FundingStateStepResp, error) {
×
752
        out := new(FundingStateStepResp)
×
753
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/FundingStateStep", in, out, opts...)
×
754
        if err != nil {
×
755
                return nil, err
×
756
        }
×
757
        return out, nil
×
758
}
759

760
func (c *lightningClient) ChannelAcceptor(ctx context.Context, opts ...grpc.CallOption) (Lightning_ChannelAcceptorClient, error) {
3✔
761
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[4], "/lnrpc.Lightning/ChannelAcceptor", opts...)
3✔
762
        if err != nil {
3✔
763
                return nil, err
×
764
        }
×
765
        x := &lightningChannelAcceptorClient{stream}
3✔
766
        return x, nil
3✔
767
}
768

769
type Lightning_ChannelAcceptorClient interface {
770
        Send(*ChannelAcceptResponse) error
771
        Recv() (*ChannelAcceptRequest, error)
772
        grpc.ClientStream
773
}
774

775
type lightningChannelAcceptorClient struct {
776
        grpc.ClientStream
777
}
778

779
func (x *lightningChannelAcceptorClient) Send(m *ChannelAcceptResponse) error {
3✔
780
        return x.ClientStream.SendMsg(m)
3✔
781
}
3✔
782

783
func (x *lightningChannelAcceptorClient) Recv() (*ChannelAcceptRequest, error) {
3✔
784
        m := new(ChannelAcceptRequest)
3✔
785
        if err := x.ClientStream.RecvMsg(m); err != nil {
6✔
786
                return nil, err
3✔
787
        }
3✔
788
        return m, nil
3✔
789
}
790

791
func (c *lightningClient) CloseChannel(ctx context.Context, in *CloseChannelRequest, opts ...grpc.CallOption) (Lightning_CloseChannelClient, error) {
×
792
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[5], "/lnrpc.Lightning/CloseChannel", opts...)
×
793
        if err != nil {
×
794
                return nil, err
×
795
        }
×
796
        x := &lightningCloseChannelClient{stream}
×
797
        if err := x.ClientStream.SendMsg(in); err != nil {
×
798
                return nil, err
×
799
        }
×
800
        if err := x.ClientStream.CloseSend(); err != nil {
×
801
                return nil, err
×
802
        }
×
803
        return x, nil
×
804
}
805

806
type Lightning_CloseChannelClient interface {
807
        Recv() (*CloseStatusUpdate, error)
808
        grpc.ClientStream
809
}
810

811
type lightningCloseChannelClient struct {
812
        grpc.ClientStream
813
}
814

815
func (x *lightningCloseChannelClient) Recv() (*CloseStatusUpdate, error) {
×
816
        m := new(CloseStatusUpdate)
×
817
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
818
                return nil, err
×
819
        }
×
820
        return m, nil
×
821
}
822

823
func (c *lightningClient) AbandonChannel(ctx context.Context, in *AbandonChannelRequest, opts ...grpc.CallOption) (*AbandonChannelResponse, error) {
×
824
        out := new(AbandonChannelResponse)
×
825
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/AbandonChannel", in, out, opts...)
×
826
        if err != nil {
×
827
                return nil, err
×
828
        }
×
829
        return out, nil
×
830
}
831

832
// Deprecated: Do not use.
833
func (c *lightningClient) SendPayment(ctx context.Context, opts ...grpc.CallOption) (Lightning_SendPaymentClient, error) {
×
834
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[6], "/lnrpc.Lightning/SendPayment", opts...)
×
835
        if err != nil {
×
836
                return nil, err
×
837
        }
×
838
        x := &lightningSendPaymentClient{stream}
×
839
        return x, nil
×
840
}
841

842
type Lightning_SendPaymentClient interface {
843
        Send(*SendRequest) error
844
        Recv() (*SendResponse, error)
845
        grpc.ClientStream
846
}
847

848
type lightningSendPaymentClient struct {
849
        grpc.ClientStream
850
}
851

852
func (x *lightningSendPaymentClient) Send(m *SendRequest) error {
×
853
        return x.ClientStream.SendMsg(m)
×
854
}
×
855

856
func (x *lightningSendPaymentClient) Recv() (*SendResponse, error) {
×
857
        m := new(SendResponse)
×
858
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
859
                return nil, err
×
860
        }
×
861
        return m, nil
×
862
}
863

864
// Deprecated: Do not use.
865
func (c *lightningClient) SendPaymentSync(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error) {
×
866
        out := new(SendResponse)
×
867
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SendPaymentSync", in, out, opts...)
×
868
        if err != nil {
×
869
                return nil, err
×
870
        }
×
871
        return out, nil
×
872
}
873

874
// Deprecated: Do not use.
875
func (c *lightningClient) SendToRoute(ctx context.Context, opts ...grpc.CallOption) (Lightning_SendToRouteClient, error) {
×
876
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[7], "/lnrpc.Lightning/SendToRoute", opts...)
×
877
        if err != nil {
×
878
                return nil, err
×
879
        }
×
880
        x := &lightningSendToRouteClient{stream}
×
881
        return x, nil
×
882
}
883

884
type Lightning_SendToRouteClient interface {
885
        Send(*SendToRouteRequest) error
886
        Recv() (*SendResponse, error)
887
        grpc.ClientStream
888
}
889

890
type lightningSendToRouteClient struct {
891
        grpc.ClientStream
892
}
893

894
func (x *lightningSendToRouteClient) Send(m *SendToRouteRequest) error {
×
895
        return x.ClientStream.SendMsg(m)
×
896
}
×
897

898
func (x *lightningSendToRouteClient) Recv() (*SendResponse, error) {
×
899
        m := new(SendResponse)
×
900
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
901
                return nil, err
×
902
        }
×
903
        return m, nil
×
904
}
905

906
// Deprecated: Do not use.
907
func (c *lightningClient) SendToRouteSync(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*SendResponse, error) {
×
908
        out := new(SendResponse)
×
909
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SendToRouteSync", in, out, opts...)
×
910
        if err != nil {
×
911
                return nil, err
×
912
        }
×
913
        return out, nil
×
914
}
915

916
func (c *lightningClient) AddInvoice(ctx context.Context, in *Invoice, opts ...grpc.CallOption) (*AddInvoiceResponse, error) {
3✔
917
        out := new(AddInvoiceResponse)
3✔
918
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/AddInvoice", in, out, opts...)
3✔
919
        if err != nil {
3✔
920
                return nil, err
×
921
        }
×
922
        return out, nil
3✔
923
}
924

925
func (c *lightningClient) ListInvoices(ctx context.Context, in *ListInvoiceRequest, opts ...grpc.CallOption) (*ListInvoiceResponse, error) {
×
926
        out := new(ListInvoiceResponse)
×
927
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListInvoices", in, out, opts...)
×
928
        if err != nil {
×
929
                return nil, err
×
930
        }
×
931
        return out, nil
×
932
}
933

934
func (c *lightningClient) LookupInvoice(ctx context.Context, in *PaymentHash, opts ...grpc.CallOption) (*Invoice, error) {
3✔
935
        out := new(Invoice)
3✔
936
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/LookupInvoice", in, out, opts...)
3✔
937
        if err != nil {
3✔
938
                return nil, err
×
939
        }
×
940
        return out, nil
3✔
941
}
942

943
func (c *lightningClient) SubscribeInvoices(ctx context.Context, in *InvoiceSubscription, opts ...grpc.CallOption) (Lightning_SubscribeInvoicesClient, error) {
3✔
944
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[8], "/lnrpc.Lightning/SubscribeInvoices", opts...)
3✔
945
        if err != nil {
3✔
946
                return nil, err
×
947
        }
×
948
        x := &lightningSubscribeInvoicesClient{stream}
3✔
949
        if err := x.ClientStream.SendMsg(in); err != nil {
3✔
950
                return nil, err
×
951
        }
×
952
        if err := x.ClientStream.CloseSend(); err != nil {
3✔
953
                return nil, err
×
954
        }
×
955
        return x, nil
3✔
956
}
957

958
type Lightning_SubscribeInvoicesClient interface {
959
        Recv() (*Invoice, error)
960
        grpc.ClientStream
961
}
962

963
type lightningSubscribeInvoicesClient struct {
964
        grpc.ClientStream
965
}
966

967
func (x *lightningSubscribeInvoicesClient) Recv() (*Invoice, error) {
3✔
968
        m := new(Invoice)
3✔
969
        if err := x.ClientStream.RecvMsg(m); err != nil {
6✔
970
                return nil, err
3✔
971
        }
3✔
972
        return m, nil
3✔
973
}
974

975
func (c *lightningClient) DecodePayReq(ctx context.Context, in *PayReqString, opts ...grpc.CallOption) (*PayReq, error) {
×
976
        out := new(PayReq)
×
977
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DecodePayReq", in, out, opts...)
×
978
        if err != nil {
×
979
                return nil, err
×
980
        }
×
981
        return out, nil
×
982
}
983

984
func (c *lightningClient) ListPayments(ctx context.Context, in *ListPaymentsRequest, opts ...grpc.CallOption) (*ListPaymentsResponse, error) {
×
985
        out := new(ListPaymentsResponse)
×
986
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListPayments", in, out, opts...)
×
987
        if err != nil {
×
988
                return nil, err
×
989
        }
×
990
        return out, nil
×
991
}
992

993
func (c *lightningClient) DeletePayment(ctx context.Context, in *DeletePaymentRequest, opts ...grpc.CallOption) (*DeletePaymentResponse, error) {
×
994
        out := new(DeletePaymentResponse)
×
995
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DeletePayment", in, out, opts...)
×
996
        if err != nil {
×
997
                return nil, err
×
998
        }
×
999
        return out, nil
×
1000
}
1001

1002
func (c *lightningClient) DeleteAllPayments(ctx context.Context, in *DeleteAllPaymentsRequest, opts ...grpc.CallOption) (*DeleteAllPaymentsResponse, error) {
×
1003
        out := new(DeleteAllPaymentsResponse)
×
1004
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DeleteAllPayments", in, out, opts...)
×
1005
        if err != nil {
×
1006
                return nil, err
×
1007
        }
×
1008
        return out, nil
×
1009
}
1010

1011
func (c *lightningClient) DescribeGraph(ctx context.Context, in *ChannelGraphRequest, opts ...grpc.CallOption) (*ChannelGraph, error) {
×
1012
        out := new(ChannelGraph)
×
1013
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DescribeGraph", in, out, opts...)
×
1014
        if err != nil {
×
1015
                return nil, err
×
1016
        }
×
1017
        return out, nil
×
1018
}
1019

1020
func (c *lightningClient) GetNodeMetrics(ctx context.Context, in *NodeMetricsRequest, opts ...grpc.CallOption) (*NodeMetricsResponse, error) {
×
1021
        out := new(NodeMetricsResponse)
×
1022
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetNodeMetrics", in, out, opts...)
×
1023
        if err != nil {
×
1024
                return nil, err
×
1025
        }
×
1026
        return out, nil
×
1027
}
1028

1029
func (c *lightningClient) GetChanInfo(ctx context.Context, in *ChanInfoRequest, opts ...grpc.CallOption) (*ChannelEdge, error) {
×
1030
        out := new(ChannelEdge)
×
1031
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetChanInfo", in, out, opts...)
×
1032
        if err != nil {
×
1033
                return nil, err
×
1034
        }
×
1035
        return out, nil
×
1036
}
1037

1038
func (c *lightningClient) GetNodeInfo(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfo, error) {
×
1039
        out := new(NodeInfo)
×
1040
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetNodeInfo", in, out, opts...)
×
1041
        if err != nil {
×
1042
                return nil, err
×
1043
        }
×
1044
        return out, nil
×
1045
}
1046

1047
func (c *lightningClient) QueryRoutes(ctx context.Context, in *QueryRoutesRequest, opts ...grpc.CallOption) (*QueryRoutesResponse, error) {
×
1048
        out := new(QueryRoutesResponse)
×
1049
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/QueryRoutes", in, out, opts...)
×
1050
        if err != nil {
×
1051
                return nil, err
×
1052
        }
×
1053
        return out, nil
×
1054
}
1055

1056
func (c *lightningClient) GetNetworkInfo(ctx context.Context, in *NetworkInfoRequest, opts ...grpc.CallOption) (*NetworkInfo, error) {
×
1057
        out := new(NetworkInfo)
×
1058
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetNetworkInfo", in, out, opts...)
×
1059
        if err != nil {
×
1060
                return nil, err
×
1061
        }
×
1062
        return out, nil
×
1063
}
1064

1065
func (c *lightningClient) StopDaemon(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) {
×
1066
        out := new(StopResponse)
×
1067
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/StopDaemon", in, out, opts...)
×
1068
        if err != nil {
×
1069
                return nil, err
×
1070
        }
×
1071
        return out, nil
×
1072
}
1073

1074
func (c *lightningClient) SubscribeChannelGraph(ctx context.Context, in *GraphTopologySubscription, opts ...grpc.CallOption) (Lightning_SubscribeChannelGraphClient, error) {
×
1075
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[9], "/lnrpc.Lightning/SubscribeChannelGraph", opts...)
×
1076
        if err != nil {
×
1077
                return nil, err
×
1078
        }
×
1079
        x := &lightningSubscribeChannelGraphClient{stream}
×
1080
        if err := x.ClientStream.SendMsg(in); err != nil {
×
1081
                return nil, err
×
1082
        }
×
1083
        if err := x.ClientStream.CloseSend(); err != nil {
×
1084
                return nil, err
×
1085
        }
×
1086
        return x, nil
×
1087
}
1088

1089
type Lightning_SubscribeChannelGraphClient interface {
1090
        Recv() (*GraphTopologyUpdate, error)
1091
        grpc.ClientStream
1092
}
1093

1094
type lightningSubscribeChannelGraphClient struct {
1095
        grpc.ClientStream
1096
}
1097

1098
func (x *lightningSubscribeChannelGraphClient) Recv() (*GraphTopologyUpdate, error) {
×
1099
        m := new(GraphTopologyUpdate)
×
1100
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
1101
                return nil, err
×
1102
        }
×
1103
        return m, nil
×
1104
}
1105

1106
func (c *lightningClient) DebugLevel(ctx context.Context, in *DebugLevelRequest, opts ...grpc.CallOption) (*DebugLevelResponse, error) {
×
1107
        out := new(DebugLevelResponse)
×
1108
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DebugLevel", in, out, opts...)
×
1109
        if err != nil {
×
1110
                return nil, err
×
1111
        }
×
1112
        return out, nil
×
1113
}
1114

1115
func (c *lightningClient) FeeReport(ctx context.Context, in *FeeReportRequest, opts ...grpc.CallOption) (*FeeReportResponse, error) {
×
1116
        out := new(FeeReportResponse)
×
1117
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/FeeReport", in, out, opts...)
×
1118
        if err != nil {
×
1119
                return nil, err
×
1120
        }
×
1121
        return out, nil
×
1122
}
1123

1124
func (c *lightningClient) UpdateChannelPolicy(ctx context.Context, in *PolicyUpdateRequest, opts ...grpc.CallOption) (*PolicyUpdateResponse, error) {
×
1125
        out := new(PolicyUpdateResponse)
×
1126
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/UpdateChannelPolicy", in, out, opts...)
×
1127
        if err != nil {
×
1128
                return nil, err
×
1129
        }
×
1130
        return out, nil
×
1131
}
1132

1133
func (c *lightningClient) ForwardingHistory(ctx context.Context, in *ForwardingHistoryRequest, opts ...grpc.CallOption) (*ForwardingHistoryResponse, error) {
×
1134
        out := new(ForwardingHistoryResponse)
×
1135
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ForwardingHistory", in, out, opts...)
×
1136
        if err != nil {
×
1137
                return nil, err
×
1138
        }
×
1139
        return out, nil
×
1140
}
1141

1142
func (c *lightningClient) ExportChannelBackup(ctx context.Context, in *ExportChannelBackupRequest, opts ...grpc.CallOption) (*ChannelBackup, error) {
×
1143
        out := new(ChannelBackup)
×
1144
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ExportChannelBackup", in, out, opts...)
×
1145
        if err != nil {
×
1146
                return nil, err
×
1147
        }
×
1148
        return out, nil
×
1149
}
1150

1151
func (c *lightningClient) ExportAllChannelBackups(ctx context.Context, in *ChanBackupExportRequest, opts ...grpc.CallOption) (*ChanBackupSnapshot, error) {
×
1152
        out := new(ChanBackupSnapshot)
×
1153
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ExportAllChannelBackups", in, out, opts...)
×
1154
        if err != nil {
×
1155
                return nil, err
×
1156
        }
×
1157
        return out, nil
×
1158
}
1159

1160
func (c *lightningClient) VerifyChanBackup(ctx context.Context, in *ChanBackupSnapshot, opts ...grpc.CallOption) (*VerifyChanBackupResponse, error) {
×
1161
        out := new(VerifyChanBackupResponse)
×
1162
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/VerifyChanBackup", in, out, opts...)
×
1163
        if err != nil {
×
1164
                return nil, err
×
1165
        }
×
1166
        return out, nil
×
1167
}
1168

1169
func (c *lightningClient) RestoreChannelBackups(ctx context.Context, in *RestoreChanBackupRequest, opts ...grpc.CallOption) (*RestoreBackupResponse, error) {
×
1170
        out := new(RestoreBackupResponse)
×
1171
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/RestoreChannelBackups", in, out, opts...)
×
1172
        if err != nil {
×
1173
                return nil, err
×
1174
        }
×
1175
        return out, nil
×
1176
}
1177

1178
func (c *lightningClient) SubscribeChannelBackups(ctx context.Context, in *ChannelBackupSubscription, opts ...grpc.CallOption) (Lightning_SubscribeChannelBackupsClient, error) {
×
1179
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[10], "/lnrpc.Lightning/SubscribeChannelBackups", opts...)
×
1180
        if err != nil {
×
1181
                return nil, err
×
1182
        }
×
1183
        x := &lightningSubscribeChannelBackupsClient{stream}
×
1184
        if err := x.ClientStream.SendMsg(in); err != nil {
×
1185
                return nil, err
×
1186
        }
×
1187
        if err := x.ClientStream.CloseSend(); err != nil {
×
1188
                return nil, err
×
1189
        }
×
1190
        return x, nil
×
1191
}
1192

1193
type Lightning_SubscribeChannelBackupsClient interface {
1194
        Recv() (*ChanBackupSnapshot, error)
1195
        grpc.ClientStream
1196
}
1197

1198
type lightningSubscribeChannelBackupsClient struct {
1199
        grpc.ClientStream
1200
}
1201

1202
func (x *lightningSubscribeChannelBackupsClient) Recv() (*ChanBackupSnapshot, error) {
×
1203
        m := new(ChanBackupSnapshot)
×
1204
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
1205
                return nil, err
×
1206
        }
×
1207
        return m, nil
×
1208
}
1209

1210
func (c *lightningClient) BakeMacaroon(ctx context.Context, in *BakeMacaroonRequest, opts ...grpc.CallOption) (*BakeMacaroonResponse, error) {
×
1211
        out := new(BakeMacaroonResponse)
×
1212
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/BakeMacaroon", in, out, opts...)
×
1213
        if err != nil {
×
1214
                return nil, err
×
1215
        }
×
1216
        return out, nil
×
1217
}
1218

1219
func (c *lightningClient) ListMacaroonIDs(ctx context.Context, in *ListMacaroonIDsRequest, opts ...grpc.CallOption) (*ListMacaroonIDsResponse, error) {
×
1220
        out := new(ListMacaroonIDsResponse)
×
1221
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListMacaroonIDs", in, out, opts...)
×
1222
        if err != nil {
×
1223
                return nil, err
×
1224
        }
×
1225
        return out, nil
×
1226
}
1227

1228
func (c *lightningClient) DeleteMacaroonID(ctx context.Context, in *DeleteMacaroonIDRequest, opts ...grpc.CallOption) (*DeleteMacaroonIDResponse, error) {
×
1229
        out := new(DeleteMacaroonIDResponse)
×
1230
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DeleteMacaroonID", in, out, opts...)
×
1231
        if err != nil {
×
1232
                return nil, err
×
1233
        }
×
1234
        return out, nil
×
1235
}
1236

1237
func (c *lightningClient) ListPermissions(ctx context.Context, in *ListPermissionsRequest, opts ...grpc.CallOption) (*ListPermissionsResponse, error) {
×
1238
        out := new(ListPermissionsResponse)
×
1239
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListPermissions", in, out, opts...)
×
1240
        if err != nil {
×
1241
                return nil, err
×
1242
        }
×
1243
        return out, nil
×
1244
}
1245

1246
func (c *lightningClient) CheckMacaroonPermissions(ctx context.Context, in *CheckMacPermRequest, opts ...grpc.CallOption) (*CheckMacPermResponse, error) {
×
1247
        out := new(CheckMacPermResponse)
×
1248
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/CheckMacaroonPermissions", in, out, opts...)
×
1249
        if err != nil {
×
1250
                return nil, err
×
1251
        }
×
1252
        return out, nil
×
1253
}
1254

1255
func (c *lightningClient) RegisterRPCMiddleware(ctx context.Context, opts ...grpc.CallOption) (Lightning_RegisterRPCMiddlewareClient, error) {
×
1256
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[11], "/lnrpc.Lightning/RegisterRPCMiddleware", opts...)
×
1257
        if err != nil {
×
1258
                return nil, err
×
1259
        }
×
1260
        x := &lightningRegisterRPCMiddlewareClient{stream}
×
1261
        return x, nil
×
1262
}
1263

1264
type Lightning_RegisterRPCMiddlewareClient interface {
1265
        Send(*RPCMiddlewareResponse) error
1266
        Recv() (*RPCMiddlewareRequest, error)
1267
        grpc.ClientStream
1268
}
1269

1270
type lightningRegisterRPCMiddlewareClient struct {
1271
        grpc.ClientStream
1272
}
1273

1274
func (x *lightningRegisterRPCMiddlewareClient) Send(m *RPCMiddlewareResponse) error {
×
1275
        return x.ClientStream.SendMsg(m)
×
1276
}
×
1277

1278
func (x *lightningRegisterRPCMiddlewareClient) Recv() (*RPCMiddlewareRequest, error) {
×
1279
        m := new(RPCMiddlewareRequest)
×
1280
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
1281
                return nil, err
×
1282
        }
×
1283
        return m, nil
×
1284
}
1285

1286
func (c *lightningClient) SendCustomMessage(ctx context.Context, in *SendCustomMessageRequest, opts ...grpc.CallOption) (*SendCustomMessageResponse, error) {
×
1287
        out := new(SendCustomMessageResponse)
×
1288
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SendCustomMessage", in, out, opts...)
×
1289
        if err != nil {
×
1290
                return nil, err
×
1291
        }
×
1292
        return out, nil
×
1293
}
1294

1295
func (c *lightningClient) SubscribeCustomMessages(ctx context.Context, in *SubscribeCustomMessagesRequest, opts ...grpc.CallOption) (Lightning_SubscribeCustomMessagesClient, error) {
×
1296
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[12], "/lnrpc.Lightning/SubscribeCustomMessages", opts...)
×
1297
        if err != nil {
×
1298
                return nil, err
×
1299
        }
×
1300
        x := &lightningSubscribeCustomMessagesClient{stream}
×
1301
        if err := x.ClientStream.SendMsg(in); err != nil {
×
1302
                return nil, err
×
1303
        }
×
1304
        if err := x.ClientStream.CloseSend(); err != nil {
×
1305
                return nil, err
×
1306
        }
×
1307
        return x, nil
×
1308
}
1309

1310
type Lightning_SubscribeCustomMessagesClient interface {
1311
        Recv() (*CustomMessage, error)
1312
        grpc.ClientStream
1313
}
1314

1315
type lightningSubscribeCustomMessagesClient struct {
1316
        grpc.ClientStream
1317
}
1318

1319
func (x *lightningSubscribeCustomMessagesClient) Recv() (*CustomMessage, error) {
×
1320
        m := new(CustomMessage)
×
1321
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
1322
                return nil, err
×
1323
        }
×
1324
        return m, nil
×
1325
}
1326

1327
func (c *lightningClient) ListAliases(ctx context.Context, in *ListAliasesRequest, opts ...grpc.CallOption) (*ListAliasesResponse, error) {
×
1328
        out := new(ListAliasesResponse)
×
1329
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListAliases", in, out, opts...)
×
1330
        if err != nil {
×
1331
                return nil, err
×
1332
        }
×
1333
        return out, nil
×
1334
}
1335

1336
func (c *lightningClient) LookupHtlcResolution(ctx context.Context, in *LookupHtlcResolutionRequest, opts ...grpc.CallOption) (*LookupHtlcResolutionResponse, error) {
×
1337
        out := new(LookupHtlcResolutionResponse)
×
1338
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/LookupHtlcResolution", in, out, opts...)
×
1339
        if err != nil {
×
1340
                return nil, err
×
1341
        }
×
1342
        return out, nil
×
1343
}
1344

1345
// LightningServer is the server API for Lightning service.
1346
// All implementations must embed UnimplementedLightningServer
1347
// for forward compatibility
1348
type LightningServer interface {
1349
        // lncli: `walletbalance`
1350
        // WalletBalance returns total unspent outputs(confirmed and unconfirmed), all
1351
        // confirmed unspent outputs and all unconfirmed unspent outputs under control
1352
        // of the wallet.
1353
        WalletBalance(context.Context, *WalletBalanceRequest) (*WalletBalanceResponse, error)
1354
        // lncli: `channelbalance`
1355
        // ChannelBalance returns a report on the total funds across all open channels,
1356
        // categorized in local/remote, pending local/remote and unsettled local/remote
1357
        // balances.
1358
        ChannelBalance(context.Context, *ChannelBalanceRequest) (*ChannelBalanceResponse, error)
1359
        // lncli: `listchaintxns`
1360
        // GetTransactions returns a list describing all the known transactions
1361
        // relevant to the wallet.
1362
        GetTransactions(context.Context, *GetTransactionsRequest) (*TransactionDetails, error)
1363
        // lncli: `estimatefee`
1364
        // EstimateFee asks the chain backend to estimate the fee rate and total fees
1365
        // for a transaction that pays to multiple specified outputs.
1366
        //
1367
        // When using REST, the `AddrToAmount` map type can be set by appending
1368
        // `&AddrToAmount[<address>]=<amount_to_send>` to the URL. Unfortunately this
1369
        // map type doesn't appear in the REST API documentation because of a bug in
1370
        // the grpc-gateway library.
1371
        EstimateFee(context.Context, *EstimateFeeRequest) (*EstimateFeeResponse, error)
1372
        // lncli: `sendcoins`
1373
        // SendCoins executes a request to send coins to a particular address. Unlike
1374
        // SendMany, this RPC call only allows creating a single output at a time. If
1375
        // neither target_conf, or sat_per_vbyte are set, then the internal wallet will
1376
        // consult its fee model to determine a fee for the default confirmation
1377
        // target.
1378
        SendCoins(context.Context, *SendCoinsRequest) (*SendCoinsResponse, error)
1379
        // lncli: `listunspent`
1380
        // Deprecated, use walletrpc.ListUnspent instead.
1381
        //
1382
        // ListUnspent returns a list of all utxos spendable by the wallet with a
1383
        // number of confirmations between the specified minimum and maximum.
1384
        ListUnspent(context.Context, *ListUnspentRequest) (*ListUnspentResponse, error)
1385
        // SubscribeTransactions creates a uni-directional stream from the server to
1386
        // the client in which any newly discovered transactions relevant to the
1387
        // wallet are sent over.
1388
        SubscribeTransactions(*GetTransactionsRequest, Lightning_SubscribeTransactionsServer) error
1389
        // lncli: `sendmany`
1390
        // SendMany handles a request for a transaction that creates multiple specified
1391
        // outputs in parallel. If neither target_conf, or sat_per_vbyte are set, then
1392
        // the internal wallet will consult its fee model to determine a fee for the
1393
        // default confirmation target.
1394
        SendMany(context.Context, *SendManyRequest) (*SendManyResponse, error)
1395
        // lncli: `newaddress`
1396
        // NewAddress creates a new address under control of the local wallet.
1397
        NewAddress(context.Context, *NewAddressRequest) (*NewAddressResponse, error)
1398
        // lncli: `signmessage`
1399
        // SignMessage signs a message with this node's private key. The returned
1400
        // signature string is `zbase32` encoded and pubkey recoverable, meaning that
1401
        // only the message digest and signature are needed for verification.
1402
        SignMessage(context.Context, *SignMessageRequest) (*SignMessageResponse, error)
1403
        // lncli: `verifymessage`
1404
        // VerifyMessage verifies a signature over a message and recovers the signer's
1405
        // public key. The signature is only deemed valid if the recovered public key
1406
        // corresponds to a node key in the public Lightning network. The signature
1407
        // must be zbase32 encoded and signed by an active node in the resident node's
1408
        // channel database. In addition to returning the validity of the signature,
1409
        // VerifyMessage also returns the recovered pubkey from the signature.
1410
        VerifyMessage(context.Context, *VerifyMessageRequest) (*VerifyMessageResponse, error)
1411
        // lncli: `connect`
1412
        // ConnectPeer attempts to establish a connection to a remote peer. This is at
1413
        // the networking level, and is used for communication between nodes. This is
1414
        // distinct from establishing a channel with a peer.
1415
        ConnectPeer(context.Context, *ConnectPeerRequest) (*ConnectPeerResponse, error)
1416
        // lncli: `disconnect`
1417
        // DisconnectPeer attempts to disconnect one peer from another identified by a
1418
        // given pubKey. In the case that we currently have a pending or active channel
1419
        // with the target peer, then this action will be not be allowed.
1420
        DisconnectPeer(context.Context, *DisconnectPeerRequest) (*DisconnectPeerResponse, error)
1421
        // lncli: `listpeers`
1422
        // ListPeers returns a verbose listing of all currently active peers.
1423
        ListPeers(context.Context, *ListPeersRequest) (*ListPeersResponse, error)
1424
        // SubscribePeerEvents creates a uni-directional stream from the server to
1425
        // the client in which any events relevant to the state of peers are sent
1426
        // over. Events include peers going online and offline.
1427
        SubscribePeerEvents(*PeerEventSubscription, Lightning_SubscribePeerEventsServer) error
1428
        // lncli: `getinfo`
1429
        // GetInfo returns general information concerning the lightning node including
1430
        // it's identity pubkey, alias, the chains it is connected to, and information
1431
        // concerning the number of open+pending channels.
1432
        GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error)
1433
        // lncli: 'getdebuginfo'
1434
        // GetDebugInfo returns debug information concerning the state of the daemon
1435
        // and its subsystems. This includes the full configuration and the latest log
1436
        // entries from the log file.
1437
        GetDebugInfo(context.Context, *GetDebugInfoRequest) (*GetDebugInfoResponse, error)
1438
        // * lncli: `getrecoveryinfo`
1439
        // GetRecoveryInfo returns information concerning the recovery mode including
1440
        // whether it's in a recovery mode, whether the recovery is finished, and the
1441
        // progress made so far.
1442
        GetRecoveryInfo(context.Context, *GetRecoveryInfoRequest) (*GetRecoveryInfoResponse, error)
1443
        // lncli: `pendingchannels`
1444
        // PendingChannels returns a list of all the channels that are currently
1445
        // considered "pending". A channel is pending if it has finished the funding
1446
        // workflow and is waiting for confirmations for the funding txn, or is in the
1447
        // process of closure, either initiated cooperatively or non-cooperatively.
1448
        PendingChannels(context.Context, *PendingChannelsRequest) (*PendingChannelsResponse, error)
1449
        // lncli: `listchannels`
1450
        // ListChannels returns a description of all the open channels that this node
1451
        // is a participant in.
1452
        ListChannels(context.Context, *ListChannelsRequest) (*ListChannelsResponse, error)
1453
        // SubscribeChannelEvents creates a uni-directional stream from the server to
1454
        // the client in which any updates relevant to the state of the channels are
1455
        // sent over. Events include new active channels, inactive channels, and closed
1456
        // channels.
1457
        SubscribeChannelEvents(*ChannelEventSubscription, Lightning_SubscribeChannelEventsServer) error
1458
        // lncli: `closedchannels`
1459
        // ClosedChannels returns a description of all the closed channels that
1460
        // this node was a participant in.
1461
        ClosedChannels(context.Context, *ClosedChannelsRequest) (*ClosedChannelsResponse, error)
1462
        // OpenChannelSync is a synchronous version of the OpenChannel RPC call. This
1463
        // call is meant to be consumed by clients to the REST proxy. As with all
1464
        // other sync calls, all byte slices are intended to be populated as hex
1465
        // encoded strings.
1466
        OpenChannelSync(context.Context, *OpenChannelRequest) (*ChannelPoint, error)
1467
        // lncli: `openchannel`
1468
        // OpenChannel attempts to open a singly funded channel specified in the
1469
        // request to a remote peer. Users are able to specify a target number of
1470
        // blocks that the funding transaction should be confirmed in, or a manual fee
1471
        // rate to us for the funding transaction. If neither are specified, then a
1472
        // lax block confirmation target is used. Each OpenStatusUpdate will return
1473
        // the pending channel ID of the in-progress channel. Depending on the
1474
        // arguments specified in the OpenChannelRequest, this pending channel ID can
1475
        // then be used to manually progress the channel funding flow.
1476
        OpenChannel(*OpenChannelRequest, Lightning_OpenChannelServer) error
1477
        // lncli: `batchopenchannel`
1478
        // BatchOpenChannel attempts to open multiple single-funded channels in a
1479
        // single transaction in an atomic way. This means either all channel open
1480
        // requests succeed at once or all attempts are aborted if any of them fail.
1481
        // This is the safer variant of using PSBTs to manually fund a batch of
1482
        // channels through the OpenChannel RPC.
1483
        BatchOpenChannel(context.Context, *BatchOpenChannelRequest) (*BatchOpenChannelResponse, error)
1484
        // FundingStateStep is an advanced funding related call that allows the caller
1485
        // to either execute some preparatory steps for a funding workflow, or
1486
        // manually progress a funding workflow. The primary way a funding flow is
1487
        // identified is via its pending channel ID. As an example, this method can be
1488
        // used to specify that we're expecting a funding flow for a particular
1489
        // pending channel ID, for which we need to use specific parameters.
1490
        // Alternatively, this can be used to interactively drive PSBT signing for
1491
        // funding for partially complete funding transactions.
1492
        FundingStateStep(context.Context, *FundingTransitionMsg) (*FundingStateStepResp, error)
1493
        // ChannelAcceptor dispatches a bi-directional streaming RPC in which
1494
        // OpenChannel requests are sent to the client and the client responds with
1495
        // a boolean that tells LND whether or not to accept the channel. This allows
1496
        // node operators to specify their own criteria for accepting inbound channels
1497
        // through a single persistent connection.
1498
        ChannelAcceptor(Lightning_ChannelAcceptorServer) error
1499
        // lncli: `closechannel`
1500
        // CloseChannel attempts to close an active channel identified by its channel
1501
        // outpoint (ChannelPoint). The actions of this method can additionally be
1502
        // augmented to attempt a force close after a timeout period in the case of an
1503
        // inactive peer. If a non-force close (cooperative closure) is requested,
1504
        // then the user can specify either a target number of blocks until the
1505
        // closure transaction is confirmed, or a manual fee rate. If neither are
1506
        // specified, then a default lax, block confirmation target is used.
1507
        CloseChannel(*CloseChannelRequest, Lightning_CloseChannelServer) error
1508
        // lncli: `abandonchannel`
1509
        // AbandonChannel removes all channel state from the database except for a
1510
        // close summary. This method can be used to get rid of permanently unusable
1511
        // channels due to bugs fixed in newer versions of lnd. This method can also be
1512
        // used to remove externally funded channels where the funding transaction was
1513
        // never broadcast. Only available for non-externally funded channels in dev
1514
        // build.
1515
        AbandonChannel(context.Context, *AbandonChannelRequest) (*AbandonChannelResponse, error)
1516
        // Deprecated: Do not use.
1517
        // lncli: `sendpayment`
1518
        // Deprecated, use routerrpc.SendPaymentV2. SendPayment dispatches a
1519
        // bi-directional streaming RPC for sending payments through the Lightning
1520
        // Network. A single RPC invocation creates a persistent bi-directional
1521
        // stream allowing clients to rapidly send payments through the Lightning
1522
        // Network with a single persistent connection.
1523
        SendPayment(Lightning_SendPaymentServer) error
1524
        // Deprecated: Do not use.
1525
        //
1526
        // Deprecated, use routerrpc.SendPaymentV2. SendPaymentSync is the synchronous
1527
        // non-streaming version of SendPayment. This RPC is intended to be consumed by
1528
        // clients of the REST proxy. Additionally, this RPC expects the destination's
1529
        // public key and the payment hash (if any) to be encoded as hex strings.
1530
        SendPaymentSync(context.Context, *SendRequest) (*SendResponse, error)
1531
        // Deprecated: Do not use.
1532
        // lncli: `sendtoroute`
1533
        // Deprecated, use routerrpc.SendToRouteV2. SendToRoute is a bi-directional
1534
        // streaming RPC for sending payment through the Lightning Network. This
1535
        // method differs from SendPayment in that it allows users to specify a full
1536
        // route manually. This can be used for things like rebalancing, and atomic
1537
        // swaps.
1538
        SendToRoute(Lightning_SendToRouteServer) error
1539
        // Deprecated: Do not use.
1540
        //
1541
        // Deprecated, use routerrpc.SendToRouteV2. SendToRouteSync is a synchronous
1542
        // version of SendToRoute. It Will block until the payment either fails or
1543
        // succeeds.
1544
        SendToRouteSync(context.Context, *SendToRouteRequest) (*SendResponse, error)
1545
        // lncli: `addinvoice`
1546
        // AddInvoice attempts to add a new invoice to the invoice database. Any
1547
        // duplicated invoices are rejected, therefore all invoices *must* have a
1548
        // unique payment preimage.
1549
        AddInvoice(context.Context, *Invoice) (*AddInvoiceResponse, error)
1550
        // lncli: `listinvoices`
1551
        // ListInvoices returns a list of all the invoices currently stored within the
1552
        // database. Any active debug invoices are ignored. It has full support for
1553
        // paginated responses, allowing users to query for specific invoices through
1554
        // their add_index. This can be done by using either the first_index_offset or
1555
        // last_index_offset fields included in the response as the index_offset of the
1556
        // next request. By default, the first 100 invoices created will be returned.
1557
        // Backwards pagination is also supported through the Reversed flag.
1558
        ListInvoices(context.Context, *ListInvoiceRequest) (*ListInvoiceResponse, error)
1559
        // lncli: `lookupinvoice`
1560
        // LookupInvoice attempts to look up an invoice according to its payment hash.
1561
        // The passed payment hash *must* be exactly 32 bytes, if not, an error is
1562
        // returned.
1563
        LookupInvoice(context.Context, *PaymentHash) (*Invoice, error)
1564
        // SubscribeInvoices returns a uni-directional stream (server -> client) for
1565
        // notifying the client of newly added/settled invoices. The caller can
1566
        // optionally specify the add_index and/or the settle_index. If the add_index
1567
        // is specified, then we'll first start by sending add invoice events for all
1568
        // invoices with an add_index greater than the specified value. If the
1569
        // settle_index is specified, then next, we'll send out all settle events for
1570
        // invoices with a settle_index greater than the specified value. One or both
1571
        // of these fields can be set. If no fields are set, then we'll only send out
1572
        // the latest add/settle events.
1573
        SubscribeInvoices(*InvoiceSubscription, Lightning_SubscribeInvoicesServer) error
1574
        // lncli: `decodepayreq`
1575
        // DecodePayReq takes an encoded payment request string and attempts to decode
1576
        // it, returning a full description of the conditions encoded within the
1577
        // payment request.
1578
        DecodePayReq(context.Context, *PayReqString) (*PayReq, error)
1579
        // lncli: `listpayments`
1580
        // ListPayments returns a list of all outgoing payments.
1581
        ListPayments(context.Context, *ListPaymentsRequest) (*ListPaymentsResponse, error)
1582
        // lncli: `deletepayments`
1583
        // DeletePayment deletes an outgoing payment from DB. Note that it will not
1584
        // attempt to delete an In-Flight payment, since that would be unsafe.
1585
        DeletePayment(context.Context, *DeletePaymentRequest) (*DeletePaymentResponse, error)
1586
        // lncli: `deletepayments --all`
1587
        // DeleteAllPayments deletes all outgoing payments from DB. Note that it will
1588
        // not attempt to delete In-Flight payments, since that would be unsafe.
1589
        DeleteAllPayments(context.Context, *DeleteAllPaymentsRequest) (*DeleteAllPaymentsResponse, error)
1590
        // lncli: `describegraph`
1591
        // DescribeGraph returns a description of the latest graph state from the
1592
        // point of view of the node. The graph information is partitioned into two
1593
        // components: all the nodes/vertexes, and all the edges that connect the
1594
        // vertexes themselves. As this is a directed graph, the edges also contain
1595
        // the node directional specific routing policy which includes: the time lock
1596
        // delta, fee information, etc.
1597
        DescribeGraph(context.Context, *ChannelGraphRequest) (*ChannelGraph, error)
1598
        // lncli: `getnodemetrics`
1599
        // GetNodeMetrics returns node metrics calculated from the graph. Currently
1600
        // the only supported metric is betweenness centrality of individual nodes.
1601
        GetNodeMetrics(context.Context, *NodeMetricsRequest) (*NodeMetricsResponse, error)
1602
        // lncli: `getchaninfo`
1603
        // GetChanInfo returns the latest authenticated network announcement for the
1604
        // given channel identified by its channel ID: an 8-byte integer which
1605
        // uniquely identifies the location of transaction's funding output within the
1606
        // blockchain.
1607
        GetChanInfo(context.Context, *ChanInfoRequest) (*ChannelEdge, error)
1608
        // lncli: `getnodeinfo`
1609
        // GetNodeInfo returns the latest advertised, aggregated, and authenticated
1610
        // channel information for the specified node identified by its public key.
1611
        GetNodeInfo(context.Context, *NodeInfoRequest) (*NodeInfo, error)
1612
        // lncli: `queryroutes`
1613
        // QueryRoutes attempts to query the daemon's Channel Router for a possible
1614
        // route to a target destination capable of carrying a specific amount of
1615
        // satoshis. The returned route contains the full details required to craft and
1616
        // send an HTLC, also including the necessary information that should be
1617
        // present within the Sphinx packet encapsulated within the HTLC.
1618
        //
1619
        // When using REST, the `dest_custom_records` map type can be set by appending
1620
        // `&dest_custom_records[<record_number>]=<record_data_base64_url_encoded>`
1621
        // to the URL. Unfortunately this map type doesn't appear in the REST API
1622
        // documentation because of a bug in the grpc-gateway library.
1623
        QueryRoutes(context.Context, *QueryRoutesRequest) (*QueryRoutesResponse, error)
1624
        // lncli: `getnetworkinfo`
1625
        // GetNetworkInfo returns some basic stats about the known channel graph from
1626
        // the point of view of the node.
1627
        GetNetworkInfo(context.Context, *NetworkInfoRequest) (*NetworkInfo, error)
1628
        // lncli: `stop`
1629
        // StopDaemon will send a shutdown request to the interrupt handler, triggering
1630
        // a graceful shutdown of the daemon.
1631
        StopDaemon(context.Context, *StopRequest) (*StopResponse, error)
1632
        // SubscribeChannelGraph launches a streaming RPC that allows the caller to
1633
        // receive notifications upon any changes to the channel graph topology from
1634
        // the point of view of the responding node. Events notified include: new
1635
        // nodes coming online, nodes updating their authenticated attributes, new
1636
        // channels being advertised, updates in the routing policy for a directional
1637
        // channel edge, and when channels are closed on-chain.
1638
        SubscribeChannelGraph(*GraphTopologySubscription, Lightning_SubscribeChannelGraphServer) error
1639
        // lncli: `debuglevel`
1640
        // DebugLevel allows a caller to programmatically set the logging verbosity of
1641
        // lnd. The logging can be targeted according to a coarse daemon-wide logging
1642
        // level, or in a granular fashion to specify the logging for a target
1643
        // sub-system.
1644
        DebugLevel(context.Context, *DebugLevelRequest) (*DebugLevelResponse, error)
1645
        // lncli: `feereport`
1646
        // FeeReport allows the caller to obtain a report detailing the current fee
1647
        // schedule enforced by the node globally for each channel.
1648
        FeeReport(context.Context, *FeeReportRequest) (*FeeReportResponse, error)
1649
        // lncli: `updatechanpolicy`
1650
        // UpdateChannelPolicy allows the caller to update the fee schedule and
1651
        // channel policies for all channels globally, or a particular channel.
1652
        UpdateChannelPolicy(context.Context, *PolicyUpdateRequest) (*PolicyUpdateResponse, error)
1653
        // lncli: `fwdinghistory`
1654
        // ForwardingHistory allows the caller to query the htlcswitch for a record of
1655
        // all HTLCs forwarded within the target time range, and integer offset
1656
        // within that time range, for a maximum number of events. If no maximum number
1657
        // of events is specified, up to 100 events will be returned. If no time-range
1658
        // is specified, then events will be returned in the order that they occured.
1659
        //
1660
        // A list of forwarding events are returned. The size of each forwarding event
1661
        // is 40 bytes, and the max message size able to be returned in gRPC is 4 MiB.
1662
        // As a result each message can only contain 50k entries. Each response has
1663
        // the index offset of the last entry. The index offset can be provided to the
1664
        // request to allow the caller to skip a series of records.
1665
        ForwardingHistory(context.Context, *ForwardingHistoryRequest) (*ForwardingHistoryResponse, error)
1666
        // lncli: `exportchanbackup`
1667
        // ExportChannelBackup attempts to return an encrypted static channel backup
1668
        // for the target channel identified by it channel point. The backup is
1669
        // encrypted with a key generated from the aezeed seed of the user. The
1670
        // returned backup can either be restored using the RestoreChannelBackup
1671
        // method once lnd is running, or via the InitWallet and UnlockWallet methods
1672
        // from the WalletUnlocker service.
1673
        ExportChannelBackup(context.Context, *ExportChannelBackupRequest) (*ChannelBackup, error)
1674
        // ExportAllChannelBackups returns static channel backups for all existing
1675
        // channels known to lnd. A set of regular singular static channel backups for
1676
        // each channel are returned. Additionally, a multi-channel backup is returned
1677
        // as well, which contains a single encrypted blob containing the backups of
1678
        // each channel.
1679
        ExportAllChannelBackups(context.Context, *ChanBackupExportRequest) (*ChanBackupSnapshot, error)
1680
        // lncli: `verifychanbackup`
1681
        // VerifyChanBackup allows a caller to verify the integrity of a channel backup
1682
        // snapshot. This method will accept either a packed Single or a packed Multi.
1683
        // Specifying both will result in an error.
1684
        VerifyChanBackup(context.Context, *ChanBackupSnapshot) (*VerifyChanBackupResponse, error)
1685
        // lncli: `restorechanbackup`
1686
        // RestoreChannelBackups accepts a set of singular channel backups, or a
1687
        // single encrypted multi-chan backup and attempts to recover any funds
1688
        // remaining within the channel. If we are able to unpack the backup, then the
1689
        // new channel will be shown under listchannels, as well as pending channels.
1690
        RestoreChannelBackups(context.Context, *RestoreChanBackupRequest) (*RestoreBackupResponse, error)
1691
        // SubscribeChannelBackups allows a client to sub-subscribe to the most up to
1692
        // date information concerning the state of all channel backups. Each time a
1693
        // new channel is added, we return the new set of channels, along with a
1694
        // multi-chan backup containing the backup info for all channels. Each time a
1695
        // channel is closed, we send a new update, which contains new new chan back
1696
        // ups, but the updated set of encrypted multi-chan backups with the closed
1697
        // channel(s) removed.
1698
        SubscribeChannelBackups(*ChannelBackupSubscription, Lightning_SubscribeChannelBackupsServer) error
1699
        // lncli: `bakemacaroon`
1700
        // BakeMacaroon allows the creation of a new macaroon with custom read and
1701
        // write permissions. No first-party caveats are added since this can be done
1702
        // offline.
1703
        BakeMacaroon(context.Context, *BakeMacaroonRequest) (*BakeMacaroonResponse, error)
1704
        // lncli: `listmacaroonids`
1705
        // ListMacaroonIDs returns all root key IDs that are in use.
1706
        ListMacaroonIDs(context.Context, *ListMacaroonIDsRequest) (*ListMacaroonIDsResponse, error)
1707
        // lncli: `deletemacaroonid`
1708
        // DeleteMacaroonID deletes the specified macaroon ID and invalidates all
1709
        // macaroons derived from that ID.
1710
        DeleteMacaroonID(context.Context, *DeleteMacaroonIDRequest) (*DeleteMacaroonIDResponse, error)
1711
        // lncli: `listpermissions`
1712
        // ListPermissions lists all RPC method URIs and their required macaroon
1713
        // permissions to access them.
1714
        ListPermissions(context.Context, *ListPermissionsRequest) (*ListPermissionsResponse, error)
1715
        // CheckMacaroonPermissions checks whether a request follows the constraints
1716
        // imposed on the macaroon and that the macaroon is authorized to follow the
1717
        // provided permissions.
1718
        CheckMacaroonPermissions(context.Context, *CheckMacPermRequest) (*CheckMacPermResponse, error)
1719
        // RegisterRPCMiddleware adds a new gRPC middleware to the interceptor chain. A
1720
        // gRPC middleware is software component external to lnd that aims to add
1721
        // additional business logic to lnd by observing/intercepting/validating
1722
        // incoming gRPC client requests and (if needed) replacing/overwriting outgoing
1723
        // messages before they're sent to the client. When registering the middleware
1724
        // must identify itself and indicate what custom macaroon caveats it wants to
1725
        // be responsible for. Only requests that contain a macaroon with that specific
1726
        // custom caveat are then sent to the middleware for inspection. The other
1727
        // option is to register for the read-only mode in which all requests/responses
1728
        // are forwarded for interception to the middleware but the middleware is not
1729
        // allowed to modify any responses. As a security measure, _no_ middleware can
1730
        // modify responses for requests made with _unencumbered_ macaroons!
1731
        RegisterRPCMiddleware(Lightning_RegisterRPCMiddlewareServer) error
1732
        // lncli: `sendcustom`
1733
        // SendCustomMessage sends a custom peer message.
1734
        SendCustomMessage(context.Context, *SendCustomMessageRequest) (*SendCustomMessageResponse, error)
1735
        // lncli: `subscribecustom`
1736
        // SubscribeCustomMessages subscribes to a stream of incoming custom peer
1737
        // messages.
1738
        //
1739
        // To include messages with type outside of the custom range (>= 32768) lnd
1740
        // needs to be compiled with  the `dev` build tag, and the message type to
1741
        // override should be specified in lnd's experimental protocol configuration.
1742
        SubscribeCustomMessages(*SubscribeCustomMessagesRequest, Lightning_SubscribeCustomMessagesServer) error
1743
        // lncli: `listaliases`
1744
        // ListAliases returns the set of all aliases that have ever existed with
1745
        // their confirmed SCID (if it exists) and/or the base SCID (in the case of
1746
        // zero conf).
1747
        ListAliases(context.Context, *ListAliasesRequest) (*ListAliasesResponse, error)
1748
        // LookupHtlcResolution retrieves a final htlc resolution from the database.
1749
        // If the htlc has no final resolution yet, a NotFound grpc status code is
1750
        // returned.
1751
        LookupHtlcResolution(context.Context, *LookupHtlcResolutionRequest) (*LookupHtlcResolutionResponse, error)
1752
        mustEmbedUnimplementedLightningServer()
1753
}
1754

1755
// UnimplementedLightningServer must be embedded to have forward compatible implementations.
1756
type UnimplementedLightningServer struct {
1757
}
1758

1759
func (UnimplementedLightningServer) WalletBalance(context.Context, *WalletBalanceRequest) (*WalletBalanceResponse, error) {
×
1760
        return nil, status.Errorf(codes.Unimplemented, "method WalletBalance not implemented")
×
1761
}
×
1762
func (UnimplementedLightningServer) ChannelBalance(context.Context, *ChannelBalanceRequest) (*ChannelBalanceResponse, error) {
×
1763
        return nil, status.Errorf(codes.Unimplemented, "method ChannelBalance not implemented")
×
1764
}
×
1765
func (UnimplementedLightningServer) GetTransactions(context.Context, *GetTransactionsRequest) (*TransactionDetails, error) {
×
1766
        return nil, status.Errorf(codes.Unimplemented, "method GetTransactions not implemented")
×
1767
}
×
1768
func (UnimplementedLightningServer) EstimateFee(context.Context, *EstimateFeeRequest) (*EstimateFeeResponse, error) {
×
1769
        return nil, status.Errorf(codes.Unimplemented, "method EstimateFee not implemented")
×
1770
}
×
1771
func (UnimplementedLightningServer) SendCoins(context.Context, *SendCoinsRequest) (*SendCoinsResponse, error) {
×
1772
        return nil, status.Errorf(codes.Unimplemented, "method SendCoins not implemented")
×
1773
}
×
1774
func (UnimplementedLightningServer) ListUnspent(context.Context, *ListUnspentRequest) (*ListUnspentResponse, error) {
×
1775
        return nil, status.Errorf(codes.Unimplemented, "method ListUnspent not implemented")
×
1776
}
×
1777
func (UnimplementedLightningServer) SubscribeTransactions(*GetTransactionsRequest, Lightning_SubscribeTransactionsServer) error {
×
1778
        return status.Errorf(codes.Unimplemented, "method SubscribeTransactions not implemented")
×
1779
}
×
1780
func (UnimplementedLightningServer) SendMany(context.Context, *SendManyRequest) (*SendManyResponse, error) {
×
1781
        return nil, status.Errorf(codes.Unimplemented, "method SendMany not implemented")
×
1782
}
×
1783
func (UnimplementedLightningServer) NewAddress(context.Context, *NewAddressRequest) (*NewAddressResponse, error) {
×
1784
        return nil, status.Errorf(codes.Unimplemented, "method NewAddress not implemented")
×
1785
}
×
1786
func (UnimplementedLightningServer) SignMessage(context.Context, *SignMessageRequest) (*SignMessageResponse, error) {
×
1787
        return nil, status.Errorf(codes.Unimplemented, "method SignMessage not implemented")
×
1788
}
×
1789
func (UnimplementedLightningServer) VerifyMessage(context.Context, *VerifyMessageRequest) (*VerifyMessageResponse, error) {
×
1790
        return nil, status.Errorf(codes.Unimplemented, "method VerifyMessage not implemented")
×
1791
}
×
1792
func (UnimplementedLightningServer) ConnectPeer(context.Context, *ConnectPeerRequest) (*ConnectPeerResponse, error) {
×
1793
        return nil, status.Errorf(codes.Unimplemented, "method ConnectPeer not implemented")
×
1794
}
×
1795
func (UnimplementedLightningServer) DisconnectPeer(context.Context, *DisconnectPeerRequest) (*DisconnectPeerResponse, error) {
×
1796
        return nil, status.Errorf(codes.Unimplemented, "method DisconnectPeer not implemented")
×
1797
}
×
1798
func (UnimplementedLightningServer) ListPeers(context.Context, *ListPeersRequest) (*ListPeersResponse, error) {
×
1799
        return nil, status.Errorf(codes.Unimplemented, "method ListPeers not implemented")
×
1800
}
×
1801
func (UnimplementedLightningServer) SubscribePeerEvents(*PeerEventSubscription, Lightning_SubscribePeerEventsServer) error {
×
1802
        return status.Errorf(codes.Unimplemented, "method SubscribePeerEvents not implemented")
×
1803
}
×
1804
func (UnimplementedLightningServer) GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error) {
×
1805
        return nil, status.Errorf(codes.Unimplemented, "method GetInfo not implemented")
×
1806
}
×
1807
func (UnimplementedLightningServer) GetDebugInfo(context.Context, *GetDebugInfoRequest) (*GetDebugInfoResponse, error) {
×
1808
        return nil, status.Errorf(codes.Unimplemented, "method GetDebugInfo not implemented")
×
1809
}
×
1810
func (UnimplementedLightningServer) GetRecoveryInfo(context.Context, *GetRecoveryInfoRequest) (*GetRecoveryInfoResponse, error) {
×
1811
        return nil, status.Errorf(codes.Unimplemented, "method GetRecoveryInfo not implemented")
×
1812
}
×
1813
func (UnimplementedLightningServer) PendingChannels(context.Context, *PendingChannelsRequest) (*PendingChannelsResponse, error) {
×
1814
        return nil, status.Errorf(codes.Unimplemented, "method PendingChannels not implemented")
×
1815
}
×
1816
func (UnimplementedLightningServer) ListChannels(context.Context, *ListChannelsRequest) (*ListChannelsResponse, error) {
×
1817
        return nil, status.Errorf(codes.Unimplemented, "method ListChannels not implemented")
×
1818
}
×
1819
func (UnimplementedLightningServer) SubscribeChannelEvents(*ChannelEventSubscription, Lightning_SubscribeChannelEventsServer) error {
×
1820
        return status.Errorf(codes.Unimplemented, "method SubscribeChannelEvents not implemented")
×
1821
}
×
1822
func (UnimplementedLightningServer) ClosedChannels(context.Context, *ClosedChannelsRequest) (*ClosedChannelsResponse, error) {
×
1823
        return nil, status.Errorf(codes.Unimplemented, "method ClosedChannels not implemented")
×
1824
}
×
1825
func (UnimplementedLightningServer) OpenChannelSync(context.Context, *OpenChannelRequest) (*ChannelPoint, error) {
×
1826
        return nil, status.Errorf(codes.Unimplemented, "method OpenChannelSync not implemented")
×
1827
}
×
1828
func (UnimplementedLightningServer) OpenChannel(*OpenChannelRequest, Lightning_OpenChannelServer) error {
×
1829
        return status.Errorf(codes.Unimplemented, "method OpenChannel not implemented")
×
1830
}
×
1831
func (UnimplementedLightningServer) BatchOpenChannel(context.Context, *BatchOpenChannelRequest) (*BatchOpenChannelResponse, error) {
×
1832
        return nil, status.Errorf(codes.Unimplemented, "method BatchOpenChannel not implemented")
×
1833
}
×
1834
func (UnimplementedLightningServer) FundingStateStep(context.Context, *FundingTransitionMsg) (*FundingStateStepResp, error) {
×
1835
        return nil, status.Errorf(codes.Unimplemented, "method FundingStateStep not implemented")
×
1836
}
×
1837
func (UnimplementedLightningServer) ChannelAcceptor(Lightning_ChannelAcceptorServer) error {
×
1838
        return status.Errorf(codes.Unimplemented, "method ChannelAcceptor not implemented")
×
1839
}
×
1840
func (UnimplementedLightningServer) CloseChannel(*CloseChannelRequest, Lightning_CloseChannelServer) error {
×
1841
        return status.Errorf(codes.Unimplemented, "method CloseChannel not implemented")
×
1842
}
×
1843
func (UnimplementedLightningServer) AbandonChannel(context.Context, *AbandonChannelRequest) (*AbandonChannelResponse, error) {
×
1844
        return nil, status.Errorf(codes.Unimplemented, "method AbandonChannel not implemented")
×
1845
}
×
1846
func (UnimplementedLightningServer) SendPayment(Lightning_SendPaymentServer) error {
×
1847
        return status.Errorf(codes.Unimplemented, "method SendPayment not implemented")
×
1848
}
×
1849
func (UnimplementedLightningServer) SendPaymentSync(context.Context, *SendRequest) (*SendResponse, error) {
×
1850
        return nil, status.Errorf(codes.Unimplemented, "method SendPaymentSync not implemented")
×
1851
}
×
1852
func (UnimplementedLightningServer) SendToRoute(Lightning_SendToRouteServer) error {
×
1853
        return status.Errorf(codes.Unimplemented, "method SendToRoute not implemented")
×
1854
}
×
1855
func (UnimplementedLightningServer) SendToRouteSync(context.Context, *SendToRouteRequest) (*SendResponse, error) {
×
1856
        return nil, status.Errorf(codes.Unimplemented, "method SendToRouteSync not implemented")
×
1857
}
×
1858
func (UnimplementedLightningServer) AddInvoice(context.Context, *Invoice) (*AddInvoiceResponse, error) {
×
1859
        return nil, status.Errorf(codes.Unimplemented, "method AddInvoice not implemented")
×
1860
}
×
1861
func (UnimplementedLightningServer) ListInvoices(context.Context, *ListInvoiceRequest) (*ListInvoiceResponse, error) {
×
1862
        return nil, status.Errorf(codes.Unimplemented, "method ListInvoices not implemented")
×
1863
}
×
1864
func (UnimplementedLightningServer) LookupInvoice(context.Context, *PaymentHash) (*Invoice, error) {
×
1865
        return nil, status.Errorf(codes.Unimplemented, "method LookupInvoice not implemented")
×
1866
}
×
1867
func (UnimplementedLightningServer) SubscribeInvoices(*InvoiceSubscription, Lightning_SubscribeInvoicesServer) error {
×
1868
        return status.Errorf(codes.Unimplemented, "method SubscribeInvoices not implemented")
×
1869
}
×
1870
func (UnimplementedLightningServer) DecodePayReq(context.Context, *PayReqString) (*PayReq, error) {
×
1871
        return nil, status.Errorf(codes.Unimplemented, "method DecodePayReq not implemented")
×
1872
}
×
1873
func (UnimplementedLightningServer) ListPayments(context.Context, *ListPaymentsRequest) (*ListPaymentsResponse, error) {
×
1874
        return nil, status.Errorf(codes.Unimplemented, "method ListPayments not implemented")
×
1875
}
×
1876
func (UnimplementedLightningServer) DeletePayment(context.Context, *DeletePaymentRequest) (*DeletePaymentResponse, error) {
×
1877
        return nil, status.Errorf(codes.Unimplemented, "method DeletePayment not implemented")
×
1878
}
×
1879
func (UnimplementedLightningServer) DeleteAllPayments(context.Context, *DeleteAllPaymentsRequest) (*DeleteAllPaymentsResponse, error) {
×
1880
        return nil, status.Errorf(codes.Unimplemented, "method DeleteAllPayments not implemented")
×
1881
}
×
1882
func (UnimplementedLightningServer) DescribeGraph(context.Context, *ChannelGraphRequest) (*ChannelGraph, error) {
×
1883
        return nil, status.Errorf(codes.Unimplemented, "method DescribeGraph not implemented")
×
1884
}
×
1885
func (UnimplementedLightningServer) GetNodeMetrics(context.Context, *NodeMetricsRequest) (*NodeMetricsResponse, error) {
×
1886
        return nil, status.Errorf(codes.Unimplemented, "method GetNodeMetrics not implemented")
×
1887
}
×
1888
func (UnimplementedLightningServer) GetChanInfo(context.Context, *ChanInfoRequest) (*ChannelEdge, error) {
×
1889
        return nil, status.Errorf(codes.Unimplemented, "method GetChanInfo not implemented")
×
1890
}
×
1891
func (UnimplementedLightningServer) GetNodeInfo(context.Context, *NodeInfoRequest) (*NodeInfo, error) {
×
1892
        return nil, status.Errorf(codes.Unimplemented, "method GetNodeInfo not implemented")
×
1893
}
×
1894
func (UnimplementedLightningServer) QueryRoutes(context.Context, *QueryRoutesRequest) (*QueryRoutesResponse, error) {
×
1895
        return nil, status.Errorf(codes.Unimplemented, "method QueryRoutes not implemented")
×
1896
}
×
1897
func (UnimplementedLightningServer) GetNetworkInfo(context.Context, *NetworkInfoRequest) (*NetworkInfo, error) {
×
1898
        return nil, status.Errorf(codes.Unimplemented, "method GetNetworkInfo not implemented")
×
1899
}
×
1900
func (UnimplementedLightningServer) StopDaemon(context.Context, *StopRequest) (*StopResponse, error) {
×
1901
        return nil, status.Errorf(codes.Unimplemented, "method StopDaemon not implemented")
×
1902
}
×
1903
func (UnimplementedLightningServer) SubscribeChannelGraph(*GraphTopologySubscription, Lightning_SubscribeChannelGraphServer) error {
×
1904
        return status.Errorf(codes.Unimplemented, "method SubscribeChannelGraph not implemented")
×
1905
}
×
1906
func (UnimplementedLightningServer) DebugLevel(context.Context, *DebugLevelRequest) (*DebugLevelResponse, error) {
×
1907
        return nil, status.Errorf(codes.Unimplemented, "method DebugLevel not implemented")
×
1908
}
×
1909
func (UnimplementedLightningServer) FeeReport(context.Context, *FeeReportRequest) (*FeeReportResponse, error) {
×
1910
        return nil, status.Errorf(codes.Unimplemented, "method FeeReport not implemented")
×
1911
}
×
1912
func (UnimplementedLightningServer) UpdateChannelPolicy(context.Context, *PolicyUpdateRequest) (*PolicyUpdateResponse, error) {
×
1913
        return nil, status.Errorf(codes.Unimplemented, "method UpdateChannelPolicy not implemented")
×
1914
}
×
1915
func (UnimplementedLightningServer) ForwardingHistory(context.Context, *ForwardingHistoryRequest) (*ForwardingHistoryResponse, error) {
×
1916
        return nil, status.Errorf(codes.Unimplemented, "method ForwardingHistory not implemented")
×
1917
}
×
1918
func (UnimplementedLightningServer) ExportChannelBackup(context.Context, *ExportChannelBackupRequest) (*ChannelBackup, error) {
×
1919
        return nil, status.Errorf(codes.Unimplemented, "method ExportChannelBackup not implemented")
×
1920
}
×
1921
func (UnimplementedLightningServer) ExportAllChannelBackups(context.Context, *ChanBackupExportRequest) (*ChanBackupSnapshot, error) {
×
1922
        return nil, status.Errorf(codes.Unimplemented, "method ExportAllChannelBackups not implemented")
×
1923
}
×
1924
func (UnimplementedLightningServer) VerifyChanBackup(context.Context, *ChanBackupSnapshot) (*VerifyChanBackupResponse, error) {
×
1925
        return nil, status.Errorf(codes.Unimplemented, "method VerifyChanBackup not implemented")
×
1926
}
×
1927
func (UnimplementedLightningServer) RestoreChannelBackups(context.Context, *RestoreChanBackupRequest) (*RestoreBackupResponse, error) {
×
1928
        return nil, status.Errorf(codes.Unimplemented, "method RestoreChannelBackups not implemented")
×
1929
}
×
1930
func (UnimplementedLightningServer) SubscribeChannelBackups(*ChannelBackupSubscription, Lightning_SubscribeChannelBackupsServer) error {
×
1931
        return status.Errorf(codes.Unimplemented, "method SubscribeChannelBackups not implemented")
×
1932
}
×
1933
func (UnimplementedLightningServer) BakeMacaroon(context.Context, *BakeMacaroonRequest) (*BakeMacaroonResponse, error) {
×
1934
        return nil, status.Errorf(codes.Unimplemented, "method BakeMacaroon not implemented")
×
1935
}
×
1936
func (UnimplementedLightningServer) ListMacaroonIDs(context.Context, *ListMacaroonIDsRequest) (*ListMacaroonIDsResponse, error) {
×
1937
        return nil, status.Errorf(codes.Unimplemented, "method ListMacaroonIDs not implemented")
×
1938
}
×
1939
func (UnimplementedLightningServer) DeleteMacaroonID(context.Context, *DeleteMacaroonIDRequest) (*DeleteMacaroonIDResponse, error) {
×
1940
        return nil, status.Errorf(codes.Unimplemented, "method DeleteMacaroonID not implemented")
×
1941
}
×
1942
func (UnimplementedLightningServer) ListPermissions(context.Context, *ListPermissionsRequest) (*ListPermissionsResponse, error) {
×
1943
        return nil, status.Errorf(codes.Unimplemented, "method ListPermissions not implemented")
×
1944
}
×
1945
func (UnimplementedLightningServer) CheckMacaroonPermissions(context.Context, *CheckMacPermRequest) (*CheckMacPermResponse, error) {
×
1946
        return nil, status.Errorf(codes.Unimplemented, "method CheckMacaroonPermissions not implemented")
×
1947
}
×
1948
func (UnimplementedLightningServer) RegisterRPCMiddleware(Lightning_RegisterRPCMiddlewareServer) error {
×
1949
        return status.Errorf(codes.Unimplemented, "method RegisterRPCMiddleware not implemented")
×
1950
}
×
1951
func (UnimplementedLightningServer) SendCustomMessage(context.Context, *SendCustomMessageRequest) (*SendCustomMessageResponse, error) {
×
1952
        return nil, status.Errorf(codes.Unimplemented, "method SendCustomMessage not implemented")
×
1953
}
×
1954
func (UnimplementedLightningServer) SubscribeCustomMessages(*SubscribeCustomMessagesRequest, Lightning_SubscribeCustomMessagesServer) error {
×
1955
        return status.Errorf(codes.Unimplemented, "method SubscribeCustomMessages not implemented")
×
1956
}
×
1957
func (UnimplementedLightningServer) ListAliases(context.Context, *ListAliasesRequest) (*ListAliasesResponse, error) {
×
1958
        return nil, status.Errorf(codes.Unimplemented, "method ListAliases not implemented")
×
1959
}
×
1960
func (UnimplementedLightningServer) LookupHtlcResolution(context.Context, *LookupHtlcResolutionRequest) (*LookupHtlcResolutionResponse, error) {
×
1961
        return nil, status.Errorf(codes.Unimplemented, "method LookupHtlcResolution not implemented")
×
1962
}
×
1963
func (UnimplementedLightningServer) mustEmbedUnimplementedLightningServer() {}
×
1964

1965
// UnsafeLightningServer may be embedded to opt out of forward compatibility for this service.
1966
// Use of this interface is not recommended, as added methods to LightningServer will
1967
// result in compilation errors.
1968
type UnsafeLightningServer interface {
1969
        mustEmbedUnimplementedLightningServer()
1970
}
1971

1972
func RegisterLightningServer(s grpc.ServiceRegistrar, srv LightningServer) {
3✔
1973
        s.RegisterService(&Lightning_ServiceDesc, srv)
3✔
1974
}
3✔
1975

1976
func _Lightning_WalletBalance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
1977
        in := new(WalletBalanceRequest)
3✔
1978
        if err := dec(in); err != nil {
3✔
1979
                return nil, err
×
1980
        }
×
1981
        if interceptor == nil {
3✔
1982
                return srv.(LightningServer).WalletBalance(ctx, in)
×
1983
        }
×
1984
        info := &grpc.UnaryServerInfo{
3✔
1985
                Server:     srv,
3✔
1986
                FullMethod: "/lnrpc.Lightning/WalletBalance",
3✔
1987
        }
3✔
1988
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
1989
                return srv.(LightningServer).WalletBalance(ctx, req.(*WalletBalanceRequest))
3✔
1990
        }
3✔
1991
        return interceptor(ctx, in, info, handler)
3✔
1992
}
1993

1994
func _Lightning_ChannelBalance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
1995
        in := new(ChannelBalanceRequest)
3✔
1996
        if err := dec(in); err != nil {
3✔
1997
                return nil, err
×
1998
        }
×
1999
        if interceptor == nil {
3✔
2000
                return srv.(LightningServer).ChannelBalance(ctx, in)
×
2001
        }
×
2002
        info := &grpc.UnaryServerInfo{
3✔
2003
                Server:     srv,
3✔
2004
                FullMethod: "/lnrpc.Lightning/ChannelBalance",
3✔
2005
        }
3✔
2006
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2007
                return srv.(LightningServer).ChannelBalance(ctx, req.(*ChannelBalanceRequest))
3✔
2008
        }
3✔
2009
        return interceptor(ctx, in, info, handler)
3✔
2010
}
2011

2012
func _Lightning_GetTransactions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2013
        in := new(GetTransactionsRequest)
3✔
2014
        if err := dec(in); err != nil {
3✔
2015
                return nil, err
×
2016
        }
×
2017
        if interceptor == nil {
3✔
2018
                return srv.(LightningServer).GetTransactions(ctx, in)
×
2019
        }
×
2020
        info := &grpc.UnaryServerInfo{
3✔
2021
                Server:     srv,
3✔
2022
                FullMethod: "/lnrpc.Lightning/GetTransactions",
3✔
2023
        }
3✔
2024
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2025
                return srv.(LightningServer).GetTransactions(ctx, req.(*GetTransactionsRequest))
3✔
2026
        }
3✔
2027
        return interceptor(ctx, in, info, handler)
3✔
2028
}
2029

2030
func _Lightning_EstimateFee_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2031
        in := new(EstimateFeeRequest)
3✔
2032
        if err := dec(in); err != nil {
3✔
2033
                return nil, err
×
2034
        }
×
2035
        if interceptor == nil {
3✔
2036
                return srv.(LightningServer).EstimateFee(ctx, in)
×
2037
        }
×
2038
        info := &grpc.UnaryServerInfo{
3✔
2039
                Server:     srv,
3✔
2040
                FullMethod: "/lnrpc.Lightning/EstimateFee",
3✔
2041
        }
3✔
2042
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2043
                return srv.(LightningServer).EstimateFee(ctx, req.(*EstimateFeeRequest))
3✔
2044
        }
3✔
2045
        return interceptor(ctx, in, info, handler)
3✔
2046
}
2047

2048
func _Lightning_SendCoins_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2049
        in := new(SendCoinsRequest)
3✔
2050
        if err := dec(in); err != nil {
3✔
2051
                return nil, err
×
2052
        }
×
2053
        if interceptor == nil {
3✔
2054
                return srv.(LightningServer).SendCoins(ctx, in)
×
2055
        }
×
2056
        info := &grpc.UnaryServerInfo{
3✔
2057
                Server:     srv,
3✔
2058
                FullMethod: "/lnrpc.Lightning/SendCoins",
3✔
2059
        }
3✔
2060
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2061
                return srv.(LightningServer).SendCoins(ctx, req.(*SendCoinsRequest))
3✔
2062
        }
3✔
2063
        return interceptor(ctx, in, info, handler)
3✔
2064
}
2065

2066
func _Lightning_ListUnspent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2067
        in := new(ListUnspentRequest)
×
2068
        if err := dec(in); err != nil {
×
2069
                return nil, err
×
2070
        }
×
2071
        if interceptor == nil {
×
2072
                return srv.(LightningServer).ListUnspent(ctx, in)
×
2073
        }
×
2074
        info := &grpc.UnaryServerInfo{
×
2075
                Server:     srv,
×
2076
                FullMethod: "/lnrpc.Lightning/ListUnspent",
×
2077
        }
×
2078
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2079
                return srv.(LightningServer).ListUnspent(ctx, req.(*ListUnspentRequest))
×
2080
        }
×
2081
        return interceptor(ctx, in, info, handler)
×
2082
}
2083

2084
func _Lightning_SubscribeTransactions_Handler(srv interface{}, stream grpc.ServerStream) error {
×
2085
        m := new(GetTransactionsRequest)
×
2086
        if err := stream.RecvMsg(m); err != nil {
×
2087
                return err
×
2088
        }
×
2089
        return srv.(LightningServer).SubscribeTransactions(m, &lightningSubscribeTransactionsServer{stream})
×
2090
}
2091

2092
type Lightning_SubscribeTransactionsServer interface {
2093
        Send(*Transaction) error
2094
        grpc.ServerStream
2095
}
2096

2097
type lightningSubscribeTransactionsServer struct {
2098
        grpc.ServerStream
2099
}
2100

2101
func (x *lightningSubscribeTransactionsServer) Send(m *Transaction) error {
×
2102
        return x.ServerStream.SendMsg(m)
×
2103
}
×
2104

2105
func _Lightning_SendMany_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2106
        in := new(SendManyRequest)
×
2107
        if err := dec(in); err != nil {
×
2108
                return nil, err
×
2109
        }
×
2110
        if interceptor == nil {
×
2111
                return srv.(LightningServer).SendMany(ctx, in)
×
2112
        }
×
2113
        info := &grpc.UnaryServerInfo{
×
2114
                Server:     srv,
×
2115
                FullMethod: "/lnrpc.Lightning/SendMany",
×
2116
        }
×
2117
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2118
                return srv.(LightningServer).SendMany(ctx, req.(*SendManyRequest))
×
2119
        }
×
2120
        return interceptor(ctx, in, info, handler)
×
2121
}
2122

2123
func _Lightning_NewAddress_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2124
        in := new(NewAddressRequest)
3✔
2125
        if err := dec(in); err != nil {
3✔
2126
                return nil, err
×
2127
        }
×
2128
        if interceptor == nil {
3✔
2129
                return srv.(LightningServer).NewAddress(ctx, in)
×
2130
        }
×
2131
        info := &grpc.UnaryServerInfo{
3✔
2132
                Server:     srv,
3✔
2133
                FullMethod: "/lnrpc.Lightning/NewAddress",
3✔
2134
        }
3✔
2135
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2136
                return srv.(LightningServer).NewAddress(ctx, req.(*NewAddressRequest))
3✔
2137
        }
3✔
2138
        return interceptor(ctx, in, info, handler)
3✔
2139
}
2140

2141
func _Lightning_SignMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2142
        in := new(SignMessageRequest)
3✔
2143
        if err := dec(in); err != nil {
3✔
2144
                return nil, err
×
2145
        }
×
2146
        if interceptor == nil {
3✔
2147
                return srv.(LightningServer).SignMessage(ctx, in)
×
2148
        }
×
2149
        info := &grpc.UnaryServerInfo{
3✔
2150
                Server:     srv,
3✔
2151
                FullMethod: "/lnrpc.Lightning/SignMessage",
3✔
2152
        }
3✔
2153
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2154
                return srv.(LightningServer).SignMessage(ctx, req.(*SignMessageRequest))
3✔
2155
        }
3✔
2156
        return interceptor(ctx, in, info, handler)
3✔
2157
}
2158

2159
func _Lightning_VerifyMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2160
        in := new(VerifyMessageRequest)
3✔
2161
        if err := dec(in); err != nil {
3✔
2162
                return nil, err
×
2163
        }
×
2164
        if interceptor == nil {
3✔
2165
                return srv.(LightningServer).VerifyMessage(ctx, in)
×
2166
        }
×
2167
        info := &grpc.UnaryServerInfo{
3✔
2168
                Server:     srv,
3✔
2169
                FullMethod: "/lnrpc.Lightning/VerifyMessage",
3✔
2170
        }
3✔
2171
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2172
                return srv.(LightningServer).VerifyMessage(ctx, req.(*VerifyMessageRequest))
3✔
2173
        }
3✔
2174
        return interceptor(ctx, in, info, handler)
3✔
2175
}
2176

2177
func _Lightning_ConnectPeer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2178
        in := new(ConnectPeerRequest)
3✔
2179
        if err := dec(in); err != nil {
3✔
2180
                return nil, err
×
2181
        }
×
2182
        if interceptor == nil {
3✔
2183
                return srv.(LightningServer).ConnectPeer(ctx, in)
×
2184
        }
×
2185
        info := &grpc.UnaryServerInfo{
3✔
2186
                Server:     srv,
3✔
2187
                FullMethod: "/lnrpc.Lightning/ConnectPeer",
3✔
2188
        }
3✔
2189
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2190
                return srv.(LightningServer).ConnectPeer(ctx, req.(*ConnectPeerRequest))
3✔
2191
        }
3✔
2192
        return interceptor(ctx, in, info, handler)
3✔
2193
}
2194

2195
func _Lightning_DisconnectPeer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2196
        in := new(DisconnectPeerRequest)
3✔
2197
        if err := dec(in); err != nil {
3✔
2198
                return nil, err
×
2199
        }
×
2200
        if interceptor == nil {
3✔
2201
                return srv.(LightningServer).DisconnectPeer(ctx, in)
×
2202
        }
×
2203
        info := &grpc.UnaryServerInfo{
3✔
2204
                Server:     srv,
3✔
2205
                FullMethod: "/lnrpc.Lightning/DisconnectPeer",
3✔
2206
        }
3✔
2207
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2208
                return srv.(LightningServer).DisconnectPeer(ctx, req.(*DisconnectPeerRequest))
3✔
2209
        }
3✔
2210
        return interceptor(ctx, in, info, handler)
3✔
2211
}
2212

2213
func _Lightning_ListPeers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2214
        in := new(ListPeersRequest)
3✔
2215
        if err := dec(in); err != nil {
3✔
2216
                return nil, err
×
2217
        }
×
2218
        if interceptor == nil {
3✔
2219
                return srv.(LightningServer).ListPeers(ctx, in)
×
2220
        }
×
2221
        info := &grpc.UnaryServerInfo{
3✔
2222
                Server:     srv,
3✔
2223
                FullMethod: "/lnrpc.Lightning/ListPeers",
3✔
2224
        }
3✔
2225
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2226
                return srv.(LightningServer).ListPeers(ctx, req.(*ListPeersRequest))
3✔
2227
        }
3✔
2228
        return interceptor(ctx, in, info, handler)
3✔
2229
}
2230

2231
func _Lightning_SubscribePeerEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
2232
        m := new(PeerEventSubscription)
3✔
2233
        if err := stream.RecvMsg(m); err != nil {
3✔
2234
                return err
×
2235
        }
×
2236
        return srv.(LightningServer).SubscribePeerEvents(m, &lightningSubscribePeerEventsServer{stream})
3✔
2237
}
2238

2239
type Lightning_SubscribePeerEventsServer interface {
2240
        Send(*PeerEvent) error
2241
        grpc.ServerStream
2242
}
2243

2244
type lightningSubscribePeerEventsServer struct {
2245
        grpc.ServerStream
2246
}
2247

2248
func (x *lightningSubscribePeerEventsServer) Send(m *PeerEvent) error {
3✔
2249
        return x.ServerStream.SendMsg(m)
3✔
2250
}
3✔
2251

2252
func _Lightning_GetInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2253
        in := new(GetInfoRequest)
3✔
2254
        if err := dec(in); err != nil {
3✔
2255
                return nil, err
×
2256
        }
×
2257
        if interceptor == nil {
3✔
2258
                return srv.(LightningServer).GetInfo(ctx, in)
×
2259
        }
×
2260
        info := &grpc.UnaryServerInfo{
3✔
2261
                Server:     srv,
3✔
2262
                FullMethod: "/lnrpc.Lightning/GetInfo",
3✔
2263
        }
3✔
2264
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2265
                return srv.(LightningServer).GetInfo(ctx, req.(*GetInfoRequest))
3✔
2266
        }
3✔
2267
        return interceptor(ctx, in, info, handler)
3✔
2268
}
2269

2270
func _Lightning_GetDebugInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2271
        in := new(GetDebugInfoRequest)
×
2272
        if err := dec(in); err != nil {
×
2273
                return nil, err
×
2274
        }
×
2275
        if interceptor == nil {
×
2276
                return srv.(LightningServer).GetDebugInfo(ctx, in)
×
2277
        }
×
2278
        info := &grpc.UnaryServerInfo{
×
2279
                Server:     srv,
×
2280
                FullMethod: "/lnrpc.Lightning/GetDebugInfo",
×
2281
        }
×
2282
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2283
                return srv.(LightningServer).GetDebugInfo(ctx, req.(*GetDebugInfoRequest))
×
2284
        }
×
2285
        return interceptor(ctx, in, info, handler)
×
2286
}
2287

2288
func _Lightning_GetRecoveryInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2289
        in := new(GetRecoveryInfoRequest)
3✔
2290
        if err := dec(in); err != nil {
3✔
2291
                return nil, err
×
2292
        }
×
2293
        if interceptor == nil {
3✔
2294
                return srv.(LightningServer).GetRecoveryInfo(ctx, in)
×
2295
        }
×
2296
        info := &grpc.UnaryServerInfo{
3✔
2297
                Server:     srv,
3✔
2298
                FullMethod: "/lnrpc.Lightning/GetRecoveryInfo",
3✔
2299
        }
3✔
2300
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2301
                return srv.(LightningServer).GetRecoveryInfo(ctx, req.(*GetRecoveryInfoRequest))
3✔
2302
        }
3✔
2303
        return interceptor(ctx, in, info, handler)
3✔
2304
}
2305

2306
func _Lightning_PendingChannels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2307
        in := new(PendingChannelsRequest)
3✔
2308
        if err := dec(in); err != nil {
3✔
2309
                return nil, err
×
2310
        }
×
2311
        if interceptor == nil {
3✔
2312
                return srv.(LightningServer).PendingChannels(ctx, in)
×
2313
        }
×
2314
        info := &grpc.UnaryServerInfo{
3✔
2315
                Server:     srv,
3✔
2316
                FullMethod: "/lnrpc.Lightning/PendingChannels",
3✔
2317
        }
3✔
2318
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2319
                return srv.(LightningServer).PendingChannels(ctx, req.(*PendingChannelsRequest))
3✔
2320
        }
3✔
2321
        return interceptor(ctx, in, info, handler)
3✔
2322
}
2323

2324
func _Lightning_ListChannels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2325
        in := new(ListChannelsRequest)
3✔
2326
        if err := dec(in); err != nil {
3✔
2327
                return nil, err
×
2328
        }
×
2329
        if interceptor == nil {
3✔
2330
                return srv.(LightningServer).ListChannels(ctx, in)
×
2331
        }
×
2332
        info := &grpc.UnaryServerInfo{
3✔
2333
                Server:     srv,
3✔
2334
                FullMethod: "/lnrpc.Lightning/ListChannels",
3✔
2335
        }
3✔
2336
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2337
                return srv.(LightningServer).ListChannels(ctx, req.(*ListChannelsRequest))
3✔
2338
        }
3✔
2339
        return interceptor(ctx, in, info, handler)
3✔
2340
}
2341

2342
func _Lightning_SubscribeChannelEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
2343
        m := new(ChannelEventSubscription)
3✔
2344
        if err := stream.RecvMsg(m); err != nil {
3✔
2345
                return err
×
2346
        }
×
2347
        return srv.(LightningServer).SubscribeChannelEvents(m, &lightningSubscribeChannelEventsServer{stream})
3✔
2348
}
2349

2350
type Lightning_SubscribeChannelEventsServer interface {
2351
        Send(*ChannelEventUpdate) error
2352
        grpc.ServerStream
2353
}
2354

2355
type lightningSubscribeChannelEventsServer struct {
2356
        grpc.ServerStream
2357
}
2358

2359
func (x *lightningSubscribeChannelEventsServer) Send(m *ChannelEventUpdate) error {
3✔
2360
        return x.ServerStream.SendMsg(m)
3✔
2361
}
3✔
2362

2363
func _Lightning_ClosedChannels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2364
        in := new(ClosedChannelsRequest)
3✔
2365
        if err := dec(in); err != nil {
3✔
2366
                return nil, err
×
2367
        }
×
2368
        if interceptor == nil {
3✔
2369
                return srv.(LightningServer).ClosedChannels(ctx, in)
×
2370
        }
×
2371
        info := &grpc.UnaryServerInfo{
3✔
2372
                Server:     srv,
3✔
2373
                FullMethod: "/lnrpc.Lightning/ClosedChannels",
3✔
2374
        }
3✔
2375
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2376
                return srv.(LightningServer).ClosedChannels(ctx, req.(*ClosedChannelsRequest))
3✔
2377
        }
3✔
2378
        return interceptor(ctx, in, info, handler)
3✔
2379
}
2380

2381
func _Lightning_OpenChannelSync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2382
        in := new(OpenChannelRequest)
×
2383
        if err := dec(in); err != nil {
×
2384
                return nil, err
×
2385
        }
×
2386
        if interceptor == nil {
×
2387
                return srv.(LightningServer).OpenChannelSync(ctx, in)
×
2388
        }
×
2389
        info := &grpc.UnaryServerInfo{
×
2390
                Server:     srv,
×
2391
                FullMethod: "/lnrpc.Lightning/OpenChannelSync",
×
2392
        }
×
2393
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2394
                return srv.(LightningServer).OpenChannelSync(ctx, req.(*OpenChannelRequest))
×
2395
        }
×
2396
        return interceptor(ctx, in, info, handler)
×
2397
}
2398

2399
func _Lightning_OpenChannel_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
2400
        m := new(OpenChannelRequest)
3✔
2401
        if err := stream.RecvMsg(m); err != nil {
3✔
2402
                return err
×
2403
        }
×
2404
        return srv.(LightningServer).OpenChannel(m, &lightningOpenChannelServer{stream})
3✔
2405
}
2406

2407
type Lightning_OpenChannelServer interface {
2408
        Send(*OpenStatusUpdate) error
2409
        grpc.ServerStream
2410
}
2411

2412
type lightningOpenChannelServer struct {
2413
        grpc.ServerStream
2414
}
2415

2416
func (x *lightningOpenChannelServer) Send(m *OpenStatusUpdate) error {
3✔
2417
        return x.ServerStream.SendMsg(m)
3✔
2418
}
3✔
2419

2420
func _Lightning_BatchOpenChannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2421
        in := new(BatchOpenChannelRequest)
3✔
2422
        if err := dec(in); err != nil {
3✔
2423
                return nil, err
×
2424
        }
×
2425
        if interceptor == nil {
3✔
2426
                return srv.(LightningServer).BatchOpenChannel(ctx, in)
×
2427
        }
×
2428
        info := &grpc.UnaryServerInfo{
3✔
2429
                Server:     srv,
3✔
2430
                FullMethod: "/lnrpc.Lightning/BatchOpenChannel",
3✔
2431
        }
3✔
2432
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2433
                return srv.(LightningServer).BatchOpenChannel(ctx, req.(*BatchOpenChannelRequest))
3✔
2434
        }
3✔
2435
        return interceptor(ctx, in, info, handler)
3✔
2436
}
2437

2438
func _Lightning_FundingStateStep_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2439
        in := new(FundingTransitionMsg)
3✔
2440
        if err := dec(in); err != nil {
3✔
2441
                return nil, err
×
2442
        }
×
2443
        if interceptor == nil {
3✔
2444
                return srv.(LightningServer).FundingStateStep(ctx, in)
×
2445
        }
×
2446
        info := &grpc.UnaryServerInfo{
3✔
2447
                Server:     srv,
3✔
2448
                FullMethod: "/lnrpc.Lightning/FundingStateStep",
3✔
2449
        }
3✔
2450
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2451
                return srv.(LightningServer).FundingStateStep(ctx, req.(*FundingTransitionMsg))
3✔
2452
        }
3✔
2453
        return interceptor(ctx, in, info, handler)
3✔
2454
}
2455

2456
func _Lightning_ChannelAcceptor_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
2457
        return srv.(LightningServer).ChannelAcceptor(&lightningChannelAcceptorServer{stream})
3✔
2458
}
3✔
2459

2460
type Lightning_ChannelAcceptorServer interface {
2461
        Send(*ChannelAcceptRequest) error
2462
        Recv() (*ChannelAcceptResponse, error)
2463
        grpc.ServerStream
2464
}
2465

2466
type lightningChannelAcceptorServer struct {
2467
        grpc.ServerStream
2468
}
2469

2470
func (x *lightningChannelAcceptorServer) Send(m *ChannelAcceptRequest) error {
3✔
2471
        return x.ServerStream.SendMsg(m)
3✔
2472
}
3✔
2473

2474
func (x *lightningChannelAcceptorServer) Recv() (*ChannelAcceptResponse, error) {
3✔
2475
        m := new(ChannelAcceptResponse)
3✔
2476
        if err := x.ServerStream.RecvMsg(m); err != nil {
6✔
2477
                return nil, err
3✔
2478
        }
3✔
2479
        return m, nil
3✔
2480
}
2481

2482
func _Lightning_CloseChannel_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
2483
        m := new(CloseChannelRequest)
3✔
2484
        if err := stream.RecvMsg(m); err != nil {
3✔
2485
                return err
×
2486
        }
×
2487
        return srv.(LightningServer).CloseChannel(m, &lightningCloseChannelServer{stream})
3✔
2488
}
2489

2490
type Lightning_CloseChannelServer interface {
2491
        Send(*CloseStatusUpdate) error
2492
        grpc.ServerStream
2493
}
2494

2495
type lightningCloseChannelServer struct {
2496
        grpc.ServerStream
2497
}
2498

2499
func (x *lightningCloseChannelServer) Send(m *CloseStatusUpdate) error {
3✔
2500
        return x.ServerStream.SendMsg(m)
3✔
2501
}
3✔
2502

2503
func _Lightning_AbandonChannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2504
        in := new(AbandonChannelRequest)
3✔
2505
        if err := dec(in); err != nil {
3✔
2506
                return nil, err
×
2507
        }
×
2508
        if interceptor == nil {
3✔
2509
                return srv.(LightningServer).AbandonChannel(ctx, in)
×
2510
        }
×
2511
        info := &grpc.UnaryServerInfo{
3✔
2512
                Server:     srv,
3✔
2513
                FullMethod: "/lnrpc.Lightning/AbandonChannel",
3✔
2514
        }
3✔
2515
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2516
                return srv.(LightningServer).AbandonChannel(ctx, req.(*AbandonChannelRequest))
3✔
2517
        }
3✔
2518
        return interceptor(ctx, in, info, handler)
3✔
2519
}
2520

2521
func _Lightning_SendPayment_Handler(srv interface{}, stream grpc.ServerStream) error {
×
2522
        return srv.(LightningServer).SendPayment(&lightningSendPaymentServer{stream})
×
2523
}
×
2524

2525
type Lightning_SendPaymentServer interface {
2526
        Send(*SendResponse) error
2527
        Recv() (*SendRequest, error)
2528
        grpc.ServerStream
2529
}
2530

2531
type lightningSendPaymentServer struct {
2532
        grpc.ServerStream
2533
}
2534

2535
func (x *lightningSendPaymentServer) Send(m *SendResponse) error {
×
2536
        return x.ServerStream.SendMsg(m)
×
2537
}
×
2538

2539
func (x *lightningSendPaymentServer) Recv() (*SendRequest, error) {
×
2540
        m := new(SendRequest)
×
2541
        if err := x.ServerStream.RecvMsg(m); err != nil {
×
2542
                return nil, err
×
2543
        }
×
2544
        return m, nil
×
2545
}
2546

2547
func _Lightning_SendPaymentSync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2548
        in := new(SendRequest)
×
2549
        if err := dec(in); err != nil {
×
2550
                return nil, err
×
2551
        }
×
2552
        if interceptor == nil {
×
2553
                return srv.(LightningServer).SendPaymentSync(ctx, in)
×
2554
        }
×
2555
        info := &grpc.UnaryServerInfo{
×
2556
                Server:     srv,
×
2557
                FullMethod: "/lnrpc.Lightning/SendPaymentSync",
×
2558
        }
×
2559
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2560
                return srv.(LightningServer).SendPaymentSync(ctx, req.(*SendRequest))
×
2561
        }
×
2562
        return interceptor(ctx, in, info, handler)
×
2563
}
2564

2565
func _Lightning_SendToRoute_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
2566
        return srv.(LightningServer).SendToRoute(&lightningSendToRouteServer{stream})
3✔
2567
}
3✔
2568

2569
type Lightning_SendToRouteServer interface {
2570
        Send(*SendResponse) error
2571
        Recv() (*SendToRouteRequest, error)
2572
        grpc.ServerStream
2573
}
2574

2575
type lightningSendToRouteServer struct {
2576
        grpc.ServerStream
2577
}
2578

2579
func (x *lightningSendToRouteServer) Send(m *SendResponse) error {
3✔
2580
        return x.ServerStream.SendMsg(m)
3✔
2581
}
3✔
2582

2583
func (x *lightningSendToRouteServer) Recv() (*SendToRouteRequest, error) {
3✔
2584
        m := new(SendToRouteRequest)
3✔
2585
        if err := x.ServerStream.RecvMsg(m); err != nil {
6✔
2586
                return nil, err
3✔
2587
        }
3✔
2588
        return m, nil
3✔
2589
}
2590

2591
func _Lightning_SendToRouteSync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2592
        in := new(SendToRouteRequest)
3✔
2593
        if err := dec(in); err != nil {
3✔
2594
                return nil, err
×
2595
        }
×
2596
        if interceptor == nil {
3✔
2597
                return srv.(LightningServer).SendToRouteSync(ctx, in)
×
2598
        }
×
2599
        info := &grpc.UnaryServerInfo{
3✔
2600
                Server:     srv,
3✔
2601
                FullMethod: "/lnrpc.Lightning/SendToRouteSync",
3✔
2602
        }
3✔
2603
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2604
                return srv.(LightningServer).SendToRouteSync(ctx, req.(*SendToRouteRequest))
3✔
2605
        }
3✔
2606
        return interceptor(ctx, in, info, handler)
3✔
2607
}
2608

2609
func _Lightning_AddInvoice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2610
        in := new(Invoice)
3✔
2611
        if err := dec(in); err != nil {
3✔
2612
                return nil, err
×
2613
        }
×
2614
        if interceptor == nil {
3✔
2615
                return srv.(LightningServer).AddInvoice(ctx, in)
×
2616
        }
×
2617
        info := &grpc.UnaryServerInfo{
3✔
2618
                Server:     srv,
3✔
2619
                FullMethod: "/lnrpc.Lightning/AddInvoice",
3✔
2620
        }
3✔
2621
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2622
                return srv.(LightningServer).AddInvoice(ctx, req.(*Invoice))
3✔
2623
        }
3✔
2624
        return interceptor(ctx, in, info, handler)
3✔
2625
}
2626

2627
func _Lightning_ListInvoices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2628
        in := new(ListInvoiceRequest)
3✔
2629
        if err := dec(in); err != nil {
3✔
2630
                return nil, err
×
2631
        }
×
2632
        if interceptor == nil {
3✔
2633
                return srv.(LightningServer).ListInvoices(ctx, in)
×
2634
        }
×
2635
        info := &grpc.UnaryServerInfo{
3✔
2636
                Server:     srv,
3✔
2637
                FullMethod: "/lnrpc.Lightning/ListInvoices",
3✔
2638
        }
3✔
2639
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2640
                return srv.(LightningServer).ListInvoices(ctx, req.(*ListInvoiceRequest))
3✔
2641
        }
3✔
2642
        return interceptor(ctx, in, info, handler)
3✔
2643
}
2644

2645
func _Lightning_LookupInvoice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2646
        in := new(PaymentHash)
3✔
2647
        if err := dec(in); err != nil {
3✔
2648
                return nil, err
×
2649
        }
×
2650
        if interceptor == nil {
3✔
2651
                return srv.(LightningServer).LookupInvoice(ctx, in)
×
2652
        }
×
2653
        info := &grpc.UnaryServerInfo{
3✔
2654
                Server:     srv,
3✔
2655
                FullMethod: "/lnrpc.Lightning/LookupInvoice",
3✔
2656
        }
3✔
2657
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2658
                return srv.(LightningServer).LookupInvoice(ctx, req.(*PaymentHash))
3✔
2659
        }
3✔
2660
        return interceptor(ctx, in, info, handler)
3✔
2661
}
2662

2663
func _Lightning_SubscribeInvoices_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
2664
        m := new(InvoiceSubscription)
3✔
2665
        if err := stream.RecvMsg(m); err != nil {
3✔
2666
                return err
×
2667
        }
×
2668
        return srv.(LightningServer).SubscribeInvoices(m, &lightningSubscribeInvoicesServer{stream})
3✔
2669
}
2670

2671
type Lightning_SubscribeInvoicesServer interface {
2672
        Send(*Invoice) error
2673
        grpc.ServerStream
2674
}
2675

2676
type lightningSubscribeInvoicesServer struct {
2677
        grpc.ServerStream
2678
}
2679

2680
func (x *lightningSubscribeInvoicesServer) Send(m *Invoice) error {
3✔
2681
        return x.ServerStream.SendMsg(m)
3✔
2682
}
3✔
2683

2684
func _Lightning_DecodePayReq_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2685
        in := new(PayReqString)
3✔
2686
        if err := dec(in); err != nil {
3✔
2687
                return nil, err
×
2688
        }
×
2689
        if interceptor == nil {
3✔
2690
                return srv.(LightningServer).DecodePayReq(ctx, in)
×
2691
        }
×
2692
        info := &grpc.UnaryServerInfo{
3✔
2693
                Server:     srv,
3✔
2694
                FullMethod: "/lnrpc.Lightning/DecodePayReq",
3✔
2695
        }
3✔
2696
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2697
                return srv.(LightningServer).DecodePayReq(ctx, req.(*PayReqString))
3✔
2698
        }
3✔
2699
        return interceptor(ctx, in, info, handler)
3✔
2700
}
2701

2702
func _Lightning_ListPayments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2703
        in := new(ListPaymentsRequest)
3✔
2704
        if err := dec(in); err != nil {
3✔
2705
                return nil, err
×
2706
        }
×
2707
        if interceptor == nil {
3✔
2708
                return srv.(LightningServer).ListPayments(ctx, in)
×
2709
        }
×
2710
        info := &grpc.UnaryServerInfo{
3✔
2711
                Server:     srv,
3✔
2712
                FullMethod: "/lnrpc.Lightning/ListPayments",
3✔
2713
        }
3✔
2714
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2715
                return srv.(LightningServer).ListPayments(ctx, req.(*ListPaymentsRequest))
3✔
2716
        }
3✔
2717
        return interceptor(ctx, in, info, handler)
3✔
2718
}
2719

2720
func _Lightning_DeletePayment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2721
        in := new(DeletePaymentRequest)
×
2722
        if err := dec(in); err != nil {
×
2723
                return nil, err
×
2724
        }
×
2725
        if interceptor == nil {
×
2726
                return srv.(LightningServer).DeletePayment(ctx, in)
×
2727
        }
×
2728
        info := &grpc.UnaryServerInfo{
×
2729
                Server:     srv,
×
2730
                FullMethod: "/lnrpc.Lightning/DeletePayment",
×
2731
        }
×
2732
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2733
                return srv.(LightningServer).DeletePayment(ctx, req.(*DeletePaymentRequest))
×
2734
        }
×
2735
        return interceptor(ctx, in, info, handler)
×
2736
}
2737

2738
func _Lightning_DeleteAllPayments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2739
        in := new(DeleteAllPaymentsRequest)
3✔
2740
        if err := dec(in); err != nil {
3✔
2741
                return nil, err
×
2742
        }
×
2743
        if interceptor == nil {
3✔
2744
                return srv.(LightningServer).DeleteAllPayments(ctx, in)
×
2745
        }
×
2746
        info := &grpc.UnaryServerInfo{
3✔
2747
                Server:     srv,
3✔
2748
                FullMethod: "/lnrpc.Lightning/DeleteAllPayments",
3✔
2749
        }
3✔
2750
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2751
                return srv.(LightningServer).DeleteAllPayments(ctx, req.(*DeleteAllPaymentsRequest))
3✔
2752
        }
3✔
2753
        return interceptor(ctx, in, info, handler)
3✔
2754
}
2755

2756
func _Lightning_DescribeGraph_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2757
        in := new(ChannelGraphRequest)
3✔
2758
        if err := dec(in); err != nil {
3✔
2759
                return nil, err
×
2760
        }
×
2761
        if interceptor == nil {
3✔
2762
                return srv.(LightningServer).DescribeGraph(ctx, in)
×
2763
        }
×
2764
        info := &grpc.UnaryServerInfo{
3✔
2765
                Server:     srv,
3✔
2766
                FullMethod: "/lnrpc.Lightning/DescribeGraph",
3✔
2767
        }
3✔
2768
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2769
                return srv.(LightningServer).DescribeGraph(ctx, req.(*ChannelGraphRequest))
3✔
2770
        }
3✔
2771
        return interceptor(ctx, in, info, handler)
3✔
2772
}
2773

2774
func _Lightning_GetNodeMetrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2775
        in := new(NodeMetricsRequest)
×
2776
        if err := dec(in); err != nil {
×
2777
                return nil, err
×
2778
        }
×
2779
        if interceptor == nil {
×
2780
                return srv.(LightningServer).GetNodeMetrics(ctx, in)
×
2781
        }
×
2782
        info := &grpc.UnaryServerInfo{
×
2783
                Server:     srv,
×
2784
                FullMethod: "/lnrpc.Lightning/GetNodeMetrics",
×
2785
        }
×
2786
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2787
                return srv.(LightningServer).GetNodeMetrics(ctx, req.(*NodeMetricsRequest))
×
2788
        }
×
2789
        return interceptor(ctx, in, info, handler)
×
2790
}
2791

2792
func _Lightning_GetChanInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2793
        in := new(ChanInfoRequest)
3✔
2794
        if err := dec(in); err != nil {
3✔
2795
                return nil, err
×
2796
        }
×
2797
        if interceptor == nil {
3✔
2798
                return srv.(LightningServer).GetChanInfo(ctx, in)
×
2799
        }
×
2800
        info := &grpc.UnaryServerInfo{
3✔
2801
                Server:     srv,
3✔
2802
                FullMethod: "/lnrpc.Lightning/GetChanInfo",
3✔
2803
        }
3✔
2804
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2805
                return srv.(LightningServer).GetChanInfo(ctx, req.(*ChanInfoRequest))
3✔
2806
        }
3✔
2807
        return interceptor(ctx, in, info, handler)
3✔
2808
}
2809

2810
func _Lightning_GetNodeInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2811
        in := new(NodeInfoRequest)
×
2812
        if err := dec(in); err != nil {
×
2813
                return nil, err
×
2814
        }
×
2815
        if interceptor == nil {
×
2816
                return srv.(LightningServer).GetNodeInfo(ctx, in)
×
2817
        }
×
2818
        info := &grpc.UnaryServerInfo{
×
2819
                Server:     srv,
×
2820
                FullMethod: "/lnrpc.Lightning/GetNodeInfo",
×
2821
        }
×
2822
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2823
                return srv.(LightningServer).GetNodeInfo(ctx, req.(*NodeInfoRequest))
×
2824
        }
×
2825
        return interceptor(ctx, in, info, handler)
×
2826
}
2827

2828
func _Lightning_QueryRoutes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2829
        in := new(QueryRoutesRequest)
3✔
2830
        if err := dec(in); err != nil {
3✔
2831
                return nil, err
×
2832
        }
×
2833
        if interceptor == nil {
3✔
2834
                return srv.(LightningServer).QueryRoutes(ctx, in)
×
2835
        }
×
2836
        info := &grpc.UnaryServerInfo{
3✔
2837
                Server:     srv,
3✔
2838
                FullMethod: "/lnrpc.Lightning/QueryRoutes",
3✔
2839
        }
3✔
2840
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2841
                return srv.(LightningServer).QueryRoutes(ctx, req.(*QueryRoutesRequest))
3✔
2842
        }
3✔
2843
        return interceptor(ctx, in, info, handler)
3✔
2844
}
2845

2846
func _Lightning_GetNetworkInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2847
        in := new(NetworkInfoRequest)
×
2848
        if err := dec(in); err != nil {
×
2849
                return nil, err
×
2850
        }
×
2851
        if interceptor == nil {
×
2852
                return srv.(LightningServer).GetNetworkInfo(ctx, in)
×
2853
        }
×
2854
        info := &grpc.UnaryServerInfo{
×
2855
                Server:     srv,
×
2856
                FullMethod: "/lnrpc.Lightning/GetNetworkInfo",
×
2857
        }
×
2858
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2859
                return srv.(LightningServer).GetNetworkInfo(ctx, req.(*NetworkInfoRequest))
×
2860
        }
×
2861
        return interceptor(ctx, in, info, handler)
×
2862
}
2863

2864
func _Lightning_StopDaemon_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2865
        in := new(StopRequest)
3✔
2866
        if err := dec(in); err != nil {
3✔
2867
                return nil, err
×
2868
        }
×
2869
        if interceptor == nil {
3✔
2870
                return srv.(LightningServer).StopDaemon(ctx, in)
×
2871
        }
×
2872
        info := &grpc.UnaryServerInfo{
3✔
2873
                Server:     srv,
3✔
2874
                FullMethod: "/lnrpc.Lightning/StopDaemon",
3✔
2875
        }
3✔
2876
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2877
                return srv.(LightningServer).StopDaemon(ctx, req.(*StopRequest))
3✔
2878
        }
3✔
2879
        return interceptor(ctx, in, info, handler)
3✔
2880
}
2881

2882
func _Lightning_SubscribeChannelGraph_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
2883
        m := new(GraphTopologySubscription)
3✔
2884
        if err := stream.RecvMsg(m); err != nil {
3✔
UNCOV
2885
                return err
×
UNCOV
2886
        }
×
2887
        return srv.(LightningServer).SubscribeChannelGraph(m, &lightningSubscribeChannelGraphServer{stream})
3✔
2888
}
2889

2890
type Lightning_SubscribeChannelGraphServer interface {
2891
        Send(*GraphTopologyUpdate) error
2892
        grpc.ServerStream
2893
}
2894

2895
type lightningSubscribeChannelGraphServer struct {
2896
        grpc.ServerStream
2897
}
2898

2899
func (x *lightningSubscribeChannelGraphServer) Send(m *GraphTopologyUpdate) error {
3✔
2900
        return x.ServerStream.SendMsg(m)
3✔
2901
}
3✔
2902

2903
func _Lightning_DebugLevel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2904
        in := new(DebugLevelRequest)
×
2905
        if err := dec(in); err != nil {
×
2906
                return nil, err
×
2907
        }
×
2908
        if interceptor == nil {
×
2909
                return srv.(LightningServer).DebugLevel(ctx, in)
×
2910
        }
×
2911
        info := &grpc.UnaryServerInfo{
×
2912
                Server:     srv,
×
2913
                FullMethod: "/lnrpc.Lightning/DebugLevel",
×
2914
        }
×
2915
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2916
                return srv.(LightningServer).DebugLevel(ctx, req.(*DebugLevelRequest))
×
2917
        }
×
2918
        return interceptor(ctx, in, info, handler)
×
2919
}
2920

2921
func _Lightning_FeeReport_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2922
        in := new(FeeReportRequest)
3✔
2923
        if err := dec(in); err != nil {
3✔
2924
                return nil, err
×
2925
        }
×
2926
        if interceptor == nil {
3✔
2927
                return srv.(LightningServer).FeeReport(ctx, in)
×
2928
        }
×
2929
        info := &grpc.UnaryServerInfo{
3✔
2930
                Server:     srv,
3✔
2931
                FullMethod: "/lnrpc.Lightning/FeeReport",
3✔
2932
        }
3✔
2933
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2934
                return srv.(LightningServer).FeeReport(ctx, req.(*FeeReportRequest))
3✔
2935
        }
3✔
2936
        return interceptor(ctx, in, info, handler)
3✔
2937
}
2938

2939
func _Lightning_UpdateChannelPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2940
        in := new(PolicyUpdateRequest)
3✔
2941
        if err := dec(in); err != nil {
3✔
2942
                return nil, err
×
2943
        }
×
2944
        if interceptor == nil {
3✔
2945
                return srv.(LightningServer).UpdateChannelPolicy(ctx, in)
×
2946
        }
×
2947
        info := &grpc.UnaryServerInfo{
3✔
2948
                Server:     srv,
3✔
2949
                FullMethod: "/lnrpc.Lightning/UpdateChannelPolicy",
3✔
2950
        }
3✔
2951
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2952
                return srv.(LightningServer).UpdateChannelPolicy(ctx, req.(*PolicyUpdateRequest))
3✔
2953
        }
3✔
2954
        return interceptor(ctx, in, info, handler)
3✔
2955
}
2956

2957
func _Lightning_ForwardingHistory_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2958
        in := new(ForwardingHistoryRequest)
3✔
2959
        if err := dec(in); err != nil {
3✔
2960
                return nil, err
×
2961
        }
×
2962
        if interceptor == nil {
3✔
2963
                return srv.(LightningServer).ForwardingHistory(ctx, in)
×
2964
        }
×
2965
        info := &grpc.UnaryServerInfo{
3✔
2966
                Server:     srv,
3✔
2967
                FullMethod: "/lnrpc.Lightning/ForwardingHistory",
3✔
2968
        }
3✔
2969
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2970
                return srv.(LightningServer).ForwardingHistory(ctx, req.(*ForwardingHistoryRequest))
3✔
2971
        }
3✔
2972
        return interceptor(ctx, in, info, handler)
3✔
2973
}
2974

2975
func _Lightning_ExportChannelBackup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2976
        in := new(ExportChannelBackupRequest)
3✔
2977
        if err := dec(in); err != nil {
3✔
2978
                return nil, err
×
2979
        }
×
2980
        if interceptor == nil {
3✔
2981
                return srv.(LightningServer).ExportChannelBackup(ctx, in)
×
2982
        }
×
2983
        info := &grpc.UnaryServerInfo{
3✔
2984
                Server:     srv,
3✔
2985
                FullMethod: "/lnrpc.Lightning/ExportChannelBackup",
3✔
2986
        }
3✔
2987
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
2988
                return srv.(LightningServer).ExportChannelBackup(ctx, req.(*ExportChannelBackupRequest))
3✔
2989
        }
3✔
2990
        return interceptor(ctx, in, info, handler)
3✔
2991
}
2992

2993
func _Lightning_ExportAllChannelBackups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
2994
        in := new(ChanBackupExportRequest)
3✔
2995
        if err := dec(in); err != nil {
3✔
2996
                return nil, err
×
2997
        }
×
2998
        if interceptor == nil {
3✔
2999
                return srv.(LightningServer).ExportAllChannelBackups(ctx, in)
×
3000
        }
×
3001
        info := &grpc.UnaryServerInfo{
3✔
3002
                Server:     srv,
3✔
3003
                FullMethod: "/lnrpc.Lightning/ExportAllChannelBackups",
3✔
3004
        }
3✔
3005
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3006
                return srv.(LightningServer).ExportAllChannelBackups(ctx, req.(*ChanBackupExportRequest))
3✔
3007
        }
3✔
3008
        return interceptor(ctx, in, info, handler)
3✔
3009
}
3010

3011
func _Lightning_VerifyChanBackup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3012
        in := new(ChanBackupSnapshot)
3✔
3013
        if err := dec(in); err != nil {
3✔
3014
                return nil, err
×
3015
        }
×
3016
        if interceptor == nil {
3✔
3017
                return srv.(LightningServer).VerifyChanBackup(ctx, in)
×
3018
        }
×
3019
        info := &grpc.UnaryServerInfo{
3✔
3020
                Server:     srv,
3✔
3021
                FullMethod: "/lnrpc.Lightning/VerifyChanBackup",
3✔
3022
        }
3✔
3023
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3024
                return srv.(LightningServer).VerifyChanBackup(ctx, req.(*ChanBackupSnapshot))
3✔
3025
        }
3✔
3026
        return interceptor(ctx, in, info, handler)
3✔
3027
}
3028

3029
func _Lightning_RestoreChannelBackups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3030
        in := new(RestoreChanBackupRequest)
3✔
3031
        if err := dec(in); err != nil {
3✔
3032
                return nil, err
×
3033
        }
×
3034
        if interceptor == nil {
3✔
3035
                return srv.(LightningServer).RestoreChannelBackups(ctx, in)
×
3036
        }
×
3037
        info := &grpc.UnaryServerInfo{
3✔
3038
                Server:     srv,
3✔
3039
                FullMethod: "/lnrpc.Lightning/RestoreChannelBackups",
3✔
3040
        }
3✔
3041
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3042
                return srv.(LightningServer).RestoreChannelBackups(ctx, req.(*RestoreChanBackupRequest))
3✔
3043
        }
3✔
3044
        return interceptor(ctx, in, info, handler)
3✔
3045
}
3046

3047
func _Lightning_SubscribeChannelBackups_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
3048
        m := new(ChannelBackupSubscription)
3✔
3049
        if err := stream.RecvMsg(m); err != nil {
3✔
3050
                return err
×
3051
        }
×
3052
        return srv.(LightningServer).SubscribeChannelBackups(m, &lightningSubscribeChannelBackupsServer{stream})
3✔
3053
}
3054

3055
type Lightning_SubscribeChannelBackupsServer interface {
3056
        Send(*ChanBackupSnapshot) error
3057
        grpc.ServerStream
3058
}
3059

3060
type lightningSubscribeChannelBackupsServer struct {
3061
        grpc.ServerStream
3062
}
3063

3064
func (x *lightningSubscribeChannelBackupsServer) Send(m *ChanBackupSnapshot) error {
3✔
3065
        return x.ServerStream.SendMsg(m)
3✔
3066
}
3✔
3067

3068
func _Lightning_BakeMacaroon_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3069
        in := new(BakeMacaroonRequest)
3✔
3070
        if err := dec(in); err != nil {
3✔
3071
                return nil, err
×
3072
        }
×
3073
        if interceptor == nil {
3✔
3074
                return srv.(LightningServer).BakeMacaroon(ctx, in)
×
3075
        }
×
3076
        info := &grpc.UnaryServerInfo{
3✔
3077
                Server:     srv,
3✔
3078
                FullMethod: "/lnrpc.Lightning/BakeMacaroon",
3✔
3079
        }
3✔
3080
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3081
                return srv.(LightningServer).BakeMacaroon(ctx, req.(*BakeMacaroonRequest))
3✔
3082
        }
3✔
3083
        return interceptor(ctx, in, info, handler)
3✔
3084
}
3085

3086
func _Lightning_ListMacaroonIDs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3087
        in := new(ListMacaroonIDsRequest)
3✔
3088
        if err := dec(in); err != nil {
3✔
3089
                return nil, err
×
3090
        }
×
3091
        if interceptor == nil {
3✔
3092
                return srv.(LightningServer).ListMacaroonIDs(ctx, in)
×
3093
        }
×
3094
        info := &grpc.UnaryServerInfo{
3✔
3095
                Server:     srv,
3✔
3096
                FullMethod: "/lnrpc.Lightning/ListMacaroonIDs",
3✔
3097
        }
3✔
3098
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3099
                return srv.(LightningServer).ListMacaroonIDs(ctx, req.(*ListMacaroonIDsRequest))
3✔
3100
        }
3✔
3101
        return interceptor(ctx, in, info, handler)
3✔
3102
}
3103

3104
func _Lightning_DeleteMacaroonID_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3105
        in := new(DeleteMacaroonIDRequest)
3✔
3106
        if err := dec(in); err != nil {
3✔
3107
                return nil, err
×
3108
        }
×
3109
        if interceptor == nil {
3✔
3110
                return srv.(LightningServer).DeleteMacaroonID(ctx, in)
×
3111
        }
×
3112
        info := &grpc.UnaryServerInfo{
3✔
3113
                Server:     srv,
3✔
3114
                FullMethod: "/lnrpc.Lightning/DeleteMacaroonID",
3✔
3115
        }
3✔
3116
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3117
                return srv.(LightningServer).DeleteMacaroonID(ctx, req.(*DeleteMacaroonIDRequest))
3✔
3118
        }
3✔
3119
        return interceptor(ctx, in, info, handler)
3✔
3120
}
3121

3122
func _Lightning_ListPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3123
        in := new(ListPermissionsRequest)
3✔
3124
        if err := dec(in); err != nil {
3✔
3125
                return nil, err
×
3126
        }
×
3127
        if interceptor == nil {
3✔
3128
                return srv.(LightningServer).ListPermissions(ctx, in)
×
3129
        }
×
3130
        info := &grpc.UnaryServerInfo{
3✔
3131
                Server:     srv,
3✔
3132
                FullMethod: "/lnrpc.Lightning/ListPermissions",
3✔
3133
        }
3✔
3134
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3135
                return srv.(LightningServer).ListPermissions(ctx, req.(*ListPermissionsRequest))
3✔
3136
        }
3✔
3137
        return interceptor(ctx, in, info, handler)
3✔
3138
}
3139

3140
func _Lightning_CheckMacaroonPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3141
        in := new(CheckMacPermRequest)
3✔
3142
        if err := dec(in); err != nil {
3✔
3143
                return nil, err
×
3144
        }
×
3145
        if interceptor == nil {
3✔
3146
                return srv.(LightningServer).CheckMacaroonPermissions(ctx, in)
×
3147
        }
×
3148
        info := &grpc.UnaryServerInfo{
3✔
3149
                Server:     srv,
3✔
3150
                FullMethod: "/lnrpc.Lightning/CheckMacaroonPermissions",
3✔
3151
        }
3✔
3152
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3153
                return srv.(LightningServer).CheckMacaroonPermissions(ctx, req.(*CheckMacPermRequest))
3✔
3154
        }
3✔
3155
        return interceptor(ctx, in, info, handler)
3✔
3156
}
3157

3158
func _Lightning_RegisterRPCMiddleware_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
3159
        return srv.(LightningServer).RegisterRPCMiddleware(&lightningRegisterRPCMiddlewareServer{stream})
3✔
3160
}
3✔
3161

3162
type Lightning_RegisterRPCMiddlewareServer interface {
3163
        Send(*RPCMiddlewareRequest) error
3164
        Recv() (*RPCMiddlewareResponse, error)
3165
        grpc.ServerStream
3166
}
3167

3168
type lightningRegisterRPCMiddlewareServer struct {
3169
        grpc.ServerStream
3170
}
3171

3172
func (x *lightningRegisterRPCMiddlewareServer) Send(m *RPCMiddlewareRequest) error {
3✔
3173
        return x.ServerStream.SendMsg(m)
3✔
3174
}
3✔
3175

3176
func (x *lightningRegisterRPCMiddlewareServer) Recv() (*RPCMiddlewareResponse, error) {
3✔
3177
        m := new(RPCMiddlewareResponse)
3✔
3178
        if err := x.ServerStream.RecvMsg(m); err != nil {
6✔
3179
                return nil, err
3✔
3180
        }
3✔
3181
        return m, nil
3✔
3182
}
3183

3184
func _Lightning_SendCustomMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3185
        in := new(SendCustomMessageRequest)
3✔
3186
        if err := dec(in); err != nil {
3✔
3187
                return nil, err
×
3188
        }
×
3189
        if interceptor == nil {
3✔
3190
                return srv.(LightningServer).SendCustomMessage(ctx, in)
×
3191
        }
×
3192
        info := &grpc.UnaryServerInfo{
3✔
3193
                Server:     srv,
3✔
3194
                FullMethod: "/lnrpc.Lightning/SendCustomMessage",
3✔
3195
        }
3✔
3196
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3197
                return srv.(LightningServer).SendCustomMessage(ctx, req.(*SendCustomMessageRequest))
3✔
3198
        }
3✔
3199
        return interceptor(ctx, in, info, handler)
3✔
3200
}
3201

3202
func _Lightning_SubscribeCustomMessages_Handler(srv interface{}, stream grpc.ServerStream) error {
3✔
3203
        m := new(SubscribeCustomMessagesRequest)
3✔
3204
        if err := stream.RecvMsg(m); err != nil {
3✔
3205
                return err
×
3206
        }
×
3207
        return srv.(LightningServer).SubscribeCustomMessages(m, &lightningSubscribeCustomMessagesServer{stream})
3✔
3208
}
3209

3210
type Lightning_SubscribeCustomMessagesServer interface {
3211
        Send(*CustomMessage) error
3212
        grpc.ServerStream
3213
}
3214

3215
type lightningSubscribeCustomMessagesServer struct {
3216
        grpc.ServerStream
3217
}
3218

3219
func (x *lightningSubscribeCustomMessagesServer) Send(m *CustomMessage) error {
3✔
3220
        return x.ServerStream.SendMsg(m)
3✔
3221
}
3✔
3222

3223
func _Lightning_ListAliases_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
3224
        in := new(ListAliasesRequest)
×
3225
        if err := dec(in); err != nil {
×
3226
                return nil, err
×
3227
        }
×
3228
        if interceptor == nil {
×
3229
                return srv.(LightningServer).ListAliases(ctx, in)
×
3230
        }
×
3231
        info := &grpc.UnaryServerInfo{
×
3232
                Server:     srv,
×
3233
                FullMethod: "/lnrpc.Lightning/ListAliases",
×
3234
        }
×
3235
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
3236
                return srv.(LightningServer).ListAliases(ctx, req.(*ListAliasesRequest))
×
3237
        }
×
3238
        return interceptor(ctx, in, info, handler)
×
3239
}
3240

3241
func _Lightning_LookupHtlcResolution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
3✔
3242
        in := new(LookupHtlcResolutionRequest)
3✔
3243
        if err := dec(in); err != nil {
3✔
3244
                return nil, err
×
3245
        }
×
3246
        if interceptor == nil {
3✔
3247
                return srv.(LightningServer).LookupHtlcResolution(ctx, in)
×
3248
        }
×
3249
        info := &grpc.UnaryServerInfo{
3✔
3250
                Server:     srv,
3✔
3251
                FullMethod: "/lnrpc.Lightning/LookupHtlcResolution",
3✔
3252
        }
3✔
3253
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
6✔
3254
                return srv.(LightningServer).LookupHtlcResolution(ctx, req.(*LookupHtlcResolutionRequest))
3✔
3255
        }
3✔
3256
        return interceptor(ctx, in, info, handler)
3✔
3257
}
3258

3259
// Lightning_ServiceDesc is the grpc.ServiceDesc for Lightning service.
3260
// It's only intended for direct use with grpc.RegisterService,
3261
// and not to be introspected or modified (even as a copy)
3262
var Lightning_ServiceDesc = grpc.ServiceDesc{
3263
        ServiceName: "lnrpc.Lightning",
3264
        HandlerType: (*LightningServer)(nil),
3265
        Methods: []grpc.MethodDesc{
3266
                {
3267
                        MethodName: "WalletBalance",
3268
                        Handler:    _Lightning_WalletBalance_Handler,
3269
                },
3270
                {
3271
                        MethodName: "ChannelBalance",
3272
                        Handler:    _Lightning_ChannelBalance_Handler,
3273
                },
3274
                {
3275
                        MethodName: "GetTransactions",
3276
                        Handler:    _Lightning_GetTransactions_Handler,
3277
                },
3278
                {
3279
                        MethodName: "EstimateFee",
3280
                        Handler:    _Lightning_EstimateFee_Handler,
3281
                },
3282
                {
3283
                        MethodName: "SendCoins",
3284
                        Handler:    _Lightning_SendCoins_Handler,
3285
                },
3286
                {
3287
                        MethodName: "ListUnspent",
3288
                        Handler:    _Lightning_ListUnspent_Handler,
3289
                },
3290
                {
3291
                        MethodName: "SendMany",
3292
                        Handler:    _Lightning_SendMany_Handler,
3293
                },
3294
                {
3295
                        MethodName: "NewAddress",
3296
                        Handler:    _Lightning_NewAddress_Handler,
3297
                },
3298
                {
3299
                        MethodName: "SignMessage",
3300
                        Handler:    _Lightning_SignMessage_Handler,
3301
                },
3302
                {
3303
                        MethodName: "VerifyMessage",
3304
                        Handler:    _Lightning_VerifyMessage_Handler,
3305
                },
3306
                {
3307
                        MethodName: "ConnectPeer",
3308
                        Handler:    _Lightning_ConnectPeer_Handler,
3309
                },
3310
                {
3311
                        MethodName: "DisconnectPeer",
3312
                        Handler:    _Lightning_DisconnectPeer_Handler,
3313
                },
3314
                {
3315
                        MethodName: "ListPeers",
3316
                        Handler:    _Lightning_ListPeers_Handler,
3317
                },
3318
                {
3319
                        MethodName: "GetInfo",
3320
                        Handler:    _Lightning_GetInfo_Handler,
3321
                },
3322
                {
3323
                        MethodName: "GetDebugInfo",
3324
                        Handler:    _Lightning_GetDebugInfo_Handler,
3325
                },
3326
                {
3327
                        MethodName: "GetRecoveryInfo",
3328
                        Handler:    _Lightning_GetRecoveryInfo_Handler,
3329
                },
3330
                {
3331
                        MethodName: "PendingChannels",
3332
                        Handler:    _Lightning_PendingChannels_Handler,
3333
                },
3334
                {
3335
                        MethodName: "ListChannels",
3336
                        Handler:    _Lightning_ListChannels_Handler,
3337
                },
3338
                {
3339
                        MethodName: "ClosedChannels",
3340
                        Handler:    _Lightning_ClosedChannels_Handler,
3341
                },
3342
                {
3343
                        MethodName: "OpenChannelSync",
3344
                        Handler:    _Lightning_OpenChannelSync_Handler,
3345
                },
3346
                {
3347
                        MethodName: "BatchOpenChannel",
3348
                        Handler:    _Lightning_BatchOpenChannel_Handler,
3349
                },
3350
                {
3351
                        MethodName: "FundingStateStep",
3352
                        Handler:    _Lightning_FundingStateStep_Handler,
3353
                },
3354
                {
3355
                        MethodName: "AbandonChannel",
3356
                        Handler:    _Lightning_AbandonChannel_Handler,
3357
                },
3358
                {
3359
                        MethodName: "SendPaymentSync",
3360
                        Handler:    _Lightning_SendPaymentSync_Handler,
3361
                },
3362
                {
3363
                        MethodName: "SendToRouteSync",
3364
                        Handler:    _Lightning_SendToRouteSync_Handler,
3365
                },
3366
                {
3367
                        MethodName: "AddInvoice",
3368
                        Handler:    _Lightning_AddInvoice_Handler,
3369
                },
3370
                {
3371
                        MethodName: "ListInvoices",
3372
                        Handler:    _Lightning_ListInvoices_Handler,
3373
                },
3374
                {
3375
                        MethodName: "LookupInvoice",
3376
                        Handler:    _Lightning_LookupInvoice_Handler,
3377
                },
3378
                {
3379
                        MethodName: "DecodePayReq",
3380
                        Handler:    _Lightning_DecodePayReq_Handler,
3381
                },
3382
                {
3383
                        MethodName: "ListPayments",
3384
                        Handler:    _Lightning_ListPayments_Handler,
3385
                },
3386
                {
3387
                        MethodName: "DeletePayment",
3388
                        Handler:    _Lightning_DeletePayment_Handler,
3389
                },
3390
                {
3391
                        MethodName: "DeleteAllPayments",
3392
                        Handler:    _Lightning_DeleteAllPayments_Handler,
3393
                },
3394
                {
3395
                        MethodName: "DescribeGraph",
3396
                        Handler:    _Lightning_DescribeGraph_Handler,
3397
                },
3398
                {
3399
                        MethodName: "GetNodeMetrics",
3400
                        Handler:    _Lightning_GetNodeMetrics_Handler,
3401
                },
3402
                {
3403
                        MethodName: "GetChanInfo",
3404
                        Handler:    _Lightning_GetChanInfo_Handler,
3405
                },
3406
                {
3407
                        MethodName: "GetNodeInfo",
3408
                        Handler:    _Lightning_GetNodeInfo_Handler,
3409
                },
3410
                {
3411
                        MethodName: "QueryRoutes",
3412
                        Handler:    _Lightning_QueryRoutes_Handler,
3413
                },
3414
                {
3415
                        MethodName: "GetNetworkInfo",
3416
                        Handler:    _Lightning_GetNetworkInfo_Handler,
3417
                },
3418
                {
3419
                        MethodName: "StopDaemon",
3420
                        Handler:    _Lightning_StopDaemon_Handler,
3421
                },
3422
                {
3423
                        MethodName: "DebugLevel",
3424
                        Handler:    _Lightning_DebugLevel_Handler,
3425
                },
3426
                {
3427
                        MethodName: "FeeReport",
3428
                        Handler:    _Lightning_FeeReport_Handler,
3429
                },
3430
                {
3431
                        MethodName: "UpdateChannelPolicy",
3432
                        Handler:    _Lightning_UpdateChannelPolicy_Handler,
3433
                },
3434
                {
3435
                        MethodName: "ForwardingHistory",
3436
                        Handler:    _Lightning_ForwardingHistory_Handler,
3437
                },
3438
                {
3439
                        MethodName: "ExportChannelBackup",
3440
                        Handler:    _Lightning_ExportChannelBackup_Handler,
3441
                },
3442
                {
3443
                        MethodName: "ExportAllChannelBackups",
3444
                        Handler:    _Lightning_ExportAllChannelBackups_Handler,
3445
                },
3446
                {
3447
                        MethodName: "VerifyChanBackup",
3448
                        Handler:    _Lightning_VerifyChanBackup_Handler,
3449
                },
3450
                {
3451
                        MethodName: "RestoreChannelBackups",
3452
                        Handler:    _Lightning_RestoreChannelBackups_Handler,
3453
                },
3454
                {
3455
                        MethodName: "BakeMacaroon",
3456
                        Handler:    _Lightning_BakeMacaroon_Handler,
3457
                },
3458
                {
3459
                        MethodName: "ListMacaroonIDs",
3460
                        Handler:    _Lightning_ListMacaroonIDs_Handler,
3461
                },
3462
                {
3463
                        MethodName: "DeleteMacaroonID",
3464
                        Handler:    _Lightning_DeleteMacaroonID_Handler,
3465
                },
3466
                {
3467
                        MethodName: "ListPermissions",
3468
                        Handler:    _Lightning_ListPermissions_Handler,
3469
                },
3470
                {
3471
                        MethodName: "CheckMacaroonPermissions",
3472
                        Handler:    _Lightning_CheckMacaroonPermissions_Handler,
3473
                },
3474
                {
3475
                        MethodName: "SendCustomMessage",
3476
                        Handler:    _Lightning_SendCustomMessage_Handler,
3477
                },
3478
                {
3479
                        MethodName: "ListAliases",
3480
                        Handler:    _Lightning_ListAliases_Handler,
3481
                },
3482
                {
3483
                        MethodName: "LookupHtlcResolution",
3484
                        Handler:    _Lightning_LookupHtlcResolution_Handler,
3485
                },
3486
        },
3487
        Streams: []grpc.StreamDesc{
3488
                {
3489
                        StreamName:    "SubscribeTransactions",
3490
                        Handler:       _Lightning_SubscribeTransactions_Handler,
3491
                        ServerStreams: true,
3492
                },
3493
                {
3494
                        StreamName:    "SubscribePeerEvents",
3495
                        Handler:       _Lightning_SubscribePeerEvents_Handler,
3496
                        ServerStreams: true,
3497
                },
3498
                {
3499
                        StreamName:    "SubscribeChannelEvents",
3500
                        Handler:       _Lightning_SubscribeChannelEvents_Handler,
3501
                        ServerStreams: true,
3502
                },
3503
                {
3504
                        StreamName:    "OpenChannel",
3505
                        Handler:       _Lightning_OpenChannel_Handler,
3506
                        ServerStreams: true,
3507
                },
3508
                {
3509
                        StreamName:    "ChannelAcceptor",
3510
                        Handler:       _Lightning_ChannelAcceptor_Handler,
3511
                        ServerStreams: true,
3512
                        ClientStreams: true,
3513
                },
3514
                {
3515
                        StreamName:    "CloseChannel",
3516
                        Handler:       _Lightning_CloseChannel_Handler,
3517
                        ServerStreams: true,
3518
                },
3519
                {
3520
                        StreamName:    "SendPayment",
3521
                        Handler:       _Lightning_SendPayment_Handler,
3522
                        ServerStreams: true,
3523
                        ClientStreams: true,
3524
                },
3525
                {
3526
                        StreamName:    "SendToRoute",
3527
                        Handler:       _Lightning_SendToRoute_Handler,
3528
                        ServerStreams: true,
3529
                        ClientStreams: true,
3530
                },
3531
                {
3532
                        StreamName:    "SubscribeInvoices",
3533
                        Handler:       _Lightning_SubscribeInvoices_Handler,
3534
                        ServerStreams: true,
3535
                },
3536
                {
3537
                        StreamName:    "SubscribeChannelGraph",
3538
                        Handler:       _Lightning_SubscribeChannelGraph_Handler,
3539
                        ServerStreams: true,
3540
                },
3541
                {
3542
                        StreamName:    "SubscribeChannelBackups",
3543
                        Handler:       _Lightning_SubscribeChannelBackups_Handler,
3544
                        ServerStreams: true,
3545
                },
3546
                {
3547
                        StreamName:    "RegisterRPCMiddleware",
3548
                        Handler:       _Lightning_RegisterRPCMiddleware_Handler,
3549
                        ServerStreams: true,
3550
                        ClientStreams: true,
3551
                },
3552
                {
3553
                        StreamName:    "SubscribeCustomMessages",
3554
                        Handler:       _Lightning_SubscribeCustomMessages_Handler,
3555
                        ServerStreams: true,
3556
                },
3557
        },
3558
        Metadata: "lightning.proto",
3559
}
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