es_block

type BlockError func(w BlockWriter, offset int64, err error)

type BlockFinisher func(w BlockWriter, size int64)

type BlockReader interface {
	// FileBlocks Returns offsets of the file.
	FileBlocks(path string) (offsets []int64, err error)

	// ReadBlock Returns block data.
	ReadBlock(path string, offset int64) (data []byte, isLastBlock bool, err error)
}

type BlockRequester func(w BlockWriter, offset, blockSize int64)

type BlockWriter interface {
	WriteBlock(data []byte, offset int64)

	// Abort abort operation and clean up resources, then send error report
	Abort(offset int64, err error)

	// Path file path to write
	Path() string

	// Wait for finish
	Wait()
}

type BlockWriterFactory interface {
	// Open a file with the block size.
	Open(path string, fileSize int64, req BlockRequester, fin BlockFinisher, be BlockError) BlockWriter

	// Wait for finish all writers
	Wait()
}

type Reader interface {
	// ReadBlock Read a block. isEof will be true when it's the last block of the source.
	// EOF will not return error.
	ReadBlock() (block []byte, isEof bool, err error)
}