Method CreateShard

dsort/extract/zip.go:168–186

CreateShard creates a new shard locally based on the Shard. Note that the order of closing must be trw, gzw, then finally tarball.

(s *Shard, w io.Writer, loadContent LoadContentFunc)

// CreateShard creates a new shard locally based on the Shard.
// Note that the order of closing must be trw, gzw, then finally tarball.
func (z *zipExtractCreator) CreateShard(s *Shard, w io.Writer, loadContent LoadContentFunc) (written int64, err error) {
	var n int64
	zw := zip.NewWriter(w)
	defer cos.Close(zw)

	rdReader := newZipRecordDataReader(z.t)
	for _, rec := range s.Records.All() {
		for _, obj := range rec.Objects {
			rdReader.reinit(zw, obj.Size, obj.MetadataSize)
			if n, err = loadContent(rdReader, rec, obj); err != nil {
				return written + n, err
			}

			written += n
		}
	}
	rdReader.free()
	return written, nil
}

func (*zipExtractCreator) UsingCompression() bool { return true }
func (*zipExtractCreator) SupportsOffset() bool   { return false }