pump

type APICollector struct {
	URL string
}

type APIDrain struct {
	// contains filtered or unexported fields
}

type APIPinEnumerator struct {
	URL string
	// contains filtered or unexported fields
}

type Block struct {
	Error error
	CID   cid.Cid
	Data  []byte
}

type BlockInfo struct {
	Error error
	CID   cid.Cid
}

type Collector interface {
	// Blocks read each CID from the input, retrieve the corresponding
	// block and emit it to the output
	Blocks(in <-chan BlockInfo, out chan<- Block) error
}

type DatastoreCollector struct {
	// contains filtered or unexported fields
}

type DatastoreDrain struct {
	// contains filtered or unexported fields
}

type DatastoreEnumerator struct {
	// contains filtered or unexported fields
}

type Drain interface {
	Drain(block Block) error
}

type Enumerator interface {
	// TotalCount return the total number of existing blocks,
	// or -1 if unknown/unsupported.
	TotalCount() int

	// CIDs emit in the given channel each CID existing in the source
	CIDs(out chan<- BlockInfo) error
}

type FailedBlocksWriter interface {
	Write(c cid.Cid) (int, error)
	Flush() error
	Count() uint
}

type FileEnumerator struct {
	// contains filtered or unexported fields
}

type FileEnumeratorWriter struct {
	// contains filtered or unexported fields
}

type MockCollector struct {
	// contains filtered or unexported fields
}

type MockDrain struct {
	Drained uint32
}

type MockEnumerator struct {
	// contains filtered or unexported fields
}

type MockFailingDrain struct {
	Drained uint32

	// How many blocks we want the Drain() to simulate as failed
	BlocksToFail uint
}

type NullableFileEnumeratorWriter struct {
	// contains filtered or unexported fields
}