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 ¶
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.
func (*Reprovider) Run ¶
func (rp *Reprovider) Run(proc goprocess.Process)
Run re-provides keys with 'tick' interval or when triggered
 Click to show internal directories. 
   Click to hide internal directories.