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

lightningnetwork / lnd / 12375116696

17 Dec 2024 02:29PM UTC coverage: 58.366% (-0.2%) from 58.595%
12375116696

Pull #8777

github

ziggie1984
docs: add release-notes
Pull Request #8777: multi: make deletion of edge atomic.

132 of 177 new or added lines in 6 files covered. (74.58%)

670 existing lines in 37 files now uncovered.

133926 of 229458 relevant lines covered (58.37%)

19223.6 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
        // SendPaymentSync is the synchronous non-streaming version of SendPayment.
197
        // This RPC is intended to be consumed by clients of the REST proxy.
198
        // Additionally, this RPC expects the destination's public key and the payment
199
        // hash (if any) to be encoded as hex strings.
200
        SendPaymentSync(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)
201
        // Deprecated: Do not use.
202
        // lncli: `sendtoroute`
203
        // Deprecated, use routerrpc.SendToRouteV2. SendToRoute is a bi-directional
204
        // streaming RPC for sending payment through the Lightning Network. This
205
        // method differs from SendPayment in that it allows users to specify a full
206
        // route manually. This can be used for things like rebalancing, and atomic
207
        // swaps.
208
        SendToRoute(ctx context.Context, opts ...grpc.CallOption) (Lightning_SendToRouteClient, error)
209
        // SendToRouteSync is a synchronous version of SendToRoute. It Will block
210
        // until the payment either fails or succeeds.
211
        SendToRouteSync(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*SendResponse, error)
212
        // lncli: `addinvoice`
213
        // AddInvoice attempts to add a new invoice to the invoice database. Any
214
        // duplicated invoices are rejected, therefore all invoices *must* have a
215
        // unique payment preimage.
216
        AddInvoice(ctx context.Context, in *Invoice, opts ...grpc.CallOption) (*AddInvoiceResponse, error)
217
        // lncli: `listinvoices`
218
        // ListInvoices returns a list of all the invoices currently stored within the
219
        // database. Any active debug invoices are ignored. It has full support for
220
        // paginated responses, allowing users to query for specific invoices through
221
        // their add_index. This can be done by using either the first_index_offset or
222
        // last_index_offset fields included in the response as the index_offset of the
223
        // next request. By default, the first 100 invoices created will be returned.
224
        // Backwards pagination is also supported through the Reversed flag.
225
        ListInvoices(ctx context.Context, in *ListInvoiceRequest, opts ...grpc.CallOption) (*ListInvoiceResponse, error)
226
        // lncli: `lookupinvoice`
227
        // LookupInvoice attempts to look up an invoice according to its payment hash.
228
        // The passed payment hash *must* be exactly 32 bytes, if not, an error is
229
        // returned.
230
        LookupInvoice(ctx context.Context, in *PaymentHash, opts ...grpc.CallOption) (*Invoice, error)
231
        // SubscribeInvoices returns a uni-directional stream (server -> client) for
232
        // notifying the client of newly added/settled invoices. The caller can
233
        // optionally specify the add_index and/or the settle_index. If the add_index
234
        // is specified, then we'll first start by sending add invoice events for all
235
        // invoices with an add_index greater than the specified value. If the
236
        // settle_index is specified, then next, we'll send out all settle events for
237
        // invoices with a settle_index greater than the specified value. One or both
238
        // of these fields can be set. If no fields are set, then we'll only send out
239
        // the latest add/settle events.
240
        SubscribeInvoices(ctx context.Context, in *InvoiceSubscription, opts ...grpc.CallOption) (Lightning_SubscribeInvoicesClient, error)
241
        // lncli: `decodepayreq`
242
        // DecodePayReq takes an encoded payment request string and attempts to decode
243
        // it, returning a full description of the conditions encoded within the
244
        // payment request.
245
        DecodePayReq(ctx context.Context, in *PayReqString, opts ...grpc.CallOption) (*PayReq, error)
246
        // lncli: `listpayments`
247
        // ListPayments returns a list of all outgoing payments.
248
        ListPayments(ctx context.Context, in *ListPaymentsRequest, opts ...grpc.CallOption) (*ListPaymentsResponse, error)
249
        // lncli: `deletepayments`
250
        // DeletePayment deletes an outgoing payment from DB. Note that it will not
251
        // attempt to delete an In-Flight payment, since that would be unsafe.
252
        DeletePayment(ctx context.Context, in *DeletePaymentRequest, opts ...grpc.CallOption) (*DeletePaymentResponse, error)
253
        // lncli: `deletepayments --all`
254
        // DeleteAllPayments deletes all outgoing payments from DB. Note that it will
255
        // not attempt to delete In-Flight payments, since that would be unsafe.
256
        DeleteAllPayments(ctx context.Context, in *DeleteAllPaymentsRequest, opts ...grpc.CallOption) (*DeleteAllPaymentsResponse, error)
257
        // lncli: `describegraph`
258
        // DescribeGraph returns a description of the latest graph state from the
259
        // point of view of the node. The graph information is partitioned into two
260
        // components: all the nodes/vertexes, and all the edges that connect the
261
        // vertexes themselves. As this is a directed graph, the edges also contain
262
        // the node directional specific routing policy which includes: the time lock
263
        // delta, fee information, etc.
264
        DescribeGraph(ctx context.Context, in *ChannelGraphRequest, opts ...grpc.CallOption) (*ChannelGraph, error)
265
        // lncli: `getnodemetrics`
266
        // GetNodeMetrics returns node metrics calculated from the graph. Currently
267
        // the only supported metric is betweenness centrality of individual nodes.
268
        GetNodeMetrics(ctx context.Context, in *NodeMetricsRequest, opts ...grpc.CallOption) (*NodeMetricsResponse, error)
269
        // lncli: `getchaninfo`
270
        // GetChanInfo returns the latest authenticated network announcement for the
271
        // given channel identified by its channel ID: an 8-byte integer which
272
        // uniquely identifies the location of transaction's funding output within the
273
        // blockchain.
274
        GetChanInfo(ctx context.Context, in *ChanInfoRequest, opts ...grpc.CallOption) (*ChannelEdge, error)
275
        // lncli: `getnodeinfo`
276
        // GetNodeInfo returns the latest advertised, aggregated, and authenticated
277
        // channel information for the specified node identified by its public key.
278
        GetNodeInfo(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfo, error)
279
        // lncli: `queryroutes`
280
        // QueryRoutes attempts to query the daemon's Channel Router for a possible
281
        // route to a target destination capable of carrying a specific amount of
282
        // satoshis. The returned route contains the full details required to craft and
283
        // send an HTLC, also including the necessary information that should be
284
        // present within the Sphinx packet encapsulated within the HTLC.
285
        //
286
        // When using REST, the `dest_custom_records` map type can be set by appending
287
        // `&dest_custom_records[<record_number>]=<record_data_base64_url_encoded>`
288
        // to the URL. Unfortunately this map type doesn't appear in the REST API
289
        // documentation because of a bug in the grpc-gateway library.
290
        QueryRoutes(ctx context.Context, in *QueryRoutesRequest, opts ...grpc.CallOption) (*QueryRoutesResponse, error)
291
        // lncli: `getnetworkinfo`
292
        // GetNetworkInfo returns some basic stats about the known channel graph from
293
        // the point of view of the node.
294
        GetNetworkInfo(ctx context.Context, in *NetworkInfoRequest, opts ...grpc.CallOption) (*NetworkInfo, error)
295
        // lncli: `stop`
296
        // StopDaemon will send a shutdown request to the interrupt handler, triggering
297
        // a graceful shutdown of the daemon.
298
        StopDaemon(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
299
        // SubscribeChannelGraph launches a streaming RPC that allows the caller to
300
        // receive notifications upon any changes to the channel graph topology from
301
        // the point of view of the responding node. Events notified include: new
302
        // nodes coming online, nodes updating their authenticated attributes, new
303
        // channels being advertised, updates in the routing policy for a directional
304
        // channel edge, and when channels are closed on-chain.
305
        SubscribeChannelGraph(ctx context.Context, in *GraphTopologySubscription, opts ...grpc.CallOption) (Lightning_SubscribeChannelGraphClient, error)
306
        // lncli: `debuglevel`
307
        // DebugLevel allows a caller to programmatically set the logging verbosity of
308
        // lnd. The logging can be targeted according to a coarse daemon-wide logging
309
        // level, or in a granular fashion to specify the logging for a target
310
        // sub-system.
311
        DebugLevel(ctx context.Context, in *DebugLevelRequest, opts ...grpc.CallOption) (*DebugLevelResponse, error)
312
        // lncli: `feereport`
313
        // FeeReport allows the caller to obtain a report detailing the current fee
314
        // schedule enforced by the node globally for each channel.
315
        FeeReport(ctx context.Context, in *FeeReportRequest, opts ...grpc.CallOption) (*FeeReportResponse, error)
316
        // lncli: `updatechanpolicy`
317
        // UpdateChannelPolicy allows the caller to update the fee schedule and
318
        // channel policies for all channels globally, or a particular channel.
319
        UpdateChannelPolicy(ctx context.Context, in *PolicyUpdateRequest, opts ...grpc.CallOption) (*PolicyUpdateResponse, error)
320
        // lncli: `fwdinghistory`
321
        // ForwardingHistory allows the caller to query the htlcswitch for a record of
322
        // all HTLCs forwarded within the target time range, and integer offset
323
        // within that time range, for a maximum number of events. If no maximum number
324
        // of events is specified, up to 100 events will be returned. If no time-range
325
        // is specified, then events will be returned in the order that they occured.
326
        //
327
        // A list of forwarding events are returned. The size of each forwarding event
328
        // is 40 bytes, and the max message size able to be returned in gRPC is 4 MiB.
329
        // As a result each message can only contain 50k entries. Each response has
330
        // the index offset of the last entry. The index offset can be provided to the
331
        // request to allow the caller to skip a series of records.
332
        ForwardingHistory(ctx context.Context, in *ForwardingHistoryRequest, opts ...grpc.CallOption) (*ForwardingHistoryResponse, error)
333
        // lncli: `exportchanbackup`
334
        // ExportChannelBackup attempts to return an encrypted static channel backup
335
        // for the target channel identified by it channel point. The backup is
336
        // encrypted with a key generated from the aezeed seed of the user. The
337
        // returned backup can either be restored using the RestoreChannelBackup
338
        // method once lnd is running, or via the InitWallet and UnlockWallet methods
339
        // from the WalletUnlocker service.
340
        ExportChannelBackup(ctx context.Context, in *ExportChannelBackupRequest, opts ...grpc.CallOption) (*ChannelBackup, error)
341
        // ExportAllChannelBackups returns static channel backups for all existing
342
        // channels known to lnd. A set of regular singular static channel backups for
343
        // each channel are returned. Additionally, a multi-channel backup is returned
344
        // as well, which contains a single encrypted blob containing the backups of
345
        // each channel.
346
        ExportAllChannelBackups(ctx context.Context, in *ChanBackupExportRequest, opts ...grpc.CallOption) (*ChanBackupSnapshot, error)
347
        // lncli: `verifychanbackup`
348
        // VerifyChanBackup allows a caller to verify the integrity of a channel backup
349
        // snapshot. This method will accept either a packed Single or a packed Multi.
350
        // Specifying both will result in an error.
351
        VerifyChanBackup(ctx context.Context, in *ChanBackupSnapshot, opts ...grpc.CallOption) (*VerifyChanBackupResponse, error)
352
        // lncli: `restorechanbackup`
353
        // RestoreChannelBackups accepts a set of singular channel backups, or a
354
        // single encrypted multi-chan backup and attempts to recover any funds
355
        // remaining within the channel. If we are able to unpack the backup, then the
356
        // new channel will be shown under listchannels, as well as pending channels.
357
        RestoreChannelBackups(ctx context.Context, in *RestoreChanBackupRequest, opts ...grpc.CallOption) (*RestoreBackupResponse, error)
358
        // SubscribeChannelBackups allows a client to sub-subscribe to the most up to
359
        // date information concerning the state of all channel backups. Each time a
360
        // new channel is added, we return the new set of channels, along with a
361
        // multi-chan backup containing the backup info for all channels. Each time a
362
        // channel is closed, we send a new update, which contains new new chan back
363
        // ups, but the updated set of encrypted multi-chan backups with the closed
364
        // channel(s) removed.
365
        SubscribeChannelBackups(ctx context.Context, in *ChannelBackupSubscription, opts ...grpc.CallOption) (Lightning_SubscribeChannelBackupsClient, error)
366
        // lncli: `bakemacaroon`
367
        // BakeMacaroon allows the creation of a new macaroon with custom read and
368
        // write permissions. No first-party caveats are added since this can be done
369
        // offline.
370
        BakeMacaroon(ctx context.Context, in *BakeMacaroonRequest, opts ...grpc.CallOption) (*BakeMacaroonResponse, error)
371
        // lncli: `listmacaroonids`
372
        // ListMacaroonIDs returns all root key IDs that are in use.
373
        ListMacaroonIDs(ctx context.Context, in *ListMacaroonIDsRequest, opts ...grpc.CallOption) (*ListMacaroonIDsResponse, error)
374
        // lncli: `deletemacaroonid`
375
        // DeleteMacaroonID deletes the specified macaroon ID and invalidates all
376
        // macaroons derived from that ID.
377
        DeleteMacaroonID(ctx context.Context, in *DeleteMacaroonIDRequest, opts ...grpc.CallOption) (*DeleteMacaroonIDResponse, error)
378
        // lncli: `listpermissions`
379
        // ListPermissions lists all RPC method URIs and their required macaroon
380
        // permissions to access them.
381
        ListPermissions(ctx context.Context, in *ListPermissionsRequest, opts ...grpc.CallOption) (*ListPermissionsResponse, error)
382
        // CheckMacaroonPermissions checks whether a request follows the constraints
383
        // imposed on the macaroon and that the macaroon is authorized to follow the
384
        // provided permissions.
385
        CheckMacaroonPermissions(ctx context.Context, in *CheckMacPermRequest, opts ...grpc.CallOption) (*CheckMacPermResponse, error)
386
        // RegisterRPCMiddleware adds a new gRPC middleware to the interceptor chain. A
387
        // gRPC middleware is software component external to lnd that aims to add
388
        // additional business logic to lnd by observing/intercepting/validating
389
        // incoming gRPC client requests and (if needed) replacing/overwriting outgoing
390
        // messages before they're sent to the client. When registering the middleware
391
        // must identify itself and indicate what custom macaroon caveats it wants to
392
        // be responsible for. Only requests that contain a macaroon with that specific
393
        // custom caveat are then sent to the middleware for inspection. The other
394
        // option is to register for the read-only mode in which all requests/responses
395
        // are forwarded for interception to the middleware but the middleware is not
396
        // allowed to modify any responses. As a security measure, _no_ middleware can
397
        // modify responses for requests made with _unencumbered_ macaroons!
398
        RegisterRPCMiddleware(ctx context.Context, opts ...grpc.CallOption) (Lightning_RegisterRPCMiddlewareClient, error)
399
        // lncli: `sendcustom`
400
        // SendCustomMessage sends a custom peer message.
401
        SendCustomMessage(ctx context.Context, in *SendCustomMessageRequest, opts ...grpc.CallOption) (*SendCustomMessageResponse, error)
402
        // lncli: `subscribecustom`
403
        // SubscribeCustomMessages subscribes to a stream of incoming custom peer
404
        // messages.
405
        //
406
        // To include messages with type outside of the custom range (>= 32768) lnd
407
        // needs to be compiled with  the `dev` build tag, and the message type to
408
        // override should be specified in lnd's experimental protocol configuration.
409
        SubscribeCustomMessages(ctx context.Context, in *SubscribeCustomMessagesRequest, opts ...grpc.CallOption) (Lightning_SubscribeCustomMessagesClient, error)
410
        // lncli: `listaliases`
411
        // ListAliases returns the set of all aliases that have ever existed with
412
        // their confirmed SCID (if it exists) and/or the base SCID (in the case of
413
        // zero conf).
414
        ListAliases(ctx context.Context, in *ListAliasesRequest, opts ...grpc.CallOption) (*ListAliasesResponse, error)
415
        // LookupHtlcResolution retrieves a final htlc resolution from the database.
416
        // If the htlc has no final resolution yet, a NotFound grpc status code is
417
        // returned.
418
        LookupHtlcResolution(ctx context.Context, in *LookupHtlcResolutionRequest, opts ...grpc.CallOption) (*LookupHtlcResolutionResponse, error)
419
}
420

421
type lightningClient struct {
422
        cc grpc.ClientConnInterface
423
}
424

425
func NewLightningClient(cc grpc.ClientConnInterface) LightningClient {
1✔
426
        return &lightningClient{cc}
1✔
427
}
1✔
428

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

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

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

456
func (c *lightningClient) EstimateFee(ctx context.Context, in *EstimateFeeRequest, opts ...grpc.CallOption) (*EstimateFeeResponse, error) {
1✔
457
        out := new(EstimateFeeResponse)
1✔
458
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/EstimateFee", in, out, opts...)
1✔
459
        if err != nil {
1✔
460
                return nil, err
×
461
        }
×
462
        return out, nil
1✔
463
}
464

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

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

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

498
type Lightning_SubscribeTransactionsClient interface {
499
        Recv() (*Transaction, error)
500
        grpc.ClientStream
501
}
502

503
type lightningSubscribeTransactionsClient struct {
504
        grpc.ClientStream
505
}
506

507
func (x *lightningSubscribeTransactionsClient) Recv() (*Transaction, error) {
×
508
        m := new(Transaction)
×
509
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
510
                return nil, err
×
511
        }
×
512
        return m, nil
×
513
}
514

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

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

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

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

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

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

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

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

593
type Lightning_SubscribePeerEventsClient interface {
594
        Recv() (*PeerEvent, error)
595
        grpc.ClientStream
596
}
597

598
type lightningSubscribePeerEventsClient struct {
599
        grpc.ClientStream
600
}
601

602
func (x *lightningSubscribePeerEventsClient) Recv() (*PeerEvent, error) {
×
603
        m := new(PeerEvent)
×
604
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
605
                return nil, err
×
606
        }
×
607
        return m, nil
×
608
}
609

610
func (c *lightningClient) GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error) {
1✔
611
        out := new(GetInfoResponse)
1✔
612
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/GetInfo", in, out, opts...)
1✔
613
        if err != nil {
1✔
614
                return nil, err
×
615
        }
×
616
        return out, nil
1✔
617
}
618

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

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

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

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

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

670
type Lightning_SubscribeChannelEventsClient interface {
671
        Recv() (*ChannelEventUpdate, error)
672
        grpc.ClientStream
673
}
674

675
type lightningSubscribeChannelEventsClient struct {
676
        grpc.ClientStream
677
}
678

679
func (x *lightningSubscribeChannelEventsClient) Recv() (*ChannelEventUpdate, error) {
×
680
        m := new(ChannelEventUpdate)
×
681
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
682
                return nil, err
×
683
        }
×
684
        return m, nil
×
685
}
686

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

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

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

720
type Lightning_OpenChannelClient interface {
721
        Recv() (*OpenStatusUpdate, error)
722
        grpc.ClientStream
723
}
724

725
type lightningOpenChannelClient struct {
726
        grpc.ClientStream
727
}
728

729
func (x *lightningOpenChannelClient) Recv() (*OpenStatusUpdate, error) {
×
730
        m := new(OpenStatusUpdate)
×
731
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
732
                return nil, err
×
733
        }
×
734
        return m, nil
×
735
}
736

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

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

755
func (c *lightningClient) ChannelAcceptor(ctx context.Context, opts ...grpc.CallOption) (Lightning_ChannelAcceptorClient, error) {
1✔
756
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[4], "/lnrpc.Lightning/ChannelAcceptor", opts...)
1✔
757
        if err != nil {
1✔
758
                return nil, err
×
759
        }
×
760
        x := &lightningChannelAcceptorClient{stream}
1✔
761
        return x, nil
1✔
762
}
763

764
type Lightning_ChannelAcceptorClient interface {
765
        Send(*ChannelAcceptResponse) error
766
        Recv() (*ChannelAcceptRequest, error)
767
        grpc.ClientStream
768
}
769

770
type lightningChannelAcceptorClient struct {
771
        grpc.ClientStream
772
}
773

774
func (x *lightningChannelAcceptorClient) Send(m *ChannelAcceptResponse) error {
1✔
775
        return x.ClientStream.SendMsg(m)
1✔
776
}
1✔
777

778
func (x *lightningChannelAcceptorClient) Recv() (*ChannelAcceptRequest, error) {
1✔
779
        m := new(ChannelAcceptRequest)
1✔
780
        if err := x.ClientStream.RecvMsg(m); err != nil {
2✔
781
                return nil, err
1✔
782
        }
1✔
783
        return m, nil
1✔
784
}
785

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

801
type Lightning_CloseChannelClient interface {
802
        Recv() (*CloseStatusUpdate, error)
803
        grpc.ClientStream
804
}
805

806
type lightningCloseChannelClient struct {
807
        grpc.ClientStream
808
}
809

810
func (x *lightningCloseChannelClient) Recv() (*CloseStatusUpdate, error) {
×
811
        m := new(CloseStatusUpdate)
×
812
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
813
                return nil, err
×
814
        }
×
815
        return m, nil
×
816
}
817

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

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

837
type Lightning_SendPaymentClient interface {
838
        Send(*SendRequest) error
839
        Recv() (*SendResponse, error)
840
        grpc.ClientStream
841
}
842

843
type lightningSendPaymentClient struct {
844
        grpc.ClientStream
845
}
846

847
func (x *lightningSendPaymentClient) Send(m *SendRequest) error {
×
848
        return x.ClientStream.SendMsg(m)
×
849
}
×
850

851
func (x *lightningSendPaymentClient) Recv() (*SendResponse, error) {
×
852
        m := new(SendResponse)
×
853
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
854
                return nil, err
×
855
        }
×
856
        return m, nil
×
857
}
858

859
func (c *lightningClient) SendPaymentSync(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error) {
×
860
        out := new(SendResponse)
×
861
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SendPaymentSync", in, out, opts...)
×
862
        if err != nil {
×
863
                return nil, err
×
864
        }
×
865
        return out, nil
×
866
}
867

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

878
type Lightning_SendToRouteClient interface {
879
        Send(*SendToRouteRequest) error
880
        Recv() (*SendResponse, error)
881
        grpc.ClientStream
882
}
883

884
type lightningSendToRouteClient struct {
885
        grpc.ClientStream
886
}
887

888
func (x *lightningSendToRouteClient) Send(m *SendToRouteRequest) error {
×
889
        return x.ClientStream.SendMsg(m)
×
890
}
×
891

892
func (x *lightningSendToRouteClient) Recv() (*SendResponse, error) {
×
893
        m := new(SendResponse)
×
894
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
895
                return nil, err
×
896
        }
×
897
        return m, nil
×
898
}
899

900
func (c *lightningClient) SendToRouteSync(ctx context.Context, in *SendToRouteRequest, opts ...grpc.CallOption) (*SendResponse, error) {
×
901
        out := new(SendResponse)
×
902
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SendToRouteSync", in, out, opts...)
×
903
        if err != nil {
×
904
                return nil, err
×
905
        }
×
906
        return out, nil
×
907
}
908

909
func (c *lightningClient) AddInvoice(ctx context.Context, in *Invoice, opts ...grpc.CallOption) (*AddInvoiceResponse, error) {
1✔
910
        out := new(AddInvoiceResponse)
1✔
911
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/AddInvoice", in, out, opts...)
1✔
912
        if err != nil {
1✔
913
                return nil, err
×
914
        }
×
915
        return out, nil
1✔
916
}
917

918
func (c *lightningClient) ListInvoices(ctx context.Context, in *ListInvoiceRequest, opts ...grpc.CallOption) (*ListInvoiceResponse, error) {
×
919
        out := new(ListInvoiceResponse)
×
920
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListInvoices", in, out, opts...)
×
921
        if err != nil {
×
922
                return nil, err
×
923
        }
×
924
        return out, nil
×
925
}
926

927
func (c *lightningClient) LookupInvoice(ctx context.Context, in *PaymentHash, opts ...grpc.CallOption) (*Invoice, error) {
1✔
928
        out := new(Invoice)
1✔
929
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/LookupInvoice", in, out, opts...)
1✔
930
        if err != nil {
1✔
931
                return nil, err
×
932
        }
×
933
        return out, nil
1✔
934
}
935

936
func (c *lightningClient) SubscribeInvoices(ctx context.Context, in *InvoiceSubscription, opts ...grpc.CallOption) (Lightning_SubscribeInvoicesClient, error) {
1✔
937
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[8], "/lnrpc.Lightning/SubscribeInvoices", opts...)
1✔
938
        if err != nil {
1✔
939
                return nil, err
×
940
        }
×
941
        x := &lightningSubscribeInvoicesClient{stream}
1✔
942
        if err := x.ClientStream.SendMsg(in); err != nil {
1✔
943
                return nil, err
×
944
        }
×
945
        if err := x.ClientStream.CloseSend(); err != nil {
1✔
946
                return nil, err
×
947
        }
×
948
        return x, nil
1✔
949
}
950

951
type Lightning_SubscribeInvoicesClient interface {
952
        Recv() (*Invoice, error)
953
        grpc.ClientStream
954
}
955

956
type lightningSubscribeInvoicesClient struct {
957
        grpc.ClientStream
958
}
959

960
func (x *lightningSubscribeInvoicesClient) Recv() (*Invoice, error) {
1✔
961
        m := new(Invoice)
1✔
962
        if err := x.ClientStream.RecvMsg(m); err != nil {
2✔
963
                return nil, err
1✔
964
        }
1✔
965
        return m, nil
1✔
966
}
967

968
func (c *lightningClient) DecodePayReq(ctx context.Context, in *PayReqString, opts ...grpc.CallOption) (*PayReq, error) {
×
969
        out := new(PayReq)
×
970
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DecodePayReq", in, out, opts...)
×
971
        if err != nil {
×
972
                return nil, err
×
973
        }
×
974
        return out, nil
×
975
}
976

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

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

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

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

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

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

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

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

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

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

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

1082
type Lightning_SubscribeChannelGraphClient interface {
1083
        Recv() (*GraphTopologyUpdate, error)
1084
        grpc.ClientStream
1085
}
1086

1087
type lightningSubscribeChannelGraphClient struct {
1088
        grpc.ClientStream
1089
}
1090

1091
func (x *lightningSubscribeChannelGraphClient) Recv() (*GraphTopologyUpdate, error) {
×
1092
        m := new(GraphTopologyUpdate)
×
1093
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
1094
                return nil, err
×
1095
        }
×
1096
        return m, nil
×
1097
}
1098

1099
func (c *lightningClient) DebugLevel(ctx context.Context, in *DebugLevelRequest, opts ...grpc.CallOption) (*DebugLevelResponse, error) {
×
1100
        out := new(DebugLevelResponse)
×
1101
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/DebugLevel", in, out, opts...)
×
1102
        if err != nil {
×
1103
                return nil, err
×
1104
        }
×
1105
        return out, nil
×
1106
}
1107

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

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

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

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

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

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

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

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

1186
type Lightning_SubscribeChannelBackupsClient interface {
1187
        Recv() (*ChanBackupSnapshot, error)
1188
        grpc.ClientStream
1189
}
1190

1191
type lightningSubscribeChannelBackupsClient struct {
1192
        grpc.ClientStream
1193
}
1194

1195
func (x *lightningSubscribeChannelBackupsClient) Recv() (*ChanBackupSnapshot, error) {
×
1196
        m := new(ChanBackupSnapshot)
×
1197
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
1198
                return nil, err
×
1199
        }
×
1200
        return m, nil
×
1201
}
1202

1203
func (c *lightningClient) BakeMacaroon(ctx context.Context, in *BakeMacaroonRequest, opts ...grpc.CallOption) (*BakeMacaroonResponse, error) {
×
1204
        out := new(BakeMacaroonResponse)
×
1205
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/BakeMacaroon", in, out, opts...)
×
1206
        if err != nil {
×
1207
                return nil, err
×
1208
        }
×
1209
        return out, nil
×
1210
}
1211

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

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

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

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

1248
func (c *lightningClient) RegisterRPCMiddleware(ctx context.Context, opts ...grpc.CallOption) (Lightning_RegisterRPCMiddlewareClient, error) {
×
1249
        stream, err := c.cc.NewStream(ctx, &Lightning_ServiceDesc.Streams[11], "/lnrpc.Lightning/RegisterRPCMiddleware", opts...)
×
1250
        if err != nil {
×
1251
                return nil, err
×
1252
        }
×
1253
        x := &lightningRegisterRPCMiddlewareClient{stream}
×
1254
        return x, nil
×
1255
}
1256

1257
type Lightning_RegisterRPCMiddlewareClient interface {
1258
        Send(*RPCMiddlewareResponse) error
1259
        Recv() (*RPCMiddlewareRequest, error)
1260
        grpc.ClientStream
1261
}
1262

1263
type lightningRegisterRPCMiddlewareClient struct {
1264
        grpc.ClientStream
1265
}
1266

1267
func (x *lightningRegisterRPCMiddlewareClient) Send(m *RPCMiddlewareResponse) error {
×
1268
        return x.ClientStream.SendMsg(m)
×
1269
}
×
1270

1271
func (x *lightningRegisterRPCMiddlewareClient) Recv() (*RPCMiddlewareRequest, error) {
×
1272
        m := new(RPCMiddlewareRequest)
×
1273
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
1274
                return nil, err
×
1275
        }
×
1276
        return m, nil
×
1277
}
1278

1279
func (c *lightningClient) SendCustomMessage(ctx context.Context, in *SendCustomMessageRequest, opts ...grpc.CallOption) (*SendCustomMessageResponse, error) {
×
1280
        out := new(SendCustomMessageResponse)
×
1281
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/SendCustomMessage", in, out, opts...)
×
1282
        if err != nil {
×
1283
                return nil, err
×
1284
        }
×
1285
        return out, nil
×
1286
}
1287

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

1303
type Lightning_SubscribeCustomMessagesClient interface {
1304
        Recv() (*CustomMessage, error)
1305
        grpc.ClientStream
1306
}
1307

1308
type lightningSubscribeCustomMessagesClient struct {
1309
        grpc.ClientStream
1310
}
1311

1312
func (x *lightningSubscribeCustomMessagesClient) Recv() (*CustomMessage, error) {
×
1313
        m := new(CustomMessage)
×
1314
        if err := x.ClientStream.RecvMsg(m); err != nil {
×
1315
                return nil, err
×
1316
        }
×
1317
        return m, nil
×
1318
}
1319

1320
func (c *lightningClient) ListAliases(ctx context.Context, in *ListAliasesRequest, opts ...grpc.CallOption) (*ListAliasesResponse, error) {
×
1321
        out := new(ListAliasesResponse)
×
1322
        err := c.cc.Invoke(ctx, "/lnrpc.Lightning/ListAliases", in, out, opts...)
×
1323
        if err != nil {
×
1324
                return nil, err
×
1325
        }
×
1326
        return out, nil
×
1327
}
1328

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

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

1743
// UnimplementedLightningServer must be embedded to have forward compatible implementations.
1744
type UnimplementedLightningServer struct {
1745
}
1746

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

1953
// UnsafeLightningServer may be embedded to opt out of forward compatibility for this service.
1954
// Use of this interface is not recommended, as added methods to LightningServer will
1955
// result in compilation errors.
1956
type UnsafeLightningServer interface {
1957
        mustEmbedUnimplementedLightningServer()
1958
}
1959

1960
func RegisterLightningServer(s grpc.ServiceRegistrar, srv LightningServer) {
1✔
1961
        s.RegisterService(&Lightning_ServiceDesc, srv)
1✔
1962
}
1✔
1963

1964
func _Lightning_WalletBalance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
1965
        in := new(WalletBalanceRequest)
1✔
1966
        if err := dec(in); err != nil {
1✔
1967
                return nil, err
×
1968
        }
×
1969
        if interceptor == nil {
1✔
1970
                return srv.(LightningServer).WalletBalance(ctx, in)
×
1971
        }
×
1972
        info := &grpc.UnaryServerInfo{
1✔
1973
                Server:     srv,
1✔
1974
                FullMethod: "/lnrpc.Lightning/WalletBalance",
1✔
1975
        }
1✔
1976
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
1977
                return srv.(LightningServer).WalletBalance(ctx, req.(*WalletBalanceRequest))
1✔
1978
        }
1✔
1979
        return interceptor(ctx, in, info, handler)
1✔
1980
}
1981

1982
func _Lightning_ChannelBalance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
1983
        in := new(ChannelBalanceRequest)
1✔
1984
        if err := dec(in); err != nil {
1✔
1985
                return nil, err
×
1986
        }
×
1987
        if interceptor == nil {
1✔
1988
                return srv.(LightningServer).ChannelBalance(ctx, in)
×
1989
        }
×
1990
        info := &grpc.UnaryServerInfo{
1✔
1991
                Server:     srv,
1✔
1992
                FullMethod: "/lnrpc.Lightning/ChannelBalance",
1✔
1993
        }
1✔
1994
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
1995
                return srv.(LightningServer).ChannelBalance(ctx, req.(*ChannelBalanceRequest))
1✔
1996
        }
1✔
1997
        return interceptor(ctx, in, info, handler)
1✔
1998
}
1999

2000
func _Lightning_GetTransactions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2001
        in := new(GetTransactionsRequest)
1✔
2002
        if err := dec(in); err != nil {
1✔
2003
                return nil, err
×
2004
        }
×
2005
        if interceptor == nil {
1✔
2006
                return srv.(LightningServer).GetTransactions(ctx, in)
×
2007
        }
×
2008
        info := &grpc.UnaryServerInfo{
1✔
2009
                Server:     srv,
1✔
2010
                FullMethod: "/lnrpc.Lightning/GetTransactions",
1✔
2011
        }
1✔
2012
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2013
                return srv.(LightningServer).GetTransactions(ctx, req.(*GetTransactionsRequest))
1✔
2014
        }
1✔
2015
        return interceptor(ctx, in, info, handler)
1✔
2016
}
2017

2018
func _Lightning_EstimateFee_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2019
        in := new(EstimateFeeRequest)
1✔
2020
        if err := dec(in); err != nil {
1✔
2021
                return nil, err
×
2022
        }
×
2023
        if interceptor == nil {
1✔
2024
                return srv.(LightningServer).EstimateFee(ctx, in)
×
2025
        }
×
2026
        info := &grpc.UnaryServerInfo{
1✔
2027
                Server:     srv,
1✔
2028
                FullMethod: "/lnrpc.Lightning/EstimateFee",
1✔
2029
        }
1✔
2030
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2031
                return srv.(LightningServer).EstimateFee(ctx, req.(*EstimateFeeRequest))
1✔
2032
        }
1✔
2033
        return interceptor(ctx, in, info, handler)
1✔
2034
}
2035

2036
func _Lightning_SendCoins_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2037
        in := new(SendCoinsRequest)
1✔
2038
        if err := dec(in); err != nil {
1✔
2039
                return nil, err
×
2040
        }
×
2041
        if interceptor == nil {
1✔
2042
                return srv.(LightningServer).SendCoins(ctx, in)
×
2043
        }
×
2044
        info := &grpc.UnaryServerInfo{
1✔
2045
                Server:     srv,
1✔
2046
                FullMethod: "/lnrpc.Lightning/SendCoins",
1✔
2047
        }
1✔
2048
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2049
                return srv.(LightningServer).SendCoins(ctx, req.(*SendCoinsRequest))
1✔
2050
        }
1✔
2051
        return interceptor(ctx, in, info, handler)
1✔
2052
}
2053

2054
func _Lightning_ListUnspent_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2055
        in := new(ListUnspentRequest)
×
2056
        if err := dec(in); err != nil {
×
2057
                return nil, err
×
2058
        }
×
2059
        if interceptor == nil {
×
2060
                return srv.(LightningServer).ListUnspent(ctx, in)
×
2061
        }
×
2062
        info := &grpc.UnaryServerInfo{
×
2063
                Server:     srv,
×
2064
                FullMethod: "/lnrpc.Lightning/ListUnspent",
×
2065
        }
×
2066
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2067
                return srv.(LightningServer).ListUnspent(ctx, req.(*ListUnspentRequest))
×
2068
        }
×
2069
        return interceptor(ctx, in, info, handler)
×
2070
}
2071

2072
func _Lightning_SubscribeTransactions_Handler(srv interface{}, stream grpc.ServerStream) error {
×
2073
        m := new(GetTransactionsRequest)
×
2074
        if err := stream.RecvMsg(m); err != nil {
×
2075
                return err
×
2076
        }
×
2077
        return srv.(LightningServer).SubscribeTransactions(m, &lightningSubscribeTransactionsServer{stream})
×
2078
}
2079

2080
type Lightning_SubscribeTransactionsServer interface {
2081
        Send(*Transaction) error
2082
        grpc.ServerStream
2083
}
2084

2085
type lightningSubscribeTransactionsServer struct {
2086
        grpc.ServerStream
2087
}
2088

2089
func (x *lightningSubscribeTransactionsServer) Send(m *Transaction) error {
×
2090
        return x.ServerStream.SendMsg(m)
×
2091
}
×
2092

2093
func _Lightning_SendMany_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2094
        in := new(SendManyRequest)
×
2095
        if err := dec(in); err != nil {
×
2096
                return nil, err
×
2097
        }
×
2098
        if interceptor == nil {
×
2099
                return srv.(LightningServer).SendMany(ctx, in)
×
2100
        }
×
2101
        info := &grpc.UnaryServerInfo{
×
2102
                Server:     srv,
×
2103
                FullMethod: "/lnrpc.Lightning/SendMany",
×
2104
        }
×
2105
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2106
                return srv.(LightningServer).SendMany(ctx, req.(*SendManyRequest))
×
2107
        }
×
2108
        return interceptor(ctx, in, info, handler)
×
2109
}
2110

2111
func _Lightning_NewAddress_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2112
        in := new(NewAddressRequest)
1✔
2113
        if err := dec(in); err != nil {
1✔
2114
                return nil, err
×
2115
        }
×
2116
        if interceptor == nil {
1✔
2117
                return srv.(LightningServer).NewAddress(ctx, in)
×
2118
        }
×
2119
        info := &grpc.UnaryServerInfo{
1✔
2120
                Server:     srv,
1✔
2121
                FullMethod: "/lnrpc.Lightning/NewAddress",
1✔
2122
        }
1✔
2123
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2124
                return srv.(LightningServer).NewAddress(ctx, req.(*NewAddressRequest))
1✔
2125
        }
1✔
2126
        return interceptor(ctx, in, info, handler)
1✔
2127
}
2128

2129
func _Lightning_SignMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2130
        in := new(SignMessageRequest)
1✔
2131
        if err := dec(in); err != nil {
1✔
2132
                return nil, err
×
2133
        }
×
2134
        if interceptor == nil {
1✔
2135
                return srv.(LightningServer).SignMessage(ctx, in)
×
2136
        }
×
2137
        info := &grpc.UnaryServerInfo{
1✔
2138
                Server:     srv,
1✔
2139
                FullMethod: "/lnrpc.Lightning/SignMessage",
1✔
2140
        }
1✔
2141
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2142
                return srv.(LightningServer).SignMessage(ctx, req.(*SignMessageRequest))
1✔
2143
        }
1✔
2144
        return interceptor(ctx, in, info, handler)
1✔
2145
}
2146

2147
func _Lightning_VerifyMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2148
        in := new(VerifyMessageRequest)
1✔
2149
        if err := dec(in); err != nil {
1✔
2150
                return nil, err
×
2151
        }
×
2152
        if interceptor == nil {
1✔
2153
                return srv.(LightningServer).VerifyMessage(ctx, in)
×
2154
        }
×
2155
        info := &grpc.UnaryServerInfo{
1✔
2156
                Server:     srv,
1✔
2157
                FullMethod: "/lnrpc.Lightning/VerifyMessage",
1✔
2158
        }
1✔
2159
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2160
                return srv.(LightningServer).VerifyMessage(ctx, req.(*VerifyMessageRequest))
1✔
2161
        }
1✔
2162
        return interceptor(ctx, in, info, handler)
1✔
2163
}
2164

2165
func _Lightning_ConnectPeer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2166
        in := new(ConnectPeerRequest)
1✔
2167
        if err := dec(in); err != nil {
1✔
2168
                return nil, err
×
2169
        }
×
2170
        if interceptor == nil {
1✔
2171
                return srv.(LightningServer).ConnectPeer(ctx, in)
×
2172
        }
×
2173
        info := &grpc.UnaryServerInfo{
1✔
2174
                Server:     srv,
1✔
2175
                FullMethod: "/lnrpc.Lightning/ConnectPeer",
1✔
2176
        }
1✔
2177
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2178
                return srv.(LightningServer).ConnectPeer(ctx, req.(*ConnectPeerRequest))
1✔
2179
        }
1✔
2180
        return interceptor(ctx, in, info, handler)
1✔
2181
}
2182

2183
func _Lightning_DisconnectPeer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2184
        in := new(DisconnectPeerRequest)
1✔
2185
        if err := dec(in); err != nil {
1✔
2186
                return nil, err
×
2187
        }
×
2188
        if interceptor == nil {
1✔
2189
                return srv.(LightningServer).DisconnectPeer(ctx, in)
×
2190
        }
×
2191
        info := &grpc.UnaryServerInfo{
1✔
2192
                Server:     srv,
1✔
2193
                FullMethod: "/lnrpc.Lightning/DisconnectPeer",
1✔
2194
        }
1✔
2195
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2196
                return srv.(LightningServer).DisconnectPeer(ctx, req.(*DisconnectPeerRequest))
1✔
2197
        }
1✔
2198
        return interceptor(ctx, in, info, handler)
1✔
2199
}
2200

2201
func _Lightning_ListPeers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2202
        in := new(ListPeersRequest)
1✔
2203
        if err := dec(in); err != nil {
1✔
2204
                return nil, err
×
2205
        }
×
2206
        if interceptor == nil {
1✔
2207
                return srv.(LightningServer).ListPeers(ctx, in)
×
2208
        }
×
2209
        info := &grpc.UnaryServerInfo{
1✔
2210
                Server:     srv,
1✔
2211
                FullMethod: "/lnrpc.Lightning/ListPeers",
1✔
2212
        }
1✔
2213
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2214
                return srv.(LightningServer).ListPeers(ctx, req.(*ListPeersRequest))
1✔
2215
        }
1✔
2216
        return interceptor(ctx, in, info, handler)
1✔
2217
}
2218

2219
func _Lightning_SubscribePeerEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
2220
        m := new(PeerEventSubscription)
1✔
2221
        if err := stream.RecvMsg(m); err != nil {
1✔
2222
                return err
×
2223
        }
×
2224
        return srv.(LightningServer).SubscribePeerEvents(m, &lightningSubscribePeerEventsServer{stream})
1✔
2225
}
2226

2227
type Lightning_SubscribePeerEventsServer interface {
2228
        Send(*PeerEvent) error
2229
        grpc.ServerStream
2230
}
2231

2232
type lightningSubscribePeerEventsServer struct {
2233
        grpc.ServerStream
2234
}
2235

2236
func (x *lightningSubscribePeerEventsServer) Send(m *PeerEvent) error {
1✔
2237
        return x.ServerStream.SendMsg(m)
1✔
2238
}
1✔
2239

2240
func _Lightning_GetInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2241
        in := new(GetInfoRequest)
1✔
2242
        if err := dec(in); err != nil {
1✔
2243
                return nil, err
×
2244
        }
×
2245
        if interceptor == nil {
1✔
2246
                return srv.(LightningServer).GetInfo(ctx, in)
×
2247
        }
×
2248
        info := &grpc.UnaryServerInfo{
1✔
2249
                Server:     srv,
1✔
2250
                FullMethod: "/lnrpc.Lightning/GetInfo",
1✔
2251
        }
1✔
2252
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2253
                return srv.(LightningServer).GetInfo(ctx, req.(*GetInfoRequest))
1✔
2254
        }
1✔
2255
        return interceptor(ctx, in, info, handler)
1✔
2256
}
2257

2258
func _Lightning_GetDebugInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2259
        in := new(GetDebugInfoRequest)
×
2260
        if err := dec(in); err != nil {
×
2261
                return nil, err
×
2262
        }
×
2263
        if interceptor == nil {
×
2264
                return srv.(LightningServer).GetDebugInfo(ctx, in)
×
2265
        }
×
2266
        info := &grpc.UnaryServerInfo{
×
2267
                Server:     srv,
×
2268
                FullMethod: "/lnrpc.Lightning/GetDebugInfo",
×
2269
        }
×
2270
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2271
                return srv.(LightningServer).GetDebugInfo(ctx, req.(*GetDebugInfoRequest))
×
2272
        }
×
2273
        return interceptor(ctx, in, info, handler)
×
2274
}
2275

2276
func _Lightning_GetRecoveryInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2277
        in := new(GetRecoveryInfoRequest)
1✔
2278
        if err := dec(in); err != nil {
1✔
2279
                return nil, err
×
2280
        }
×
2281
        if interceptor == nil {
1✔
2282
                return srv.(LightningServer).GetRecoveryInfo(ctx, in)
×
2283
        }
×
2284
        info := &grpc.UnaryServerInfo{
1✔
2285
                Server:     srv,
1✔
2286
                FullMethod: "/lnrpc.Lightning/GetRecoveryInfo",
1✔
2287
        }
1✔
2288
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2289
                return srv.(LightningServer).GetRecoveryInfo(ctx, req.(*GetRecoveryInfoRequest))
1✔
2290
        }
1✔
2291
        return interceptor(ctx, in, info, handler)
1✔
2292
}
2293

2294
func _Lightning_PendingChannels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2295
        in := new(PendingChannelsRequest)
1✔
2296
        if err := dec(in); err != nil {
1✔
2297
                return nil, err
×
2298
        }
×
2299
        if interceptor == nil {
1✔
2300
                return srv.(LightningServer).PendingChannels(ctx, in)
×
2301
        }
×
2302
        info := &grpc.UnaryServerInfo{
1✔
2303
                Server:     srv,
1✔
2304
                FullMethod: "/lnrpc.Lightning/PendingChannels",
1✔
2305
        }
1✔
2306
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2307
                return srv.(LightningServer).PendingChannels(ctx, req.(*PendingChannelsRequest))
1✔
2308
        }
1✔
2309
        return interceptor(ctx, in, info, handler)
1✔
2310
}
2311

2312
func _Lightning_ListChannels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2313
        in := new(ListChannelsRequest)
1✔
2314
        if err := dec(in); err != nil {
1✔
2315
                return nil, err
×
2316
        }
×
2317
        if interceptor == nil {
1✔
2318
                return srv.(LightningServer).ListChannels(ctx, in)
×
2319
        }
×
2320
        info := &grpc.UnaryServerInfo{
1✔
2321
                Server:     srv,
1✔
2322
                FullMethod: "/lnrpc.Lightning/ListChannels",
1✔
2323
        }
1✔
2324
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2325
                return srv.(LightningServer).ListChannels(ctx, req.(*ListChannelsRequest))
1✔
2326
        }
1✔
2327
        return interceptor(ctx, in, info, handler)
1✔
2328
}
2329

2330
func _Lightning_SubscribeChannelEvents_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
2331
        m := new(ChannelEventSubscription)
1✔
2332
        if err := stream.RecvMsg(m); err != nil {
1✔
2333
                return err
×
2334
        }
×
2335
        return srv.(LightningServer).SubscribeChannelEvents(m, &lightningSubscribeChannelEventsServer{stream})
1✔
2336
}
2337

2338
type Lightning_SubscribeChannelEventsServer interface {
2339
        Send(*ChannelEventUpdate) error
2340
        grpc.ServerStream
2341
}
2342

2343
type lightningSubscribeChannelEventsServer struct {
2344
        grpc.ServerStream
2345
}
2346

2347
func (x *lightningSubscribeChannelEventsServer) Send(m *ChannelEventUpdate) error {
1✔
2348
        return x.ServerStream.SendMsg(m)
1✔
2349
}
1✔
2350

2351
func _Lightning_ClosedChannels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2352
        in := new(ClosedChannelsRequest)
1✔
2353
        if err := dec(in); err != nil {
1✔
2354
                return nil, err
×
2355
        }
×
2356
        if interceptor == nil {
1✔
2357
                return srv.(LightningServer).ClosedChannels(ctx, in)
×
2358
        }
×
2359
        info := &grpc.UnaryServerInfo{
1✔
2360
                Server:     srv,
1✔
2361
                FullMethod: "/lnrpc.Lightning/ClosedChannels",
1✔
2362
        }
1✔
2363
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2364
                return srv.(LightningServer).ClosedChannels(ctx, req.(*ClosedChannelsRequest))
1✔
2365
        }
1✔
2366
        return interceptor(ctx, in, info, handler)
1✔
2367
}
2368

2369
func _Lightning_OpenChannelSync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2370
        in := new(OpenChannelRequest)
×
2371
        if err := dec(in); err != nil {
×
2372
                return nil, err
×
2373
        }
×
2374
        if interceptor == nil {
×
2375
                return srv.(LightningServer).OpenChannelSync(ctx, in)
×
2376
        }
×
2377
        info := &grpc.UnaryServerInfo{
×
2378
                Server:     srv,
×
2379
                FullMethod: "/lnrpc.Lightning/OpenChannelSync",
×
2380
        }
×
2381
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2382
                return srv.(LightningServer).OpenChannelSync(ctx, req.(*OpenChannelRequest))
×
2383
        }
×
2384
        return interceptor(ctx, in, info, handler)
×
2385
}
2386

2387
func _Lightning_OpenChannel_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
2388
        m := new(OpenChannelRequest)
1✔
2389
        if err := stream.RecvMsg(m); err != nil {
1✔
2390
                return err
×
2391
        }
×
2392
        return srv.(LightningServer).OpenChannel(m, &lightningOpenChannelServer{stream})
1✔
2393
}
2394

2395
type Lightning_OpenChannelServer interface {
2396
        Send(*OpenStatusUpdate) error
2397
        grpc.ServerStream
2398
}
2399

2400
type lightningOpenChannelServer struct {
2401
        grpc.ServerStream
2402
}
2403

2404
func (x *lightningOpenChannelServer) Send(m *OpenStatusUpdate) error {
1✔
2405
        return x.ServerStream.SendMsg(m)
1✔
2406
}
1✔
2407

2408
func _Lightning_BatchOpenChannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2409
        in := new(BatchOpenChannelRequest)
1✔
2410
        if err := dec(in); err != nil {
1✔
2411
                return nil, err
×
2412
        }
×
2413
        if interceptor == nil {
1✔
2414
                return srv.(LightningServer).BatchOpenChannel(ctx, in)
×
2415
        }
×
2416
        info := &grpc.UnaryServerInfo{
1✔
2417
                Server:     srv,
1✔
2418
                FullMethod: "/lnrpc.Lightning/BatchOpenChannel",
1✔
2419
        }
1✔
2420
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2421
                return srv.(LightningServer).BatchOpenChannel(ctx, req.(*BatchOpenChannelRequest))
1✔
2422
        }
1✔
2423
        return interceptor(ctx, in, info, handler)
1✔
2424
}
2425

2426
func _Lightning_FundingStateStep_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2427
        in := new(FundingTransitionMsg)
1✔
2428
        if err := dec(in); err != nil {
1✔
2429
                return nil, err
×
2430
        }
×
2431
        if interceptor == nil {
1✔
2432
                return srv.(LightningServer).FundingStateStep(ctx, in)
×
2433
        }
×
2434
        info := &grpc.UnaryServerInfo{
1✔
2435
                Server:     srv,
1✔
2436
                FullMethod: "/lnrpc.Lightning/FundingStateStep",
1✔
2437
        }
1✔
2438
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2439
                return srv.(LightningServer).FundingStateStep(ctx, req.(*FundingTransitionMsg))
1✔
2440
        }
1✔
2441
        return interceptor(ctx, in, info, handler)
1✔
2442
}
2443

2444
func _Lightning_ChannelAcceptor_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
2445
        return srv.(LightningServer).ChannelAcceptor(&lightningChannelAcceptorServer{stream})
1✔
2446
}
1✔
2447

2448
type Lightning_ChannelAcceptorServer interface {
2449
        Send(*ChannelAcceptRequest) error
2450
        Recv() (*ChannelAcceptResponse, error)
2451
        grpc.ServerStream
2452
}
2453

2454
type lightningChannelAcceptorServer struct {
2455
        grpc.ServerStream
2456
}
2457

2458
func (x *lightningChannelAcceptorServer) Send(m *ChannelAcceptRequest) error {
1✔
2459
        return x.ServerStream.SendMsg(m)
1✔
2460
}
1✔
2461

2462
func (x *lightningChannelAcceptorServer) Recv() (*ChannelAcceptResponse, error) {
1✔
2463
        m := new(ChannelAcceptResponse)
1✔
2464
        if err := x.ServerStream.RecvMsg(m); err != nil {
2✔
2465
                return nil, err
1✔
2466
        }
1✔
2467
        return m, nil
1✔
2468
}
2469

2470
func _Lightning_CloseChannel_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
2471
        m := new(CloseChannelRequest)
1✔
2472
        if err := stream.RecvMsg(m); err != nil {
1✔
2473
                return err
×
2474
        }
×
2475
        return srv.(LightningServer).CloseChannel(m, &lightningCloseChannelServer{stream})
1✔
2476
}
2477

2478
type Lightning_CloseChannelServer interface {
2479
        Send(*CloseStatusUpdate) error
2480
        grpc.ServerStream
2481
}
2482

2483
type lightningCloseChannelServer struct {
2484
        grpc.ServerStream
2485
}
2486

2487
func (x *lightningCloseChannelServer) Send(m *CloseStatusUpdate) error {
1✔
2488
        return x.ServerStream.SendMsg(m)
1✔
2489
}
1✔
2490

2491
func _Lightning_AbandonChannel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2492
        in := new(AbandonChannelRequest)
1✔
2493
        if err := dec(in); err != nil {
1✔
2494
                return nil, err
×
2495
        }
×
2496
        if interceptor == nil {
1✔
2497
                return srv.(LightningServer).AbandonChannel(ctx, in)
×
2498
        }
×
2499
        info := &grpc.UnaryServerInfo{
1✔
2500
                Server:     srv,
1✔
2501
                FullMethod: "/lnrpc.Lightning/AbandonChannel",
1✔
2502
        }
1✔
2503
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2504
                return srv.(LightningServer).AbandonChannel(ctx, req.(*AbandonChannelRequest))
1✔
2505
        }
1✔
2506
        return interceptor(ctx, in, info, handler)
1✔
2507
}
2508

2509
func _Lightning_SendPayment_Handler(srv interface{}, stream grpc.ServerStream) error {
×
2510
        return srv.(LightningServer).SendPayment(&lightningSendPaymentServer{stream})
×
2511
}
×
2512

2513
type Lightning_SendPaymentServer interface {
2514
        Send(*SendResponse) error
2515
        Recv() (*SendRequest, error)
2516
        grpc.ServerStream
2517
}
2518

2519
type lightningSendPaymentServer struct {
2520
        grpc.ServerStream
2521
}
2522

2523
func (x *lightningSendPaymentServer) Send(m *SendResponse) error {
×
2524
        return x.ServerStream.SendMsg(m)
×
2525
}
×
2526

2527
func (x *lightningSendPaymentServer) Recv() (*SendRequest, error) {
×
2528
        m := new(SendRequest)
×
2529
        if err := x.ServerStream.RecvMsg(m); err != nil {
×
2530
                return nil, err
×
2531
        }
×
2532
        return m, nil
×
2533
}
2534

2535
func _Lightning_SendPaymentSync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2536
        in := new(SendRequest)
×
2537
        if err := dec(in); err != nil {
×
2538
                return nil, err
×
2539
        }
×
2540
        if interceptor == nil {
×
2541
                return srv.(LightningServer).SendPaymentSync(ctx, in)
×
2542
        }
×
2543
        info := &grpc.UnaryServerInfo{
×
2544
                Server:     srv,
×
2545
                FullMethod: "/lnrpc.Lightning/SendPaymentSync",
×
2546
        }
×
2547
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2548
                return srv.(LightningServer).SendPaymentSync(ctx, req.(*SendRequest))
×
2549
        }
×
2550
        return interceptor(ctx, in, info, handler)
×
2551
}
2552

2553
func _Lightning_SendToRoute_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
2554
        return srv.(LightningServer).SendToRoute(&lightningSendToRouteServer{stream})
1✔
2555
}
1✔
2556

2557
type Lightning_SendToRouteServer interface {
2558
        Send(*SendResponse) error
2559
        Recv() (*SendToRouteRequest, error)
2560
        grpc.ServerStream
2561
}
2562

2563
type lightningSendToRouteServer struct {
2564
        grpc.ServerStream
2565
}
2566

2567
func (x *lightningSendToRouteServer) Send(m *SendResponse) error {
1✔
2568
        return x.ServerStream.SendMsg(m)
1✔
2569
}
1✔
2570

2571
func (x *lightningSendToRouteServer) Recv() (*SendToRouteRequest, error) {
1✔
2572
        m := new(SendToRouteRequest)
1✔
2573
        if err := x.ServerStream.RecvMsg(m); err != nil {
2✔
2574
                return nil, err
1✔
2575
        }
1✔
2576
        return m, nil
1✔
2577
}
2578

2579
func _Lightning_SendToRouteSync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2580
        in := new(SendToRouteRequest)
1✔
2581
        if err := dec(in); err != nil {
1✔
2582
                return nil, err
×
2583
        }
×
2584
        if interceptor == nil {
1✔
2585
                return srv.(LightningServer).SendToRouteSync(ctx, in)
×
2586
        }
×
2587
        info := &grpc.UnaryServerInfo{
1✔
2588
                Server:     srv,
1✔
2589
                FullMethod: "/lnrpc.Lightning/SendToRouteSync",
1✔
2590
        }
1✔
2591
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2592
                return srv.(LightningServer).SendToRouteSync(ctx, req.(*SendToRouteRequest))
1✔
2593
        }
1✔
2594
        return interceptor(ctx, in, info, handler)
1✔
2595
}
2596

2597
func _Lightning_AddInvoice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2598
        in := new(Invoice)
1✔
2599
        if err := dec(in); err != nil {
1✔
2600
                return nil, err
×
2601
        }
×
2602
        if interceptor == nil {
1✔
2603
                return srv.(LightningServer).AddInvoice(ctx, in)
×
2604
        }
×
2605
        info := &grpc.UnaryServerInfo{
1✔
2606
                Server:     srv,
1✔
2607
                FullMethod: "/lnrpc.Lightning/AddInvoice",
1✔
2608
        }
1✔
2609
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2610
                return srv.(LightningServer).AddInvoice(ctx, req.(*Invoice))
1✔
2611
        }
1✔
2612
        return interceptor(ctx, in, info, handler)
1✔
2613
}
2614

2615
func _Lightning_ListInvoices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2616
        in := new(ListInvoiceRequest)
1✔
2617
        if err := dec(in); err != nil {
1✔
2618
                return nil, err
×
2619
        }
×
2620
        if interceptor == nil {
1✔
2621
                return srv.(LightningServer).ListInvoices(ctx, in)
×
2622
        }
×
2623
        info := &grpc.UnaryServerInfo{
1✔
2624
                Server:     srv,
1✔
2625
                FullMethod: "/lnrpc.Lightning/ListInvoices",
1✔
2626
        }
1✔
2627
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2628
                return srv.(LightningServer).ListInvoices(ctx, req.(*ListInvoiceRequest))
1✔
2629
        }
1✔
2630
        return interceptor(ctx, in, info, handler)
1✔
2631
}
2632

2633
func _Lightning_LookupInvoice_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2634
        in := new(PaymentHash)
1✔
2635
        if err := dec(in); err != nil {
1✔
2636
                return nil, err
×
2637
        }
×
2638
        if interceptor == nil {
1✔
2639
                return srv.(LightningServer).LookupInvoice(ctx, in)
×
2640
        }
×
2641
        info := &grpc.UnaryServerInfo{
1✔
2642
                Server:     srv,
1✔
2643
                FullMethod: "/lnrpc.Lightning/LookupInvoice",
1✔
2644
        }
1✔
2645
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2646
                return srv.(LightningServer).LookupInvoice(ctx, req.(*PaymentHash))
1✔
2647
        }
1✔
2648
        return interceptor(ctx, in, info, handler)
1✔
2649
}
2650

2651
func _Lightning_SubscribeInvoices_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
2652
        m := new(InvoiceSubscription)
1✔
2653
        if err := stream.RecvMsg(m); err != nil {
1✔
2654
                return err
×
2655
        }
×
2656
        return srv.(LightningServer).SubscribeInvoices(m, &lightningSubscribeInvoicesServer{stream})
1✔
2657
}
2658

2659
type Lightning_SubscribeInvoicesServer interface {
2660
        Send(*Invoice) error
2661
        grpc.ServerStream
2662
}
2663

2664
type lightningSubscribeInvoicesServer struct {
2665
        grpc.ServerStream
2666
}
2667

2668
func (x *lightningSubscribeInvoicesServer) Send(m *Invoice) error {
1✔
2669
        return x.ServerStream.SendMsg(m)
1✔
2670
}
1✔
2671

2672
func _Lightning_DecodePayReq_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2673
        in := new(PayReqString)
1✔
2674
        if err := dec(in); err != nil {
1✔
2675
                return nil, err
×
2676
        }
×
2677
        if interceptor == nil {
1✔
2678
                return srv.(LightningServer).DecodePayReq(ctx, in)
×
2679
        }
×
2680
        info := &grpc.UnaryServerInfo{
1✔
2681
                Server:     srv,
1✔
2682
                FullMethod: "/lnrpc.Lightning/DecodePayReq",
1✔
2683
        }
1✔
2684
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2685
                return srv.(LightningServer).DecodePayReq(ctx, req.(*PayReqString))
1✔
2686
        }
1✔
2687
        return interceptor(ctx, in, info, handler)
1✔
2688
}
2689

2690
func _Lightning_ListPayments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2691
        in := new(ListPaymentsRequest)
1✔
2692
        if err := dec(in); err != nil {
1✔
2693
                return nil, err
×
2694
        }
×
2695
        if interceptor == nil {
1✔
2696
                return srv.(LightningServer).ListPayments(ctx, in)
×
2697
        }
×
2698
        info := &grpc.UnaryServerInfo{
1✔
2699
                Server:     srv,
1✔
2700
                FullMethod: "/lnrpc.Lightning/ListPayments",
1✔
2701
        }
1✔
2702
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2703
                return srv.(LightningServer).ListPayments(ctx, req.(*ListPaymentsRequest))
1✔
2704
        }
1✔
2705
        return interceptor(ctx, in, info, handler)
1✔
2706
}
2707

2708
func _Lightning_DeletePayment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2709
        in := new(DeletePaymentRequest)
×
2710
        if err := dec(in); err != nil {
×
2711
                return nil, err
×
2712
        }
×
2713
        if interceptor == nil {
×
2714
                return srv.(LightningServer).DeletePayment(ctx, in)
×
2715
        }
×
2716
        info := &grpc.UnaryServerInfo{
×
2717
                Server:     srv,
×
2718
                FullMethod: "/lnrpc.Lightning/DeletePayment",
×
2719
        }
×
2720
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2721
                return srv.(LightningServer).DeletePayment(ctx, req.(*DeletePaymentRequest))
×
2722
        }
×
2723
        return interceptor(ctx, in, info, handler)
×
2724
}
2725

2726
func _Lightning_DeleteAllPayments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2727
        in := new(DeleteAllPaymentsRequest)
1✔
2728
        if err := dec(in); err != nil {
1✔
2729
                return nil, err
×
2730
        }
×
2731
        if interceptor == nil {
1✔
2732
                return srv.(LightningServer).DeleteAllPayments(ctx, in)
×
2733
        }
×
2734
        info := &grpc.UnaryServerInfo{
1✔
2735
                Server:     srv,
1✔
2736
                FullMethod: "/lnrpc.Lightning/DeleteAllPayments",
1✔
2737
        }
1✔
2738
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2739
                return srv.(LightningServer).DeleteAllPayments(ctx, req.(*DeleteAllPaymentsRequest))
1✔
2740
        }
1✔
2741
        return interceptor(ctx, in, info, handler)
1✔
2742
}
2743

2744
func _Lightning_DescribeGraph_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2745
        in := new(ChannelGraphRequest)
1✔
2746
        if err := dec(in); err != nil {
1✔
2747
                return nil, err
×
2748
        }
×
2749
        if interceptor == nil {
1✔
2750
                return srv.(LightningServer).DescribeGraph(ctx, in)
×
2751
        }
×
2752
        info := &grpc.UnaryServerInfo{
1✔
2753
                Server:     srv,
1✔
2754
                FullMethod: "/lnrpc.Lightning/DescribeGraph",
1✔
2755
        }
1✔
2756
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2757
                return srv.(LightningServer).DescribeGraph(ctx, req.(*ChannelGraphRequest))
1✔
2758
        }
1✔
2759
        return interceptor(ctx, in, info, handler)
1✔
2760
}
2761

2762
func _Lightning_GetNodeMetrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2763
        in := new(NodeMetricsRequest)
×
2764
        if err := dec(in); err != nil {
×
2765
                return nil, err
×
2766
        }
×
2767
        if interceptor == nil {
×
2768
                return srv.(LightningServer).GetNodeMetrics(ctx, in)
×
2769
        }
×
2770
        info := &grpc.UnaryServerInfo{
×
2771
                Server:     srv,
×
2772
                FullMethod: "/lnrpc.Lightning/GetNodeMetrics",
×
2773
        }
×
2774
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2775
                return srv.(LightningServer).GetNodeMetrics(ctx, req.(*NodeMetricsRequest))
×
2776
        }
×
2777
        return interceptor(ctx, in, info, handler)
×
2778
}
2779

2780
func _Lightning_GetChanInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2781
        in := new(ChanInfoRequest)
1✔
2782
        if err := dec(in); err != nil {
1✔
2783
                return nil, err
×
2784
        }
×
2785
        if interceptor == nil {
1✔
2786
                return srv.(LightningServer).GetChanInfo(ctx, in)
×
2787
        }
×
2788
        info := &grpc.UnaryServerInfo{
1✔
2789
                Server:     srv,
1✔
2790
                FullMethod: "/lnrpc.Lightning/GetChanInfo",
1✔
2791
        }
1✔
2792
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2793
                return srv.(LightningServer).GetChanInfo(ctx, req.(*ChanInfoRequest))
1✔
2794
        }
1✔
2795
        return interceptor(ctx, in, info, handler)
1✔
2796
}
2797

2798
func _Lightning_GetNodeInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2799
        in := new(NodeInfoRequest)
×
2800
        if err := dec(in); err != nil {
×
2801
                return nil, err
×
2802
        }
×
2803
        if interceptor == nil {
×
2804
                return srv.(LightningServer).GetNodeInfo(ctx, in)
×
2805
        }
×
2806
        info := &grpc.UnaryServerInfo{
×
2807
                Server:     srv,
×
2808
                FullMethod: "/lnrpc.Lightning/GetNodeInfo",
×
2809
        }
×
2810
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2811
                return srv.(LightningServer).GetNodeInfo(ctx, req.(*NodeInfoRequest))
×
2812
        }
×
2813
        return interceptor(ctx, in, info, handler)
×
2814
}
2815

2816
func _Lightning_QueryRoutes_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2817
        in := new(QueryRoutesRequest)
1✔
2818
        if err := dec(in); err != nil {
1✔
2819
                return nil, err
×
2820
        }
×
2821
        if interceptor == nil {
1✔
2822
                return srv.(LightningServer).QueryRoutes(ctx, in)
×
2823
        }
×
2824
        info := &grpc.UnaryServerInfo{
1✔
2825
                Server:     srv,
1✔
2826
                FullMethod: "/lnrpc.Lightning/QueryRoutes",
1✔
2827
        }
1✔
2828
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2829
                return srv.(LightningServer).QueryRoutes(ctx, req.(*QueryRoutesRequest))
1✔
2830
        }
1✔
2831
        return interceptor(ctx, in, info, handler)
1✔
2832
}
2833

2834
func _Lightning_GetNetworkInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2835
        in := new(NetworkInfoRequest)
×
2836
        if err := dec(in); err != nil {
×
2837
                return nil, err
×
2838
        }
×
2839
        if interceptor == nil {
×
2840
                return srv.(LightningServer).GetNetworkInfo(ctx, in)
×
2841
        }
×
2842
        info := &grpc.UnaryServerInfo{
×
2843
                Server:     srv,
×
2844
                FullMethod: "/lnrpc.Lightning/GetNetworkInfo",
×
2845
        }
×
2846
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2847
                return srv.(LightningServer).GetNetworkInfo(ctx, req.(*NetworkInfoRequest))
×
2848
        }
×
2849
        return interceptor(ctx, in, info, handler)
×
2850
}
2851

2852
func _Lightning_StopDaemon_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2853
        in := new(StopRequest)
1✔
2854
        if err := dec(in); err != nil {
1✔
2855
                return nil, err
×
2856
        }
×
2857
        if interceptor == nil {
1✔
2858
                return srv.(LightningServer).StopDaemon(ctx, in)
×
2859
        }
×
2860
        info := &grpc.UnaryServerInfo{
1✔
2861
                Server:     srv,
1✔
2862
                FullMethod: "/lnrpc.Lightning/StopDaemon",
1✔
2863
        }
1✔
2864
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2865
                return srv.(LightningServer).StopDaemon(ctx, req.(*StopRequest))
1✔
2866
        }
1✔
2867
        return interceptor(ctx, in, info, handler)
1✔
2868
}
2869

2870
func _Lightning_SubscribeChannelGraph_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
2871
        m := new(GraphTopologySubscription)
1✔
2872
        if err := stream.RecvMsg(m); err != nil {
1✔
UNCOV
2873
                return err
×
UNCOV
2874
        }
×
2875
        return srv.(LightningServer).SubscribeChannelGraph(m, &lightningSubscribeChannelGraphServer{stream})
1✔
2876
}
2877

2878
type Lightning_SubscribeChannelGraphServer interface {
2879
        Send(*GraphTopologyUpdate) error
2880
        grpc.ServerStream
2881
}
2882

2883
type lightningSubscribeChannelGraphServer struct {
2884
        grpc.ServerStream
2885
}
2886

2887
func (x *lightningSubscribeChannelGraphServer) Send(m *GraphTopologyUpdate) error {
1✔
2888
        return x.ServerStream.SendMsg(m)
1✔
2889
}
1✔
2890

2891
func _Lightning_DebugLevel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
2892
        in := new(DebugLevelRequest)
×
2893
        if err := dec(in); err != nil {
×
2894
                return nil, err
×
2895
        }
×
2896
        if interceptor == nil {
×
2897
                return srv.(LightningServer).DebugLevel(ctx, in)
×
2898
        }
×
2899
        info := &grpc.UnaryServerInfo{
×
2900
                Server:     srv,
×
2901
                FullMethod: "/lnrpc.Lightning/DebugLevel",
×
2902
        }
×
2903
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
2904
                return srv.(LightningServer).DebugLevel(ctx, req.(*DebugLevelRequest))
×
2905
        }
×
2906
        return interceptor(ctx, in, info, handler)
×
2907
}
2908

2909
func _Lightning_FeeReport_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2910
        in := new(FeeReportRequest)
1✔
2911
        if err := dec(in); err != nil {
1✔
2912
                return nil, err
×
2913
        }
×
2914
        if interceptor == nil {
1✔
2915
                return srv.(LightningServer).FeeReport(ctx, in)
×
2916
        }
×
2917
        info := &grpc.UnaryServerInfo{
1✔
2918
                Server:     srv,
1✔
2919
                FullMethod: "/lnrpc.Lightning/FeeReport",
1✔
2920
        }
1✔
2921
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2922
                return srv.(LightningServer).FeeReport(ctx, req.(*FeeReportRequest))
1✔
2923
        }
1✔
2924
        return interceptor(ctx, in, info, handler)
1✔
2925
}
2926

2927
func _Lightning_UpdateChannelPolicy_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2928
        in := new(PolicyUpdateRequest)
1✔
2929
        if err := dec(in); err != nil {
1✔
2930
                return nil, err
×
2931
        }
×
2932
        if interceptor == nil {
1✔
2933
                return srv.(LightningServer).UpdateChannelPolicy(ctx, in)
×
2934
        }
×
2935
        info := &grpc.UnaryServerInfo{
1✔
2936
                Server:     srv,
1✔
2937
                FullMethod: "/lnrpc.Lightning/UpdateChannelPolicy",
1✔
2938
        }
1✔
2939
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2940
                return srv.(LightningServer).UpdateChannelPolicy(ctx, req.(*PolicyUpdateRequest))
1✔
2941
        }
1✔
2942
        return interceptor(ctx, in, info, handler)
1✔
2943
}
2944

2945
func _Lightning_ForwardingHistory_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2946
        in := new(ForwardingHistoryRequest)
1✔
2947
        if err := dec(in); err != nil {
1✔
2948
                return nil, err
×
2949
        }
×
2950
        if interceptor == nil {
1✔
2951
                return srv.(LightningServer).ForwardingHistory(ctx, in)
×
2952
        }
×
2953
        info := &grpc.UnaryServerInfo{
1✔
2954
                Server:     srv,
1✔
2955
                FullMethod: "/lnrpc.Lightning/ForwardingHistory",
1✔
2956
        }
1✔
2957
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2958
                return srv.(LightningServer).ForwardingHistory(ctx, req.(*ForwardingHistoryRequest))
1✔
2959
        }
1✔
2960
        return interceptor(ctx, in, info, handler)
1✔
2961
}
2962

2963
func _Lightning_ExportChannelBackup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2964
        in := new(ExportChannelBackupRequest)
1✔
2965
        if err := dec(in); err != nil {
1✔
2966
                return nil, err
×
2967
        }
×
2968
        if interceptor == nil {
1✔
2969
                return srv.(LightningServer).ExportChannelBackup(ctx, in)
×
2970
        }
×
2971
        info := &grpc.UnaryServerInfo{
1✔
2972
                Server:     srv,
1✔
2973
                FullMethod: "/lnrpc.Lightning/ExportChannelBackup",
1✔
2974
        }
1✔
2975
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2976
                return srv.(LightningServer).ExportChannelBackup(ctx, req.(*ExportChannelBackupRequest))
1✔
2977
        }
1✔
2978
        return interceptor(ctx, in, info, handler)
1✔
2979
}
2980

2981
func _Lightning_ExportAllChannelBackups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
2982
        in := new(ChanBackupExportRequest)
1✔
2983
        if err := dec(in); err != nil {
1✔
2984
                return nil, err
×
2985
        }
×
2986
        if interceptor == nil {
1✔
2987
                return srv.(LightningServer).ExportAllChannelBackups(ctx, in)
×
2988
        }
×
2989
        info := &grpc.UnaryServerInfo{
1✔
2990
                Server:     srv,
1✔
2991
                FullMethod: "/lnrpc.Lightning/ExportAllChannelBackups",
1✔
2992
        }
1✔
2993
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
2994
                return srv.(LightningServer).ExportAllChannelBackups(ctx, req.(*ChanBackupExportRequest))
1✔
2995
        }
1✔
2996
        return interceptor(ctx, in, info, handler)
1✔
2997
}
2998

2999
func _Lightning_VerifyChanBackup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3000
        in := new(ChanBackupSnapshot)
1✔
3001
        if err := dec(in); err != nil {
1✔
3002
                return nil, err
×
3003
        }
×
3004
        if interceptor == nil {
1✔
3005
                return srv.(LightningServer).VerifyChanBackup(ctx, in)
×
3006
        }
×
3007
        info := &grpc.UnaryServerInfo{
1✔
3008
                Server:     srv,
1✔
3009
                FullMethod: "/lnrpc.Lightning/VerifyChanBackup",
1✔
3010
        }
1✔
3011
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3012
                return srv.(LightningServer).VerifyChanBackup(ctx, req.(*ChanBackupSnapshot))
1✔
3013
        }
1✔
3014
        return interceptor(ctx, in, info, handler)
1✔
3015
}
3016

3017
func _Lightning_RestoreChannelBackups_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3018
        in := new(RestoreChanBackupRequest)
1✔
3019
        if err := dec(in); err != nil {
1✔
3020
                return nil, err
×
3021
        }
×
3022
        if interceptor == nil {
1✔
3023
                return srv.(LightningServer).RestoreChannelBackups(ctx, in)
×
3024
        }
×
3025
        info := &grpc.UnaryServerInfo{
1✔
3026
                Server:     srv,
1✔
3027
                FullMethod: "/lnrpc.Lightning/RestoreChannelBackups",
1✔
3028
        }
1✔
3029
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3030
                return srv.(LightningServer).RestoreChannelBackups(ctx, req.(*RestoreChanBackupRequest))
1✔
3031
        }
1✔
3032
        return interceptor(ctx, in, info, handler)
1✔
3033
}
3034

3035
func _Lightning_SubscribeChannelBackups_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
3036
        m := new(ChannelBackupSubscription)
1✔
3037
        if err := stream.RecvMsg(m); err != nil {
1✔
3038
                return err
×
3039
        }
×
3040
        return srv.(LightningServer).SubscribeChannelBackups(m, &lightningSubscribeChannelBackupsServer{stream})
1✔
3041
}
3042

3043
type Lightning_SubscribeChannelBackupsServer interface {
3044
        Send(*ChanBackupSnapshot) error
3045
        grpc.ServerStream
3046
}
3047

3048
type lightningSubscribeChannelBackupsServer struct {
3049
        grpc.ServerStream
3050
}
3051

3052
func (x *lightningSubscribeChannelBackupsServer) Send(m *ChanBackupSnapshot) error {
1✔
3053
        return x.ServerStream.SendMsg(m)
1✔
3054
}
1✔
3055

3056
func _Lightning_BakeMacaroon_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3057
        in := new(BakeMacaroonRequest)
1✔
3058
        if err := dec(in); err != nil {
1✔
3059
                return nil, err
×
3060
        }
×
3061
        if interceptor == nil {
1✔
3062
                return srv.(LightningServer).BakeMacaroon(ctx, in)
×
3063
        }
×
3064
        info := &grpc.UnaryServerInfo{
1✔
3065
                Server:     srv,
1✔
3066
                FullMethod: "/lnrpc.Lightning/BakeMacaroon",
1✔
3067
        }
1✔
3068
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3069
                return srv.(LightningServer).BakeMacaroon(ctx, req.(*BakeMacaroonRequest))
1✔
3070
        }
1✔
3071
        return interceptor(ctx, in, info, handler)
1✔
3072
}
3073

3074
func _Lightning_ListMacaroonIDs_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3075
        in := new(ListMacaroonIDsRequest)
1✔
3076
        if err := dec(in); err != nil {
1✔
3077
                return nil, err
×
3078
        }
×
3079
        if interceptor == nil {
1✔
3080
                return srv.(LightningServer).ListMacaroonIDs(ctx, in)
×
3081
        }
×
3082
        info := &grpc.UnaryServerInfo{
1✔
3083
                Server:     srv,
1✔
3084
                FullMethod: "/lnrpc.Lightning/ListMacaroonIDs",
1✔
3085
        }
1✔
3086
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3087
                return srv.(LightningServer).ListMacaroonIDs(ctx, req.(*ListMacaroonIDsRequest))
1✔
3088
        }
1✔
3089
        return interceptor(ctx, in, info, handler)
1✔
3090
}
3091

3092
func _Lightning_DeleteMacaroonID_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3093
        in := new(DeleteMacaroonIDRequest)
1✔
3094
        if err := dec(in); err != nil {
1✔
3095
                return nil, err
×
3096
        }
×
3097
        if interceptor == nil {
1✔
3098
                return srv.(LightningServer).DeleteMacaroonID(ctx, in)
×
3099
        }
×
3100
        info := &grpc.UnaryServerInfo{
1✔
3101
                Server:     srv,
1✔
3102
                FullMethod: "/lnrpc.Lightning/DeleteMacaroonID",
1✔
3103
        }
1✔
3104
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3105
                return srv.(LightningServer).DeleteMacaroonID(ctx, req.(*DeleteMacaroonIDRequest))
1✔
3106
        }
1✔
3107
        return interceptor(ctx, in, info, handler)
1✔
3108
}
3109

3110
func _Lightning_ListPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3111
        in := new(ListPermissionsRequest)
1✔
3112
        if err := dec(in); err != nil {
1✔
3113
                return nil, err
×
3114
        }
×
3115
        if interceptor == nil {
1✔
3116
                return srv.(LightningServer).ListPermissions(ctx, in)
×
3117
        }
×
3118
        info := &grpc.UnaryServerInfo{
1✔
3119
                Server:     srv,
1✔
3120
                FullMethod: "/lnrpc.Lightning/ListPermissions",
1✔
3121
        }
1✔
3122
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3123
                return srv.(LightningServer).ListPermissions(ctx, req.(*ListPermissionsRequest))
1✔
3124
        }
1✔
3125
        return interceptor(ctx, in, info, handler)
1✔
3126
}
3127

3128
func _Lightning_CheckMacaroonPermissions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3129
        in := new(CheckMacPermRequest)
1✔
3130
        if err := dec(in); err != nil {
1✔
3131
                return nil, err
×
3132
        }
×
3133
        if interceptor == nil {
1✔
3134
                return srv.(LightningServer).CheckMacaroonPermissions(ctx, in)
×
3135
        }
×
3136
        info := &grpc.UnaryServerInfo{
1✔
3137
                Server:     srv,
1✔
3138
                FullMethod: "/lnrpc.Lightning/CheckMacaroonPermissions",
1✔
3139
        }
1✔
3140
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3141
                return srv.(LightningServer).CheckMacaroonPermissions(ctx, req.(*CheckMacPermRequest))
1✔
3142
        }
1✔
3143
        return interceptor(ctx, in, info, handler)
1✔
3144
}
3145

3146
func _Lightning_RegisterRPCMiddleware_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
3147
        return srv.(LightningServer).RegisterRPCMiddleware(&lightningRegisterRPCMiddlewareServer{stream})
1✔
3148
}
1✔
3149

3150
type Lightning_RegisterRPCMiddlewareServer interface {
3151
        Send(*RPCMiddlewareRequest) error
3152
        Recv() (*RPCMiddlewareResponse, error)
3153
        grpc.ServerStream
3154
}
3155

3156
type lightningRegisterRPCMiddlewareServer struct {
3157
        grpc.ServerStream
3158
}
3159

3160
func (x *lightningRegisterRPCMiddlewareServer) Send(m *RPCMiddlewareRequest) error {
1✔
3161
        return x.ServerStream.SendMsg(m)
1✔
3162
}
1✔
3163

3164
func (x *lightningRegisterRPCMiddlewareServer) Recv() (*RPCMiddlewareResponse, error) {
1✔
3165
        m := new(RPCMiddlewareResponse)
1✔
3166
        if err := x.ServerStream.RecvMsg(m); err != nil {
2✔
3167
                return nil, err
1✔
3168
        }
1✔
3169
        return m, nil
1✔
3170
}
3171

3172
func _Lightning_SendCustomMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3173
        in := new(SendCustomMessageRequest)
1✔
3174
        if err := dec(in); err != nil {
1✔
3175
                return nil, err
×
3176
        }
×
3177
        if interceptor == nil {
1✔
3178
                return srv.(LightningServer).SendCustomMessage(ctx, in)
×
3179
        }
×
3180
        info := &grpc.UnaryServerInfo{
1✔
3181
                Server:     srv,
1✔
3182
                FullMethod: "/lnrpc.Lightning/SendCustomMessage",
1✔
3183
        }
1✔
3184
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3185
                return srv.(LightningServer).SendCustomMessage(ctx, req.(*SendCustomMessageRequest))
1✔
3186
        }
1✔
3187
        return interceptor(ctx, in, info, handler)
1✔
3188
}
3189

3190
func _Lightning_SubscribeCustomMessages_Handler(srv interface{}, stream grpc.ServerStream) error {
1✔
3191
        m := new(SubscribeCustomMessagesRequest)
1✔
3192
        if err := stream.RecvMsg(m); err != nil {
1✔
3193
                return err
×
3194
        }
×
3195
        return srv.(LightningServer).SubscribeCustomMessages(m, &lightningSubscribeCustomMessagesServer{stream})
1✔
3196
}
3197

3198
type Lightning_SubscribeCustomMessagesServer interface {
3199
        Send(*CustomMessage) error
3200
        grpc.ServerStream
3201
}
3202

3203
type lightningSubscribeCustomMessagesServer struct {
3204
        grpc.ServerStream
3205
}
3206

3207
func (x *lightningSubscribeCustomMessagesServer) Send(m *CustomMessage) error {
1✔
3208
        return x.ServerStream.SendMsg(m)
1✔
3209
}
1✔
3210

3211
func _Lightning_ListAliases_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
×
3212
        in := new(ListAliasesRequest)
×
3213
        if err := dec(in); err != nil {
×
3214
                return nil, err
×
3215
        }
×
3216
        if interceptor == nil {
×
3217
                return srv.(LightningServer).ListAliases(ctx, in)
×
3218
        }
×
3219
        info := &grpc.UnaryServerInfo{
×
3220
                Server:     srv,
×
3221
                FullMethod: "/lnrpc.Lightning/ListAliases",
×
3222
        }
×
3223
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
×
3224
                return srv.(LightningServer).ListAliases(ctx, req.(*ListAliasesRequest))
×
3225
        }
×
3226
        return interceptor(ctx, in, info, handler)
×
3227
}
3228

3229
func _Lightning_LookupHtlcResolution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
1✔
3230
        in := new(LookupHtlcResolutionRequest)
1✔
3231
        if err := dec(in); err != nil {
1✔
3232
                return nil, err
×
3233
        }
×
3234
        if interceptor == nil {
1✔
3235
                return srv.(LightningServer).LookupHtlcResolution(ctx, in)
×
3236
        }
×
3237
        info := &grpc.UnaryServerInfo{
1✔
3238
                Server:     srv,
1✔
3239
                FullMethod: "/lnrpc.Lightning/LookupHtlcResolution",
1✔
3240
        }
1✔
3241
        handler := func(ctx context.Context, req interface{}) (interface{}, error) {
2✔
3242
                return srv.(LightningServer).LookupHtlcResolution(ctx, req.(*LookupHtlcResolutionRequest))
1✔
3243
        }
1✔
3244
        return interceptor(ctx, in, info, handler)
1✔
3245
}
3246

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