mirror of
https://github.com/ipfs/kubo.git
synced 2026-02-25 20:37:53 +08:00
restore boxo KeyChanFunc
This commit is contained in:
parent
2dfcd3d8a2
commit
d7d3e2bcfa
@ -4,6 +4,7 @@ import (
|
||||
"context"
|
||||
"time"
|
||||
|
||||
provider "github.com/ipfs/boxo/provider"
|
||||
"github.com/ipfs/go-cid"
|
||||
"github.com/ipfs/kubo/config"
|
||||
"github.com/ipfs/kubo/repo"
|
||||
@ -29,7 +30,7 @@ func (r *NoopReprovider) InstantProvide(context.Context, ...mh.Multihash) error
|
||||
func (r *NoopReprovider) ForceProvide(context.Context, ...mh.Multihash) error { return nil }
|
||||
|
||||
func Reprovider(cfg *config.Config) fx.Option {
|
||||
mhStore := fx.Provide(func(keyProvider rds.KeyChanFunc, repo repo.Repo) (*rds.MHStore, error) {
|
||||
mhStore := fx.Provide(func(keyProvider provider.KeyChanFunc, repo repo.Repo) (*rds.MHStore, error) {
|
||||
return rds.NewMHStore(context.Background(), repo.Datastore(),
|
||||
rds.WithPrefixLen(10),
|
||||
rds.WithDatastorePrefix("/reprovider/mhs"),
|
||||
|
||||
Loading…
Reference in New Issue
Block a user