Method FinishWriting

worker/export.go:543–575

(w *Writers)

}

func (r *remoteExportStorage) FinishWriting(w *Writers) (ExportedFiles, error) {
	defer func() {
		glog.Infof("Deleting temporary export directory %s\n", r.les.destination)
		if err := os.RemoveAll(r.les.destination); err != nil {
			glog.Errorf("error deleting temporary export directory: %w", err)
		}
	}()

	files, err := r.les.FinishWriting(w)
	if err != nil {
		return nil, err
	}

	for _, f := range files {
		var d string
		if r.prefix == "" {
			d = f
		} else {
			d = r.prefix + "/" + f
		}
		filePath := filepath.Join(r.les.destination, f)
		// FIXME: tejas [06/2020] - We could probably stream these results, but it's easier to copy for now
		glog.Infof("Uploading from %s to %s\n", filePath, d)
		_, err := r.mc.FPutObject(context.Background(), r.bucket, d, filePath, minio.PutObjectOptions{
			ContentType: "application/gzip",
		})
		if err != nil {
			return nil, err
		}
	}

	return files, nil
}

func NewExportStorage(in *pb.ExportRequest, backupName string) (ExportStorage, error) {
	switch {