mirror of
https://github.com/ipfs/kubo.git
synced 2026-02-21 10:27:46 +08:00
6a008fc74c
* chore: apply go fix modernizers from Go 1.26
automated refactoring: interface{} to any, slices.Contains,
and other idiomatic updates.
* feat(ci): add `go fix` check to Go analysis workflow
ensures Go 1.26 modernizers are applied, fails CI if `go fix ./...`
produces any changes (similar to existing `go fmt` enforcement)
31 lines
790 B
Go
31 lines
790 B
Go
package libp2p
|
|
|
|
import (
|
|
"math/rand"
|
|
"time"
|
|
|
|
"github.com/libp2p/go-libp2p/core/discovery"
|
|
"github.com/libp2p/go-libp2p/core/host"
|
|
"github.com/libp2p/go-libp2p/p2p/discovery/backoff"
|
|
disc "github.com/libp2p/go-libp2p/p2p/discovery/routing"
|
|
|
|
"github.com/libp2p/go-libp2p/core/routing"
|
|
)
|
|
|
|
func TopicDiscovery() any {
|
|
return func(host host.Host, cr routing.ContentRouting) (service discovery.Discovery, err error) {
|
|
baseDisc := disc.NewRoutingDiscovery(cr)
|
|
minBackoff, maxBackoff := time.Second*60, time.Hour
|
|
rng := rand.New(rand.NewSource(rand.Int63()))
|
|
d, err := backoff.NewBackoffDiscovery(
|
|
baseDisc,
|
|
backoff.NewExponentialBackoff(minBackoff, maxBackoff, backoff.FullJitter, time.Second, 5.0, 0, rng),
|
|
)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return d, nil
|
|
}
|
|
}
|