EncoderDelegate holds methods that are called during the encode process.
| 40 | // EncoderDelegate holds methods that are called during the encode |
| 41 | // process. |
| 42 | type EncoderDelegate interface { |
| 43 | OnDataFileLoad(i, n int, path string, byteCount int, err error) |
| 44 | OnIndexFileWrite(path string, byteCount int, err error) |
| 45 | OnRecoveryFileWrite(start, count, total int, path string, dataByteCount, byteCount int, err error) |
| 46 | } |
| 47 | |
| 48 | func newEncoder(fileIO fileIO, delegate EncoderDelegate, basePath string, filePaths []string, sliceByteCount, parityShardCount, numGoroutines int) (*Encoder, error) { |
| 49 | if !filepath.IsAbs(basePath) { |
no outgoing calls
no test coverage detected