Documentation
¶
Overview ¶
Package simple implements structures and methods to provide blocks, keep track of which blocks are provided, and to allow those blocks to be reprovided.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KeyChanFunc ¶
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
func NewPinnedProvider ¶
func NewPinnedProvider(onlyRoots bool, pinning Pinner, dag ipld.DAGService) KeyChanFunc
NewPinnedProvider returns provider supplying pinned keys
type Pinner ¶
Pinner interface defines how the simple.Reprovider wants to interact with a Pinning service
type Provider ¶
type Provider struct {
// contains filtered or unexported fields
}
Provider announces blocks to the network
func NewProvider ¶
func NewProvider(ctx context.Context, queue *q.Queue, contentRouting routing.ContentRouting) *Provider
NewProvider creates a provider that announces blocks to the network using a content router
type Reprovider ¶
type Reprovider struct {
// contains filtered or unexported fields
}
Reprovider reannounces blocks to the network
func NewReprovider ¶
func NewReprovider(ctx context.Context, reprovideIniterval time.Duration, rsys routing.ContentRouting, keyProvider KeyChanFunc) *Reprovider
NewReprovider creates new Reprovider instance.
func (*Reprovider) Reprovide ¶
func (rp *Reprovider) Reprovide() error
Reprovide registers all keys given by rp.keyProvider to libp2p content routing
func (*Reprovider) Run ¶
func (rp *Reprovider) Run()
Run re-provides keys with 'tick' interval or when triggered
Source Files