coosld/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2026-03-03 07:18:12 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

back to start

Browse Source
This commit is contained in:
guillaumemichel 2025-06-11 15:55:40 +02:00 committed by gammazero
parent 456c69beb6
commit b62ac647c8
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
core/node/groups.go
View File

@ -17,7 +17,6 @@ import (
"github.com/ipfs/kubo/config"
"github.com/ipfs/kubo/core/node/libp2p"
"github.com/ipfs/kubo/p2p"
"github.com/libp2p/go-libp2p-kad-dht/reprovider"
pubsub "github.com/libp2p/go-libp2p-pubsub"
"github.com/libp2p/go-libp2p-pubsub/timecache"
"github.com/libp2p/go-libp2p/core/peer"
@ -366,18 +365,18 @@ func Online(bcfg *BuildCfg, cfg *config.Config, userResourceOverrides rcmgr.Part
fx.Provide(p2p.New),
LibP2P(bcfg, cfg, userResourceOverrides),
// OnlineProviders(
// isProviderEnabled,
// cfg.Reprovider.Strategy.WithDefault(config.DefaultReproviderStrategy),
// cfg.Reprovider.Interval.WithDefault(config.DefaultReproviderInterval),
// cfg.Routing.AcceleratedDHTClient.WithDefault(config.DefaultAcceleratedDHTClient),
// int(cfg.Provider.WorkerCount.WithDefault(config.DefaultProviderWorkerCount)),
// ),
SweepingReprovider(
OnlineProviders(
isProviderEnabled,
cfg.Reprovider.Strategy.WithDefault(config.DefaultReproviderStrategy),
reprovider.WithReprovideInterval(cfg.Reprovider.Interval.WithDefault(config.DefaultReproviderInterval)),
cfg.Reprovider.Interval.WithDefault(config.DefaultReproviderInterval),
cfg.Routing.AcceleratedDHTClient.WithDefault(config.DefaultAcceleratedDHTClient),
int(cfg.Provider.WorkerCount.WithDefault(config.DefaultProviderWorkerCount)),
),
// SweepingReprovider(
// isProviderEnabled,
// cfg.Reprovider.Strategy.WithDefault(config.DefaultReproviderStrategy),
// reprovider.WithReprovideInterval(cfg.Reprovider.Interval.WithDefault(config.DefaultReproviderInterval)),
// ),
)
}