(fpath string)
| 404 | } |
| 405 | |
| 406 | func (writer *ExportWriter) open(fpath string) error { |
| 407 | var err error |
| 408 | writer.fd, err = os.Create(fpath) |
| 409 | if err != nil { |
| 410 | return err |
| 411 | } |
| 412 | writer.bw = bufio.NewWriterSize(writer.fd, 1e6) |
| 413 | w, err := enc.GetWriter(x.WorkerConfig.EncryptionKey, writer.bw) |
| 414 | if err != nil { |
| 415 | return err |
| 416 | } |
| 417 | writer.gw, err = gzip.NewWriterLevel(w, gzip.BestSpeed) |
| 418 | return err |
| 419 | } |
| 420 | |
| 421 | func (writer *ExportWriter) Close() error { |
| 422 | if err := writer.gw.Flush(); err != nil { |