Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPinnedProvider ¶
func NewPinnedProvider(onlyRoots bool) func(pinning pin.Pinner, dag ipld.DAGService) KeyChanFunc
NewPinnedProvider returns provider supplying pinned keys
Types ¶
type KeyChanFunc ¶
type KeyChanFunc func(context.Context) (<-chan cid.Cid, error)
KeyChanFunc is function streaming CIDs to pass to content routing
func NewBlockstoreProvider ¶
func NewBlockstoreProvider(bstore blocks.Blockstore) KeyChanFunc
NewBlockstoreProvider returns key provider using bstore.AllKeysChan
type Reprovider ¶
type Reprovider struct {
// contains filtered or unexported fields
}
func NewReprovider ¶
func NewReprovider(ctx context.Context, tick time.Duration, rsys routing.ContentRouting, keyProvider KeyChanFunc) *Reprovider
NewReprovider creates new Reprovider instance.
Click to show internal directories.
Click to hide internal directories.