mirror of
https://github.com/ipfs/kubo.git
synced 2026-02-21 18:37:45 +08:00
92c4dc61a8
* Delegated Routing. Implementation of Reframe specs (https://github.com/ipfs/specs/blob/master/REFRAME.md) using go-delegated-routing library. * Requested changes. * Init using op string * Separate possible ContentRouters for TopicDiscovery. If we don't do this, we have a ciclic dependency creating TieredRouter. Now we can create first all possible content routers, and after that, create Routers. * Set dht default routing type * Add tests and remove uneeded code * Add documentation. * docs: Routing.Routers * Requested changes. Signed-off-by: Antonio Navarro Perez <antnavper@gmail.com> * Add some documentation on new fx functions. * Add changelog entry and integration tests * test: sharness for 'dht' in 'routing' commands Since 'routing' is currently the same as 'dht' (minus query command) we need to test both, that way we won't have unnoticed divergence in the default behavior. * test(sharness): delegated routing via reframe URL * Add more tests for delegated routing. * If any put operation fails, the tiered router will fail. * refactor: Routing.Routers: Parameters.Endpoint As agreed in https://github.com/ipfs/kubo/pull/8997#issuecomment-1175684716 * Try to improve CHANGELOG entry. * chore: update reframe spec link * Update go-delegated-routing dependency * Fix config error test * use new changelog format * Remove port conflict * go mod tidy * ProviderManyWrapper to ProviderMany * Update docs/changelogs/v0.14.md Co-authored-by: Adin Schmahmann <adin.schmahmann@gmail.com> Co-authored-by: Marcin Rataj <lidel@lidel.org> Co-authored-by: Adin Schmahmann <adin.schmahmann@gmail.com>
67 lines
1.6 KiB
Go
67 lines
1.6 KiB
Go
package routing
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/ipfs/go-cid"
|
|
drc "github.com/ipfs/go-delegated-routing/client"
|
|
"github.com/libp2p/go-libp2p-core/peer"
|
|
"github.com/libp2p/go-libp2p-core/routing"
|
|
"github.com/multiformats/go-multihash"
|
|
"golang.org/x/sync/errgroup"
|
|
)
|
|
|
|
var _ routing.Routing = &reframeRoutingWrapper{}
|
|
|
|
// reframeRoutingWrapper is a wrapper needed to construct the routing.Routing interface from
|
|
// delegated-routing library.
|
|
type reframeRoutingWrapper struct {
|
|
*drc.Client
|
|
*drc.ContentRoutingClient
|
|
}
|
|
|
|
func (c *reframeRoutingWrapper) FindProvidersAsync(ctx context.Context, cid cid.Cid, count int) <-chan peer.AddrInfo {
|
|
return c.ContentRoutingClient.FindProvidersAsync(ctx, cid, count)
|
|
}
|
|
|
|
func (c *reframeRoutingWrapper) Bootstrap(ctx context.Context) error {
|
|
return nil
|
|
}
|
|
|
|
func (c *reframeRoutingWrapper) FindPeer(ctx context.Context, id peer.ID) (peer.AddrInfo, error) {
|
|
return peer.AddrInfo{}, routing.ErrNotSupported
|
|
}
|
|
|
|
type ProvideMany interface {
|
|
ProvideMany(ctx context.Context, keys []multihash.Multihash) error
|
|
Ready() bool
|
|
}
|
|
|
|
var _ ProvideMany = &ProvideManyWrapper{}
|
|
|
|
type ProvideManyWrapper struct {
|
|
pms []ProvideMany
|
|
}
|
|
|
|
func (pmw *ProvideManyWrapper) ProvideMany(ctx context.Context, keys []multihash.Multihash) error {
|
|
var g errgroup.Group
|
|
for _, pm := range pmw.pms {
|
|
pm := pm
|
|
g.Go(func() error {
|
|
return pm.ProvideMany(ctx, keys)
|
|
})
|
|
}
|
|
|
|
return g.Wait()
|
|
}
|
|
|
|
// Ready is ready if all providers are ready
|
|
func (pmw *ProvideManyWrapper) Ready() bool {
|
|
out := true
|
|
for _, pm := range pmw.pms {
|
|
out = out && pm.Ready()
|
|
}
|
|
|
|
return out
|
|
}
|