Method compress

helper/server/downstream.go:199–220

Compress compresses the given files and folders into a tar archive

(writer io.WriteCloser, files []string)

// Compress compresses the given files and folders into a tar archive
func (d *Downstream) compress(writer io.WriteCloser, files []string) error {
	defer writer.Close()

	// Use compression
	gw := gzip.NewWriter(writer)
	defer gw.Close()

	tarWriter := tar.NewWriter(gw)
	defer tarWriter.Close()

	writtenFiles := make(map[string]bool)
	for _, path := range files {
		if _, ok := writtenFiles[path]; !ok {
			err := recursiveTar(d.options.RemotePath, path, writtenFiles, tarWriter, true)
			if err != nil {
				return errors.Wrapf(err, "compress %s", path)
			}
		}
	}

	return nil
}

// Ping returns empty
func (d *Downstream) Ping(context.Context, *remote.Empty) (*remote.Empty, error) {