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

pump

package

Go to main page

Versions in this module

v1

v1.3.0

Jun 4, 2021

v1.2.0

Jun 4, 2021

Changes in this version

+ func PumpIt(enumerator Enumerator, collector Collector, drain Drain, ...)

+ type APICollector struct

+ URL string

+ func NewAPICollector(URL string) *APICollector

+ func (a *APICollector) Blocks(in <-chan BlockInfo, out chan<- Block) error

+ type APIDrain struct

+ func NewAPIDrain(URL string) *APIDrain

+ func NewAPIDrainWithShell(shell *shell.Shell) *APIDrain

+ func (a *APIDrain) Drain(block Block) error

+ type APIPinEnumerator struct

+ URL string

+ func NewAPIPinEnumerator(URL string, stream bool) *APIPinEnumerator

+ func (a *APIPinEnumerator) CIDs(out chan<- BlockInfo) error

+ func (a *APIPinEnumerator) TotalCount() int

+ type Block struct

+ CID cid.Cid

+ Data []byte

+ Error error

+ type BlockInfo struct

+ CID cid.Cid

+ Error error

+ type Collector interface

+ Blocks func(in <-chan BlockInfo, out chan<- Block) error

+ type CountedDrain interface

+ SuccessfulBlocksCount func() uint64

+ type CounterDrain struct

+ func NewCountedDrain(drain Drain) *CounterDrain

+ func (c *CounterDrain) Drain(block Block) error

+ func (c *CounterDrain) SuccessfulBlocksCount() uint64

+ type DatastoreCollector struct

+ func NewBadgerCollector(path string) (*DatastoreCollector, error)

+ func NewDatastoreCollector(dstore ds.Datastore) *DatastoreCollector

+ func NewFlatFSCollector(path string) (*DatastoreCollector, error)

+ func NewS3Collector(config s3ds.Config) (*DatastoreCollector, error)

+ func (d *DatastoreCollector) Blocks(in <-chan BlockInfo, out chan<- Block) error

+ type DatastoreDrain struct

+ func NewBadgerDrain(path string) (*DatastoreDrain, error)

+ func NewDatastoreDrain(dstore ds.Datastore) *DatastoreDrain

+ func NewFlatFSDrain(path string) (*DatastoreDrain, error)

+ func NewS3Drain(config s3ds.Config) (*DatastoreDrain, error)

+ func (d *DatastoreDrain) Drain(block Block) error

+ type DatastoreEnumerator struct

+ func NewBadgerEnumerator(path string) (*DatastoreEnumerator, error)

+ func NewDatastoreEnumerator(dstore ds.Datastore) *DatastoreEnumerator

+ func NewFlatFSEnumerator(path string) (*DatastoreEnumerator, error)

+ func NewS3Enumerator(config s3ds.Config) (*DatastoreEnumerator, error)

+ func (*DatastoreEnumerator) TotalCount() int

+ func (d *DatastoreEnumerator) CIDs(out chan<- BlockInfo) error

+ type Drain interface

+ Drain func(block Block) error

+ type Enumerator interface

+ CIDs func(out chan<- BlockInfo) error

+ TotalCount func() int

+ type FailedBlocksWriter interface

+ Count func() uint

+ Flush func() error

+ Write func(c cid.Cid) (int, error)

+ func NewFileEnumeratorWriter(path string) (enumWriter FailedBlocksWriter, close func() error, err error)

+ func NewNullableFileEnumeratorWriter() FailedBlocksWriter

+ type FileEnumerator struct

+ func NewFileEnumerator(file io.ReadSeeker) (*FileEnumerator, error)

+ func (f *FileEnumerator) CIDs(out chan<- BlockInfo) error

+ func (f *FileEnumerator) TotalCount() int

+ type FileEnumeratorWriter struct

+ func (f *FileEnumeratorWriter) Count() uint

+ func (f *FileEnumeratorWriter) Flush() error

+ func (f *FileEnumeratorWriter) Write(c cid.Cid) (int, error)

+ type MockCollector struct

+ func NewMockCollector(source *sync.Map) *MockCollector

+ func (m *MockCollector) Blocks(in <-chan BlockInfo, out chan<- Block) error

+ type MockEnumerator struct

+ func (m *MockEnumerator) CIDs(out chan<- BlockInfo) error

+ func (m *MockEnumerator) TotalCount() int

+ type NullProgressWriter struct

+ func NewNullProgressWriter() *NullProgressWriter

+ func (p *NullProgressWriter) Finish()

+ func (p *NullProgressWriter) Increment() int

+ func (p *NullProgressWriter) Prefix(elem string)

+ func (p *NullProgressWriter) SetTotal(total int)

+ type NullableFileEnumeratorWriter struct

+ func (f *NullableFileEnumeratorWriter) Count() uint

+ func (f *NullableFileEnumeratorWriter) Flush() error

+ func (f *NullableFileEnumeratorWriter) Write(c cid.Cid) (int, error)

+ type ProgressBarWriter struct

+ func NewProgressWriter() *ProgressBarWriter

+ func (p *ProgressBarWriter) Finish()

+ func (p *ProgressBarWriter) Increment() int

+ func (p *ProgressBarWriter) Prefix(elem string)

+ func (p *ProgressBarWriter) SetTotal(total int)

+ type ProgressWriter interface

+ Finish func()

+ Increment func() int

+ Prefix func(elem string)

+ SetTotal func(total int)

v1.1.0

Jun 1, 2021

v1.0.0

Sep 3, 2020