Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

simple

package

Go to main page

Versions in this module

v0

v0.0.3

Aug 30, 2021

v0.0.2

Aug 24, 2021

v0.0.1

Aug 23, 2021

Changes in this version

+ var ErrClosed = errors.New("reprovider service stopped")

+ type KeyChanFunc func(context.Context) (<-chan cid.Cid, error)

+ func NewBlockstoreProvider(bstore blocks.Blockstore) KeyChanFunc

+ func NewPinnedProvider(onlyRoots bool, pinning Pinner, dag ld.DAGService) KeyChanFunc

+ type Option func(*Provider)

+ func MaxWorkers(count int) Option

+ func WithTimeout(timeout time.Duration) Option

+ type Pinner interface

+ DirectKeys func(ctx context.Context) ([]cid.Cid, error)

+ RecursiveKeys func(ctx context.Context) ([]cid.Cid, error)

+ type Provider struct

+ func NewProvider(ctx context.Context, queue *q.Queue, contentRouting routing.ContentRouting, ...) *Provider

+ func (p *Provider) Close() error

+ func (p *Provider) Provide(root cid.Cid) error

+ func (p *Provider) Run()

+ type Reprovider struct

+ func NewReprovider(ctx context.Context, reprovideIniterval time.Duration, ...) *Reprovider

+ func (rp *Reprovider) Close() error

+ func (rp *Reprovider) Reprovide() error

+ func (rp *Reprovider) Run()

+ func (rp *Reprovider) Trigger(ctx context.Context) error