mirrors/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-01-18 21:35:24 +01:00
Code Issues Projects Releases Wiki Activity

lnd: use impl cfg TlvTrafficShaper

Browse Source
This commit is contained in:
George Tsagkarelis 2024-04-19 14:00:34 +02:00 committed by Oliver Gugger
parent f04fa54622
commit c39143052e
No known key found for this signature in database
GPG Key ID: 8E4256593F177720
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
config_builder.go
View File

@ -44,6 +44,7 @@ import (
"github.com/lightningnetwork/lnd/lnwallet/rpcwallet" "github.com/lightningnetwork/lnd/lnwallet/rpcwallet"
"github.com/lightningnetwork/lnd/macaroons" "github.com/lightningnetwork/lnd/macaroons"
"github.com/lightningnetwork/lnd/msgmux" "github.com/lightningnetwork/lnd/msgmux"
"github.com/lightningnetwork/lnd/routing"
"github.com/lightningnetwork/lnd/rpcperms" "github.com/lightningnetwork/lnd/rpcperms"
"github.com/lightningnetwork/lnd/signal" "github.com/lightningnetwork/lnd/signal"
"github.com/lightningnetwork/lnd/sqldb" "github.com/lightningnetwork/lnd/sqldb"
@ -159,6 +160,10 @@ type AuxComponents struct {
// channels to fetch+store various data. // channels to fetch+store various data.
AuxLeafStore fn.Option[lnwallet.AuxLeafStore] AuxLeafStore fn.Option[lnwallet.AuxLeafStore]
// TrafficShaper is an optional traffic shaper that can be used to
// control the outgoing channel of a payment.
TrafficShaper fn.Option[routing.TlvTrafficShaper]
// MsgRouter is an optional message router that if set will be used in // MsgRouter is an optional message router that if set will be used in
// place of a new blank default message router. // place of a new blank default message router.
MsgRouter fn.Option[msgmux.Router] MsgRouter fn.Option[msgmux.Router]

1
server.go
View File

@ -1022,6 +1022,7 @@ func newServer(cfg *Config, listenAddrs []net.Addr,
Clock: clock.NewDefaultClock(), Clock: clock.NewDefaultClock(),
ApplyChannelUpdate: s.graphBuilder.ApplyChannelUpdate, ApplyChannelUpdate: s.graphBuilder.ApplyChannelUpdate,
ClosedSCIDs: s.fetchClosedChannelSCIDs(), ClosedSCIDs: s.fetchClosedChannelSCIDs(),
TrafficShaper: implCfg.TrafficShaper,
}) })
if err != nil { if err != nil {
return nil, fmt.Errorf("can't create router: %w", err) return nil, fmt.Errorf("can't create router: %w", err)