blobref

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

type ChanPeeker struct {
	Ch <-chan SizedBlobRef
	// contains filtered or unexported fields
}

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

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

type ReadSeekCloser interface {
	io.Reader
	io.Seeker
	io.Closer
}

type SeekFetcher interface {
	// Fetch returns a blob.  If the blob is not found then
	// os.ErrNotExist should be returned for the error (not a wrapped
	// error with a ErrNotExist inside)
	//
	// The caller should close blob.
	Fetch(*BlobRef) (blob ReadSeekCloser, size int64, err error)
}

type SeekTester interface {
	IsFetcherASeeker() bool
}

type SizedBlobRef struct {
	*BlobRef
	Size int64
}

type StreamingFetcher interface {
	// FetchStreaming returns a blob.  If the blob is not found then
	// os.ErrNotExist should be returned for the error (not a wrapped
	// error with a ErrNotExist inside)
	//
	// The caller should close blob.
	FetchStreaming(*BlobRef) (blob io.ReadCloser, size int64, err error)
}