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

lightningnetwork / lnd / 13317599314

13 Feb 2025 09:17PM UTC coverage: 58.783% (+9.4%) from 49.357%
13317599314

Pull #9491

github

ziggie1984
docs: add release-notes
Pull Request #9491: Allow coop closing a channel with HTLCs on it via lncli

17 of 49 new or added lines in 4 files covered. (34.69%)

37 existing lines in 12 files now uncovered.

136094 of 231519 relevant lines covered (58.78%)

19279.64 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